worker_node.worker_node_factory

Start up distributing process.

Classes

WorkerNodeFactory

Initialization of the WorkerNode Factory.

Module Contents

class worker_node.worker_node_factory.WorkerNodeFactory(cluster_name: str, requester: jobmon.core.requester.Requester | None = None)

Initialization of the WorkerNode Factory.

get_job_task_instance(task_instance_id: int) → jobmon.worker_node.worker_node_task_instance.WorkerNodeTaskInstance

Set up and return WorkerNodeTaskInstance object.

get_array_task_instance(array_id: int, batch_number: int) → jobmon.worker_node.worker_node_task_instance.WorkerNodeTaskInstance

Set up and return WorkerNodeTaskInstance object.