distributor.task_instance_batch

Attributes

logger

Classes

TaskInstanceBatch

Module Contents

distributor.task_instance_batch.logger[source]

class distributor.task_instance_batch.TaskInstanceBatch(array_id: int, array_name: str, array_batch_num: int, task_resources_id: int, requester: jobmon.core.requester.Requester)[source]

array_id[source]

array_name[source]

batch_number[source]

task_resources_id[source]

task_instances: Set[jobmon.distributor.distributor_task_instance.DistributorTaskInstance][source]

requester[source]

property submission_name: str[source]

property requested_resources: Dict[source]

add_task_instance(task_instsance: jobmon.distributor.distributor_task_instance.DistributorTaskInstance) → None[source]

load_requested_resources() → None[source]

prepare_task_instance_batch_for_launch() → None[source]: Add the current batch number to the current set of registered task instance ids.

set_distributor_ids(distributor_id_map: Dict) → None[source]

Set the distributor_ids on the task instances in the array.

Parameters:: distributor_id_map – map of array_step_id to distributor_id

transition_to_launched(next_report_by: float) → None[source]: Transition all associated task instances to LAUNCHED state.

log_distributor_ids() → None[source]: Log the distributor ID in the database for all task instances in the batch.

__hash__() → int[source]: Hash to encompass tool version id, workflow args, tasks and dag.

__eq__(other: object) → bool[source]: Check if the hashes of two tasks are equivalent.

__lt__(other: TaskInstanceBatch) → bool[source]: Check if one hash is less than the has of another Task.