Ruben FiszelandClaude Opus 4.8 1c3b2041dd fix(debounce): serialize upsert per key (simpler, race-free) ...

Companion to windmill-ee-private: the running-survivor guard and batch
chaining are now protected by a per-key advisory lock instead of
snapshot-sensitive single-statement SQL. This closes a concurrent-arrival
data-loss race where a debounced late arrival's args could be dropped
because the batch lookup couldn't see the predecessor's just-committed
batch row.

Extends test_debounce_concurrent_arrivals_after_running_survivor to pull the
survivor and assert its accumulation includes BOTH racing late arrivals
(shared batch), and refreshes the SQLx cache for the rewritten queries.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

2026-06-25 10:05:23 +00:00

..

src

feat: Data Pipelines alpha (#9193)

2026-06-18 18:09:02 +02:00

tests

fix(debounce): serialize upsert per key (simpler, race-free)

2026-06-25 10:05:23 +00:00

Cargo.toml

feat(queue): stochastic admission + EE availability of workspace fairness algorithm (#9321)

2026-05-26 04:51:53 +00:00