worker_node.worker_node_factory

Start up distributing process.

Classes

WorkerNodeFactory

Module Contents

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

_cluster_name[source]

cluster[source]

_worker_node_interface[source]

get_job_task_instance(task_instance_id: int) → jobmon.worker_node.worker_node_task_instance.WorkerNodeTaskInstance[source]: Set up and return WorkerNodeTaskInstance object.

get_array_task_instance(array_id: int, batch_number: int) → jobmon.worker_node.worker_node_task_instance.WorkerNodeTaskInstance[source]: Set up and return WorkerNodeTaskInstance object.