Skip to content
Draft
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
fix: increase processWorkerQueueDebounceMs in priority test to preven…
…t race condition

With PrismaPg adapter overhead, each trigger() call takes longer than with
the old Rust engine. A 50ms processWorkerQueueDebounceMs causes the background
processQueueForWorkerQueue job to fire between individual triggers, moving
items to the worker queue one-by-one in arrival (FIFO) order instead of
waiting for all items to be in the master queue and moving them collectively
in priority order.

Increase to 10s so the test's manual processMasterQueueForEnvironment call
controls the ordering.

Co-Authored-By: Eric Allam <eallam@icloud.com>
  • Loading branch information
devin-ai-integration[bot] and ericallam committed Apr 16, 2026
commit 9579fbcb0765adad4dac03e50d76e69de14986e0
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,12 @@ describe("RunEngine priority", () => {
},
queue: {
redis: redisOptions,
processWorkerQueueDebounceMs: 50,
// Use a large debounce so the background processQueueForWorkerQueue job
// doesn't race with the manual processMasterQueueForEnvironment call.
// With PrismaPg adapter overhead each trigger() takes longer, so a small
// debounce causes items to be moved to the worker queue individually in
// arrival order rather than collectively in priority order.
processWorkerQueueDebounceMs: 10_000,
masterQueueConsumersDisabled: true,
},
runLock: {
Expand Down
Loading