Arbiter.Core.Job.Schema.Groups

Partial index over (group_key, priority, id), read by the claim's LATERAL subqueries and by the maintenance triggers recomputing a group's minima.

Partial index over (group_key, attempts DESC, priority, id) for retried rows, read by the claim's group head gate. Retried rows rank ahead of the rest. The gate merges this run with the (group_key, priority, id) scan.

Parked grouped jobs (scheduled, backoff or leased) by visibility deadline. Group maintenance uses this index to replace next_due with one point lookup.

Possible in-flight grouped jobs by descending lease deadline. The query applies the time-dependent part of the predicate at runtime.

Create a queue's groups table, one summary row per group_key carrying the group's precomputed minima, counts and in_flight_until. Maintained by the triggers createGroupsTriggersSQL installs.

Add ready_count and next_due to the groups summary, make the ranking index partial on ready rows, and add the next_due due-finder.

Index over the summary rows the maintenance triggers emptied in place.

The group summary aggregates over job rows grouped by group_key. min_priority and min_id rank the group. col prefixes each column.

Whether a job still holds its group's in-flight slot. col prefixes each column.

Group maintenance with indexed extremum replacement. Transition tables supply count deltas. No update or delete scans all rows in an affected group.

The three statement-level AFTER triggers calling a queue's groups maintenance functions, each handed its affected rows through a transition table.