Queue

Workflow	Type	Description
queue.ack	Atomic	Complete a claimed or running queue item and release its partition key.
queue.claim-next	Atomic	Lease the next eligible queue item in FIFO order. Skips partition keys that already have an active item and owners at their concurrency cap. Returns claimed=false when nothing is eligible.
queue.drain	Atomic	Advance a keyed queue: reap expired leases, reconcile running items against their target runs, then claim and launch up to max_claims new items honouring per-key and per-owner concurrency.
queue.drop	Atomic	Terminate a queue item without running it, releasing its partition key.
queue.enqueue	Atomic	Admit one unit of work into a keyed queue. Applies the admission policy (append / coalesce_latest / reject_duplicate) plus optional debounce, and returns the resulting item and effect.
queue.get	Atomic	Fetch one queue item by uuid, including what superseded it and what it superseded.
queue.list	Atomic	List queue items for an organization, filtered by queue, key, status or owner.
queue.mark-running	Atomic	Record the run uuid of the workflow launched for a claimed queue item.
queue.nack	Atomic	Record a failed attempt for a queue item. Requeues with backoff until the attempt budget is exhausted, then fails terminally.
queue.peek	Atomic	Show the next eligible item per partition key without claiming it, plus the keys currently blocked by an active item.
queue.reap-leases	Atomic	Recover queue items whose lease expired, requeueing them or failing them once their attempt budget is spent. Required for per-key exclusivity to be safe: without it a crashed worker wedges its partition key forever.
queue.requeue	Atomic	Return a claimed or running queue item to the queue without consuming an attempt. For leases genuinely lost rather than work that failed.
queue.stats	Atomic	Aggregate queue depth by status, plus the deepest partition keys.