Constraints for queue operations (requires table name lookup from registry).

Constraints for job operations (table name stored in job).

Insert a job. Returns the inserted job, or Nothing if skipped by dedup (IgnoreDuplicate) or if parentId references a non-existent job.

Insert multiple jobs in one round-trip. Returns only the jobs that were actually inserted (dedup'd jobs are excluded). Does not validate parentId - use insertJobTree for parent-child relationships.

Like insertJobsBatch but returns only the count of inserted rows.

Claim visible jobs (at most one per group). May return fewer than the limit if groups are exhausted.

Claims multiple jobs per group. Unlike claimNextVisibleJobs, this can claim up to batchSize jobs from each group while still respecting head-of-line blocking between batches.

Acknowledge a job as complete. Deletes it from the queue, or suspends it if it's a parent with unfinished children. Returns 1 on success, 0 if gone.

Acknowledges multiple jobs as complete. All jobs must be from the same queue. Returns the total number of rows deleted.

Bulk ack for standalone jobs (no parent, no tree logic).

A single DELETE with unnest - one round trip for N jobs. Only valid for jobs claimed in BatchedJobsMode.

Returns the number of rows deleted.

Marks a failed job for retry at a later time.

Returns the number of rows updated (0 if job was already claimed by another worker).

Manually extends a job's visibility timeout, useful for long-running jobs.

Returns the number of rows updated (0 if job was already reclaimed by another worker).

Extends visibility timeout for multiple jobs. All jobs must be from the same queue.

Result of setting visibility timeout for a single job in a batch.

Filter predicates for job listing queries.

Lists jobs with composable filters.

Returns jobs ordered by ID (descending, newest first).

Counts jobs with composable filters.

Lists DLQ jobs with composable filters.

Returns jobs ordered by failed_at (most recent first).

Counts DLQ jobs with composable filters.

Move a job to the DLQ. Returns 0 if already claimed by another worker.

Move multiple jobs to the DLQ. Jobs already claimed by another worker are skipped. Returns the count of jobs moved.

Lists jobs in the dead-letter queue with pagination.

Retry a DLQ job (re-insert into main queue with attempts reset). Returns Nothing if the DLQ job no longer exists.

Check whether a DLQ job exists by ID.

Permanently deletes a job from the dead-letter queue.

Returns the number of rows deleted (0 if the DLQ job no longer exists).

Permanently deletes multiple jobs from the dead-letter queue.

Returns the total number of DLQ jobs deleted.

Lists jobs in the queue with pagination.

Returns jobs ordered by ID (descending, newest first).

Gets a single job by its ID.

Returns Nothing if the job doesn't exist.

Gets all jobs for a specific group key with pagination.

Gets all jobs for a specific parent ID with pagination.

Gets all in-flight jobs (claimed, visibility timeout not expired).

Cancels (deletes) a job by ID.

Returns 0 if the job has children - use cancelJobCascade to delete a parent and all its descendants.

Cancels (deletes) multiple jobs by ID.

Returns the total number of jobs deleted.

Promote a delayed or retrying job to be immediately visible.

Refuses in-flight jobs (attempts > 0 with no last_error). Returns 1 on success, 0 if not found, already visible, or in-flight.

Statistics about the job queue

Gets statistics about the job queue.

Counts all jobs in the queue.

Counts jobs matching a group key.

Counts jobs matching a parent ID.

Counts in-flight jobs (currently being processed by workers).

Counts jobs in the dead-letter queue.

Counts children for a batch of potential parent IDs.

Returns a Map from parent_id to (total, paused) counts (only non-zero entries).

Count how many children of a parent are in the DLQ. Useful inside finalizer handlers to detect failed children.

Counts children in the DLQ for a batch of potential parent IDs.

Returns a Map from parent_id to DLQ child count (only non-zero entries).

Pause all visible children of a parent job, making them unclaimable.

Only affects children that are currently claimable. In-flight children are left alone so their visibility timeout can expire normally if the worker crashes.

Returns the number of children paused.

Resume all suspended children of a parent job.

Returns the number of children resumed.

Cancel a job and all its descendants recursively.

Returns the total number of jobs deleted (parent + all descendants).

Suspend a job, making it unclaimable.

Only suspends non-in-flight jobs (not currently being processed by workers). Returns the number of rows updated (0 if job doesn't exist, is in-flight, or already suspended).

Resume a suspended job, making it claimable again.

Returns the number of rows updated (0 if job doesn't exist or isn't suspended).

Insert a child's result into the results table.

Each child gets its own row keyed by (parent_id, child_id). The FK ON DELETE CASCADE ensures cleanup when the parent is acked.

Returns the number of rows inserted (1 on success).

Get all child results for a parent from the results table.

Get DLQ child errors for a parent.

Returns a Map from child job ID to the last error message.

Read all child data for a rollup finalizer. Returns (childId->result, childId->error, parentStateSnapshot, dlqPK->error).

Merge raw child results from three sources.

Precedence (left-biased union): DLQ errors > results > snapshot.

Snapshot results into parent_state before DLQ move.

Read raw parent_state snapshot from the DB.

Full recompute of the groups table from the main queue.

Corrects any drift in job_count, min_priority, min_id, and in_flight_until.

Insert a JobTree atomically. Returns all inserted jobs (pre-order), or Left if the root has a dedup conflict. Rolls back on any failure.

The schema name for this monad's Arbiter tables.