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

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

Inserts a job into the queue.

Returns Nothing if a job with the same deduplication key already exists (with IgnoreDuplicate strategy).

Insert multiple jobs in a single batch operation.

Supports dedup keys: within the batch, duplicate keys are resolved (last ReplaceDuplicate wins), and against existing rows via ON CONFLICT.

Does not validate parentId. Use insertJobTree for parent-child relationships.

Claims visible jobs from the queue. At most one job per group is claimed to enforce head-of-line blocking.

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.

Acknowledges a job as complete, permanently deleting it from the queue.

Returns 1 on success (job deleted or parent suspended), 0 if already 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.

Moves a job from the main queue to the dead-letter queue (DLQ).

Returns the number of rows deleted from main queue (0 if job was already claimed by another worker).

Moves multiple jobs to the dead-letter queue.

Each job is moved with its own error message. Jobs that have already been claimed by another worker (attempts mismatch) are silently skipped.

Returns the total number of jobs moved to DLQ.

Lists jobs in the dead-letter queue with pagination.

Moves a job from the dead-letter queue back into the main queue to be retried.

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.

Useful for debugging or admin UI to see all jobs for a specific entity.

Gets all jobs for a specific parent ID with pagination.

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

A job is considered in-flight if it has been claimed (attempts > 0) and its visibility timeout hasn't expired yet.

Useful for monitoring active work and detecting stuck jobs.

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 child results, DLQ errors, parent_state snapshot, and DLQ failures for a rollup finalizer in a single query.

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 in a single transaction.

HighLevel wrapper that resolves schema/table from the registry. See insertJobTree for details.