From 36d59a0751273ddf78939d89567de553abfdf0ed Mon Sep 17 00:00:00 2001 From: Eric Allam Date: Mon, 30 Jun 2025 16:37:23 +0100 Subject: [PATCH] Fix v4 concurrency sweeper flaky test --- .../src/run-queue/tests/concurrencySweeper.test.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal-packages/run-engine/src/run-queue/tests/concurrencySweeper.test.ts b/internal-packages/run-engine/src/run-queue/tests/concurrencySweeper.test.ts index 97fef5303dc..8a1399911f6 100644 --- a/internal-packages/run-engine/src/run-queue/tests/concurrencySweeper.test.ts +++ b/internal-packages/run-engine/src/run-queue/tests/concurrencySweeper.test.ts @@ -74,9 +74,9 @@ describe("RunQueue Concurrency Sweeper", () => { }, concurrencySweeper: { scanSchedule: "* * * * * *", // Every second - scanJitter: 5, + scanJitterInMs: 5, processMarkedSchedule: "* * * * * *", // Every second - processMarkedJitter: 5, + processMarkedJitterInMs: 5, callback: async (runIds) => { if (!enableConcurrencySweeper) { return []; @@ -151,9 +151,9 @@ describe("RunQueue Concurrency Sweeper", () => { enableConcurrencySweeper = true; - await setTimeout(3_000); // Now a run is "completed" and should be removed from the concurrency set + await setTimeout(5_000); // Now a run is "completed" and should be removed from the concurrency set - // queue concurrency should be 0 + // queue concurrency should be 1 const queueConcurrency3 = await queue.currentConcurrencyOfQueue( authenticatedEnvDev, messageDev.queue