Ruben Fiszel bc67842f7a feat: reap abandoned AND-join slots after a TTL (default 60d, per-slot) ...

join_pending_inputs slots are normally cleared when the join fires;
partial slots whose inputs never all arrive (upstream removed/renamed,
one-off dynamic partition key, permanent skew) would otherwise leak.
windmill_queue::asset_dispatch::reap_stale_join_slots, called from the
monitor's delete_expired_items loop, deletes a (workspace, subscriber,
partition) slot only when its MOST RECENT row is older than
JOIN_SLOT_TTL_SECS (60d) — per-slot, never per-row, so a legitimately
slow join is not corrupted mid-accumulation. Conservative default;
per-join configurable TTL via the annotation is a planned follow-up.
Test covers stale-reaped / fresh-kept / mixed-slot-kept.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

2026-05-17 09:43:39 +00:00

..

src

feat: reap abandoned AND-join slots after a TTL (default 60d, per-slot)

2026-05-17 09:43:39 +00:00

tests

fix(concurrency): two-phase admit to skip FOR UPDATE on over-limit pulls (#9064)

2026-05-07 09:43:33 +00:00

Cargo.toml

fix: improve scheduling reliability in extreme pool contention conditions (#7825)

2026-02-07 13:16:32 +00:00