client.swarm.swarm_task

Swarm side task object.

Attributes

logger

Classes

SwarmTask

Swarm side task object.

Module Contents

client.swarm.swarm_task.logger[source]

class client.swarm.swarm_task.SwarmTask(task_id: int, array_id: int, status: str, max_attempts: int, task_resources: jobmon.client.task_resources.TaskResources, cluster: jobmon.core.cluster.Cluster, resource_scales: Dict | None = None, fallback_queues: List[jobmon.core.cluster_protocol.ClusterQueue] | None = None, compute_resources_callable: Callable | None = None)[source]

Bases: object

Swarm side task object.

task_id[source]

array_id[source]

status[source]

downstream_swarm_tasks: Set[SwarmTask][source]

current_task_resources[source]

compute_resources_callable = None[source]

fallback_queues = None[source]

resource_scales = None[source]

cluster[source]

max_attempts[source]

num_upstreams: int = 0[source]

num_upstreams_done: int = 0[source]

property all_upstreams_done: bool[source]: Return a bool of if upstreams are done or not.

property downstream_tasks: List[SwarmTask][source]: Return list of downstream tasks.

__hash__() → int[source]: Returns the ID of the task.

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

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