queue.migrations package

Submodules

queue.migrations.0001_initial module

class queue.migrations.0001_initial.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'job', u'0001_initial')]

operations = [<CreateModel fields=[(u'job_exe', <django.db.models.fields.related.ForeignKey>), (u'is_job_type_paused', <django.db.models.fields.BooleanField>), (u'priority', <django.db.models.fields.IntegerField>), (u'cpus_required', <django.db.models.fields.FloatField>), (u'mem_required', <django.db.models.fields.FloatField>), (u'disk_in_required', <django.db.models.fields.FloatField>), (u'disk_out_required', <django.db.models.fields.FloatField>), (u'disk_total_required', <django.db.models.fields.FloatField>), (u'created', <django.db.models.fields.DateTimeField>), (u'queued', <django.db.models.fields.DateTimeField>), (u'last_modified', <django.db.models.fields.DateTimeField>), (u'job_type', <django.db.models.fields.related.ForeignKey>)], bases=(<class 'django.db.models.base.Model'>,), options={u'db_table': u'queue'}, name=u'Queue'>, <CreateModel fields=[(u'id', <django.db.models.fields.AutoField>), (u'depth_time', <django.db.models.fields.DateTimeField>), (u'depth', <django.db.models.fields.IntegerField>), (u'job_type', <django.db.models.fields.related.ForeignKey>)], bases=(<class 'django.db.models.base.Model'>,), options={u'db_table': u'queue_depth_job_type'}, name=u'QueueDepthByJobType'>, <CreateModel fields=[(u'id', <django.db.models.fields.AutoField>), (u'priority', <django.db.models.fields.IntegerField>), (u'depth_time', <django.db.models.fields.DateTimeField>), (u'depth', <django.db.models.fields.IntegerField>)], bases=(<class 'django.db.models.base.Model'>,), options={u'db_table': u'queue_depth_priority'}, name=u'QueueDepthByPriority'>]

queue.migrations.0002_jobload module

class queue.migrations.0002_jobload.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'job', u'0003_auto_20151016_0849'), (u'queue', u'0001_initial')]

operations = [<CreateModel fields=[(u'id', <django.db.models.fields.AutoField>), (u'measured', <django.db.models.fields.DateTimeField>), (u'pending_count', <django.db.models.fields.IntegerField>), (u'queued_count', <django.db.models.fields.IntegerField>), (u'running_count', <django.db.models.fields.IntegerField>), (u'total_count', <django.db.models.fields.IntegerField>), (u'job_type', <django.db.models.fields.related.ForeignKey>)], bases=(<class 'django.db.models.base.Model'>,), options={u'db_table': u'job_load'}, name=u'JobLoad'>]

queue.migrations.0003_auto_20151023_1104 module

class queue.migrations.0003_auto_20151023_1104.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0002_jobload')]

operations = [<AlterField field=<django.db.models.fields.related.ForeignKey>, preserve_default=True, name=u'job_type', model_name=u'jobload'>]

queue.migrations.0004_remove_queue_is_job_type_paused module

class queue.migrations.0004_remove_queue_is_job_type_paused.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0003_auto_20151023_1104')]

operations = [<RemoveField name=u'is_job_type_paused', model_name=u'queue'>]

queue.migrations.0005_queue_node_required module

class queue.migrations.0005_queue_node_required.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'node', u'0003_node_is_paused_errors'), (u'queue', u'0004_remove_queue_is_job_type_paused')]

operations = [<AddField field=<django.db.models.fields.related.ForeignKey>, preserve_default=True, name=u'node_required', model_name=u'queue'>]

queue.migrations.0006_auto_20160316_1625 module

class queue.migrations.0006_auto_20160316_1625.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0005_queue_node_required')]

operations = [<RemoveField name=u'job_type', model_name=u'queuedepthbyjobtype'>, <DeleteModel name=u'QueueDepthByJobType'>, <DeleteModel name=u'QueueDepthByPriority'>]

queue.migrations.0007_auto_20160421_1643 module

class queue.migrations.0007_auto_20160421_1643.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'job', u'0016_auto_20160421_1553'), (u'queue', u'0006_auto_20160316_1625')]

operations = [<AddField field=<util.deprecation.JSONStringField>, preserve_default=True, name=u'configuration', model_name=u'queue'>, <AddField field=<django.db.models.fields.related.ForeignKey>, preserve_default=False, name=u'job', model_name=u'queue'>]

queue.migrations.0008_auto_20160421_1648 module

class queue.migrations.0008_auto_20160421_1648.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0007_auto_20160421_1643')]

operations = [<RunPython <function update_queue_models>>]

update_queue_models(apps, schema_editor)

queue.migrations.0009_auto_20170412_1225 module

class queue.migrations.0009_auto_20170412_1225.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0008_auto_20160421_1648')]

operations = [<AlterField field=<django.contrib.postgres.fields.jsonb.JSONField>, name=u'configuration', model_name=u'queue'>, <AlterField field=<django.db.models.fields.related.OneToOneField>, name=u'job_exe', model_name=u'queue'>]

queue.migrations.0010_auto_20170615_1704 module

class queue.migrations.0010_auto_20170615_1704.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0009_auto_20170412_1225')]

operations = [<RenameField new_name=u'input_file_size', model_name=u'queue', old_name=u'disk_in_required'>, <RemoveField name=u'node_required', model_name=u'queue'>, <AddField field=<django.contrib.postgres.fields.jsonb.JSONField>, name=u'resources', model_name=u'queue'>]

queue.migrations.0011_auto_20170616_1052 module

class queue.migrations.0011_auto_20170616_1052.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0010_auto_20170615_1704')]

operations = [<RunPython <function populate_queue_resources>>]

populate_queue_resources(apps, schema_editor)

queue.migrations.0012_auto_20170616_1101 module

class queue.migrations.0012_auto_20170616_1101.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0011_auto_20170616_1052')]

operations = [<RemoveField name=u'cpus_required', model_name=u'queue'>, <RemoveField name=u'disk_out_required', model_name=u'queue'>, <RemoveField name=u'disk_total_required', model_name=u'queue'>, <RemoveField name=u'mem_required', model_name=u'queue'>]

queue.migrations.0013_auto_20170720_1702 module

class queue.migrations.0013_auto_20170720_1702.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0012_auto_20170616_1101')]

operations = [<RemoveField name=u'job', model_name=u'queue'>, <RemoveField name=u'job_exe', model_name=u'queue'>, <RemoveField name=u'job_type', model_name=u'queue'>, <DeleteModel name=u'Queue'>]

queue.migrations.0014_queue module

class queue.migrations.0014_queue.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'job', u'0029_auto_20170707_1034'), (u'queue', u'0013_auto_20170720_1702')]

operations = [<CreateModel fields=[(u'id', <django.db.models.fields.AutoField>), (u'exe_num', <django.db.models.fields.IntegerField>), (u'input_file_size', <django.db.models.fields.FloatField>), (u'is_canceled', <django.db.models.fields.BooleanField>), (u'priority', <django.db.models.fields.IntegerField>), (u'timeout', <django.db.models.fields.IntegerField>), (u'interface', <django.contrib.postgres.fields.jsonb.JSONField>), (u'configuration', <django.contrib.postgres.fields.jsonb.JSONField>), (u'resources', <django.contrib.postgres.fields.jsonb.JSONField>), (u'created', <django.db.models.fields.DateTimeField>), (u'queued', <django.db.models.fields.DateTimeField>), (u'job', <django.db.models.fields.related.ForeignKey>), (u'job_type', <django.db.models.fields.related.ForeignKey>)], options={u'db_table': u'queue'}, name=u'Queue'>]

queue.migrations.0015_auto_20170731_1527 module

class queue.migrations.0015_auto_20170731_1527.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'job', u'0029_auto_20170707_1034'), (u'product', u'0010_auto_20170727_1349'), (u'storage', u'0008_auto_20170609_1443'), (u'queue', u'0014_queue')]

operations = [<RunPython <function populate_queue>>]

populate_queue(apps, schema_editor)

queue.migrations.0015_auto_20170731_1527.get_job_data(self)

Returns the data for this job

Returns:The data for this job Return type:job.configuration.data.job_data.JobData

queue.migrations.0015_auto_20170731_1527.get_secrets_key(self)

Returns the reference key for job type secrets stored in the secrets backend.

Returns:The job_type name and version concatenated Return type:str

queue.migrations.0015_auto_20170731_1527.job_get_job_interface(self)

Returns the interface for this job

Returns:The interface for this job Return type:job.configuration.interface.job_interface.JobInterface

queue.migrations.0015_auto_20170731_1527.job_get_resources(self)

Returns the resources required for this job

Returns:The required resources Return type:node.resources.node_resources.NodeResources

queue.migrations.0015_auto_20170731_1527.job_type_get_job_interface(self)

Returns the interface for running jobs of this type

Returns:The job interface for this type Return type:job.configuration.interface.job_interface.JobInterface

queue.migrations.0015_auto_20170731_1527.job_type_get_resources(self)

Returns the resources required for jobs of this type

Returns:The required resources Return type:node.resources.node_resources.NodeResources

queue.migrations.0016_auto_20180123_2037 module

class queue.migrations.0016_auto_20180123_2037.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'batch', u'0004_auto_20180122_1444'), (u'recipe', u'0020_recipe_batch'), (u'queue', u'0015_auto_20170731_1527')]

operations = [<AddField field=<django.db.models.fields.related.ForeignKey>, name=u'batch', model_name=u'queue'>, <AddField field=<django.db.models.fields.related.ForeignKey>, name=u'recipe', model_name=u'queue'>]

queue.migrations.0017_queue_docker_image module

class queue.migrations.0017_queue_docker_image.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0016_auto_20180123_2037')]

operations = [<AddField field=<django.db.models.fields.TextField>, name=u'docker_image', model_name=u'queue'>]

queue.migrations.0018_queue_docker_image_populate module

class queue.migrations.0018_queue_docker_image_populate.Migration(name, app_label)

Bases: django.db.migrations.migration.Migration

dependencies = [(u'queue', u'0017_queue_docker_image'), (u'job', u'0046_jobtyperevision_docker_image')]

operations = [<RunPython <function populate_queue_with_docker_image>>]

populate_queue_with_docker_image(apps, schema_editor)

Module contents