client.swarm.array

Array object used by swarm to create task instance batches.

Attributes

Classes

Initialization of the SwarmArray.

Module Contents

client.swarm.array.logger

class client.swarm.array.SwarmArray(array_id: int, max_concurrently_running: int, array_name: str | None = None)

Initialization of the SwarmArray.

array_id

array_name

tasks: Set[jobmon.client.swarm.task.SwarmTask]

max_concurrently_running

add_task(task: jobmon.client.swarm.task.SwarmTask) → None