Picks the graphs that reached a terminal status without delivering their continuation.
Filtered here rather than in SQL because the delivery marker lives inside the parent's
InputPayload JSON, and it lives there deliberately: one representation means the writer
(TryClaimContinuation) and the reader are pinned to each other, and a graph settled before any
of this existed is judged by the same parser as one settled after — which a new column plus a
backfill could not promise.
An unreadable payload counts as undelivered. It is selected, the claim then refuses it
(ISJSON guard), and it is selected again next pass until it ages out of the window. That is the
intended shape: we cannot prove such a graph was delivered, so we must not assume it, and the
window is what keeps "cannot prove" from meaning "retry forever".
Picks the graphs that reached a terminal status without delivering their continuation.
Filtered here rather than in SQL because the delivery marker lives inside the parent's
InputPayloadJSON, and it lives there deliberately: one representation means the writer (TryClaimContinuation) and the reader are pinned to each other, and a graph settled before any of this existed is judged by the same parser as one settled after — which a new column plus a backfill could not promise.An unreadable payload counts as undelivered. It is selected, the claim then refuses it (
ISJSONguard), and it is selected again next pass until it ages out of the window. That is the intended shape: we cannot prove such a graph was delivered, so we must not assume it, and the window is what keeps "cannot prove" from meaning "retry forever".