From fcc2e156051875a3ed9868d109d5596bf2317618 Mon Sep 17 00:00:00 2001 From: James Martinez Date: Fri, 17 Apr 2026 13:12:31 -0500 Subject: [PATCH] test: widen timing bounds for flaky step retry-budget tests --- packages/openworkflow/worker/worker.test.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/packages/openworkflow/worker/worker.test.ts b/packages/openworkflow/worker/worker.test.ts index a8470638..ab8a3a6c 100644 --- a/packages/openworkflow/worker/worker.test.ts +++ b/packages/openworkflow/worker/worker.test.ts @@ -1664,7 +1664,7 @@ describe("Worker", () => { await sleep(100); await worker.tick(); - await sleep(100); + await sleep(200); const afterSecond = await backend.getWorkflowRun({ workflowRunId: handle.workflowRun.id, @@ -1734,7 +1734,7 @@ describe("Worker", () => { if (!run?.availableAt) throw new Error("Expected availableAt"); const firstDelayMs = run.availableAt.getTime() - beforeFirst; expect(firstDelayMs).toBeGreaterThanOrEqual(80); - expect(firstDelayMs).toBeLessThan(220); + expect(firstDelayMs).toBeLessThan(350); await sleep(180); const beforeSecond = Date.now(); @@ -1760,7 +1760,7 @@ describe("Worker", () => { if (!run?.availableAt) throw new Error("Expected availableAt"); const thirdDelayMs = run.availableAt.getTime() - beforeThird; expect(thirdDelayMs).toBeGreaterThanOrEqual(80); - expect(thirdDelayMs).toBeLessThan(220); + expect(thirdDelayMs).toBeLessThan(350); await sleep(180); await worker.tick(); @@ -1830,7 +1830,7 @@ describe("Worker", () => { // first failed step attempt should still use attempt 1 backoff (100ms) const beforeFirstFail = Date.now(); await worker.tick(); - await sleep(100); + await sleep(200); run = await backend.getWorkflowRun({ workflowRunId: handle.workflowRun.id, }); @@ -1838,7 +1838,7 @@ describe("Worker", () => { if (!run?.availableAt) throw new Error("Expected availableAt"); const firstDelayMs = run.availableAt.getTime() - beforeFirstFail; expect(firstDelayMs).toBeGreaterThanOrEqual(80); - expect(firstDelayMs).toBeLessThan(230); + expect(firstDelayMs).toBeLessThan(350); await sleep(220);