sequential.seq_queue

The client for the Sequential Executor.

Classes

SequentialQueue

Implementation of the sequential executor queue, derived from ClusterQueue.

Module Contents

class sequential.seq_queue.SequentialQueue(queue_id: int, queue_name: str, parameters: dict)

Bases: jobmon.core.cluster_protocol.ClusterQueue

Implementation of the sequential executor queue, derived from ClusterQueue.

Intialization of SequentialQueue.

Get the limits from database in client.

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

No resources defined for sequential execution. All resources valid.

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 specified required resources for sequential, return empty list.