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)[source]

Bases: jobmon.core.cluster_protocol.ClusterQueue

Implementation of the sequential 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]: No resources defined for sequential execution. All resources valid.

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