Ruben FiszelandClaude Opus 4.8 febef8e16a test(debounce): port the #9781 regression case, flow-node guard, full-path bench ...

- Port the regression from #9781
  (test_post_preprocessing_debounce_into_running_survivor_loses_message):
  post-preprocessing survivor accumulates + runs, a later same-key message must
  start a new batch (survive) not be folded into the running survivor. Exercises
  the full EE path via jobs_ee::maybe_debounce_post_preprocessing.
- Add the third EE entry point's guard:
  test_flow_node_debounce_running_survivor_not_superseded (maybe_debounce_flow_node).
- Add an #[ignore] full-source throughput bench (bench_debounce_full_path) driving
  the real maybe_debounce + maybe_apply_debouncing end-to-end.

All debounce tests exercise the real jobs_ee implementation (run with
--features private,enterprise); none stub it.

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

2026-06-25 14:39:30 +00:00

..

src

feat(debounce): claim-based exactly-once batch consumption

2026-06-25 14:16:00 +00:00

tests

test(debounce): port the #9781 regression case, flow-node guard, full-path bench

2026-06-25 14:39:30 +00:00

Cargo.toml

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

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