Suspend every unsuspended visible job in a parent's subtree, lapsed leases included. Jobs with a future visibility (delayed, backoff, throttled, leased) are skipped.

Resume the suspended jobs in a parent's subtree. A finalizer with children still in the queue stays suspended.

CTE binding locked to the ids named, locked in descending id order. The statement carries id IN (SELECT id FROM locked) to keep the CTE.

descendantsFromCte seeded from a parent's children, excluding the parent itself.

CTE binding wake_parent to the suspended parent of source's rows, resumed when no other child remains.

Lock the named jobs and all their descendants, several trees in one pass. Locks rows in descending id order. Then lock the group summaries of the rows and their parents.

Extend lockJobTreesSQL to the complete tree of each named job. This locks all rows that tree cancellation can delete. The named identifiers also start the downward walk. An orphan locks its subtree.

Cancel a job and all its descendants recursively. Locks rows in descending id order. Returns the ids deleted.

Force-cancel a job subtree. Flags still-live claimed jobs and bumps their claim token once, deletes the rest, and NOTIFYs every claimed job affected.

The amount that a force-cancel flag adds to the claim token.

Delete the force-cancel-flagged jobs that have no live lease.

Delete the force-cancel-flagged jobs that owner holds. Each pair is a job id and the claim token that its claim returned.

Flagged jobs whose lease has lapsed. The reaper deletes them and resumes their parents.

Cancel an entire job tree by walking up from any node to the root, then cascade-deleting everything from the root down. Locks rows in descending id order. Deletes nothing for an orphan. Returns the ids deleted.

Resume a suspended parent for its completion round, once no child of it is left in the main queue.

Rollup finalizer ids in a job's subtree, the job itself included. Read before a DLQ move.

Suspend a job, making it unclaimable. Refuses an in-flight job.

Resume a suspended job. Refuses a finalizer with children still in the main queue. A child in the DLQ is terminal. The finalizer reads its error through readChildResultsSQL and decides for itself.

Mark a claimed, childless job as a rollup finalizer, matched on the claim token. The ack's suspend branch refunds the attempt.

Whether a job has already spawned a round under the given claim token.

Which of the given ids carry a rollup finalizer's parent_state.

Fetch the parent ids of several jobs.

Take the transaction-scoped advisory locks keyed by a schema.table string and the ids named, ascending, in one round trip.

Check whether a job with the given id exists.

Insert a child's result into the results table.

insertResultSQL for several children in one statement.

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

Drop a parent's stored child results.

Detach a parent's DLQ children.

Get DLQ child errors for a parent, one (job_id, last_error) row per DLQ'd child.

Snapshot child results into parent_state before a DLQ move.

Read a job's raw parent_state snapshot.

A rollup finalizer's child results, DLQ child errors, and parent_state snapshot in one query, tagged r, e and s respectively.