client.swarm.swarm_array

Array object used by swarm to create task instance batches.

Attributes

Classes

Module Contents

client.swarm.swarm_array.logger[source]

class client.swarm.swarm_array.SwarmArray(array_id: int, max_concurrently_running: int, array_name: str | None = None)[source]

array_id[source]

array_name = 'array_Uninferable'[source]

tasks: Set[jobmon.client.swarm.swarm_task.SwarmTask][source]

max_concurrently_running[source]

add_task(task: jobmon.client.swarm.swarm_task.SwarmTask) → None[source]

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

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

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