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)

Bases: jobmon.core.cluster_protocol.ClusterQueue

Implementation of the multiprocess executor queue, derived from ClusterQueue.

Intialization of the multiprocess queue.

Get the limits from the database in the client.

validate_resources(strict: bool = False, **kwargs: str | int | float) → Tuple[bool, str]

Ensure cores requested isn’t more than available on that node.

coerce_resources(**kwargs: str | int | float) → Dict

Ensures that requested resources aren’t greater than what’s available.

property queue_id: int

Return the ID of the queue.

property queue_name: str

Return the name of the queue.

property parameters: Dict

Return the dictionary of parameters.

property required_resources: List

No required resources specified for dummy executor, return empty list.