queue

exception Empty

Bases: Exception

exception Busy

Bases: Exception

class HeapSlot(job: _canary.job.BaseJob)

Bases: object

cost: float

job: BaseJob

resources: list[dict[str, Any]]

class ResourceQueue(lock: allocate_lock, resource_pool: ResourcePool, jobs: list[BaseJob] | None = None)

Bases: object

Heap-based resource queue for jobs.

Jobs with largest cost are scheduled first. Respects dependencies and exclusive job semantics. Raises Busy if no job can be run with available resources.

exclusive_job_id: str | None

prepare() → None

Empty method that a subclass can implement

put(*jobs: BaseJob) → None

get() → BaseJob

clear(status: str = 'CANCELLED') → None

done(job: BaseJob) → None

jobs() → list[BaseJob]

Return all jobs in queue, busy, and finished.

pending() → list[BaseJob]

status(start: float | None = None) → str

truncate(items: Iterable[str]) → str