Skip to content

Commit 08d84eb

Browse files
authored
Fix v4 concurrency sweeper flaky test (#2213)
1 parent f38d35e commit 08d84eb

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

internal-packages/run-engine/src/run-queue/tests/concurrencySweeper.test.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -74,9 +74,9 @@ describe("RunQueue Concurrency Sweeper", () => {
7474
},
7575
concurrencySweeper: {
7676
scanSchedule: "* * * * * *", // Every second
77-
scanJitter: 5,
77+
scanJitterInMs: 5,
7878
processMarkedSchedule: "* * * * * *", // Every second
79-
processMarkedJitter: 5,
79+
processMarkedJitterInMs: 5,
8080
callback: async (runIds) => {
8181
if (!enableConcurrencySweeper) {
8282
return [];
@@ -151,9 +151,9 @@ describe("RunQueue Concurrency Sweeper", () => {
151151

152152
enableConcurrencySweeper = true;
153153

154-
await setTimeout(3_000); // Now a run is "completed" and should be removed from the concurrency set
154+
await setTimeout(5_000); // Now a run is "completed" and should be removed from the concurrency set
155155

156-
// queue concurrency should be 0
156+
// queue concurrency should be 1
157157
const queueConcurrency3 = await queue.currentConcurrencyOfQueue(
158158
authenticatedEnvDev,
159159
messageDev.queue

0 commit comments

Comments
 (0)