multiprocess.multiproc_queue

The client for the Multiprocess executor.

Classes

MultiprocessQueue

Implementation of the multiprocess executor queue, derived from ClusterQueue.

Module Contents

class multiprocess.multiproc_queue.MultiprocessQueue(queue_id: int, queue_name: str, parameters: Dict)[source]

Bases: jobmon.core.cluster_protocol.ClusterQueue

Implementation of the multiprocess executor queue, derived from ClusterQueue.

_queue_id[source]

_queue_name[source]

_parameters[source]

validate_resources(strict: bool = False, **kwargs: str | int | float) → Tuple[bool, str][source]: Ensure cores requested isn’t more than available on that node.

coerce_resources(**kwargs: str | int | float) → Dict[source]: Ensures that requested resources aren’t greater than what’s available.

property queue_id: int[source]: Return the ID of the queue.

property queue_name: str[source]: Return the name of the queue.

property parameters: Dict[source]: Return the dictionary of parameters.

property required_resources: List[source]: No required resources specified for dummy executor, return empty list.