Module queue 

Bounded queue readiness reads over the configured database adapter.

Functions

claim_worker_rows 🔒

Acquires adapter-owned leases before any delivery side effect. The transient view retains the due status expected by the existing processors, while completion guards compare the committed lease to prevent stale acknowledgments.

complete_one_local_job

Marks one queued local job complete with a guarded, backend-neutral write. This operator operation has no external handler side effects.

control_job

Applies a declared queue control with a compare-and-write transition. Admission and role policy belong to the caller; active actor state and the expected job status are checked atomically with the mutation.

job_detail_view

Reads one execution and its bounded attempts for declared detail rendering.

job_queue_page

Reads one queue page and aggregate counts without exporting unrelated app state. The declared route policy authorizes queue access before this call.

local_job_replay

Reads one job and its bounded attempt/event history through the adapter.

local_job_report

Reads the bounded operator job list and complete status counts.

local_workflow_report

Lists bounded workflow executions for the operator jobs report.

pending_queue_work

Checks for pending work without exporting the app state document. A schema without the complete queue contract returns None so its caller can retain its existing worker behavior during adoption.

requeue_local_jobs

Moves bounded failed or expired-lease jobs back to the queue. The status guard prevents an operator command from overwriting a concurrent worker.

scoped_job_worker_snapshot

Reads the next due records and related notification display data. Evidence ID seeds contain no historical payloads or unrelated users.