client.swarm.task

Swarm side task object.

Attributes

logger

Classes

SwarmTask

Swarm side task object.

Module Contents

client.swarm.task.logger
class client.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)

Bases: object

Swarm side task object.

Implementing swarm behavior of tasks.

Parameters:

  • task_id – id of task object from db auto increment.

  • array_id – id of associated array object.

  • status – status of task object.

  • max_attempts – maximum number of task_instances before failure.

  • task_resources – callable to be executed when Task is ready to be run and resources can be assigned.

  • cluster – The name of the cluster that the user wants to run their tasks on.

  • resource_scales – Specifies how much a user wants to scale their requested resources after failure.

  • fallback_queues – A list of queues that users want to try if their original queue isn’t able to handle their adjusted resources.

  • compute_resources_callable – callable compute resources.

task_id
array_id
status
downstream_swarm_tasks: Set[SwarmTask]
current_task_resources
compute_resources_callable = None
fallback_queues = None
resource_scales
cluster
max_attempts
num_upstreams: int = 0
num_upstreams_done: int = 0
property all_upstreams_done: bool

Return a bool of if upstreams are done or not.

property downstream_tasks: List[SwarmTask]

Return list of downstream tasks.