From 3849de642c50da1db5360a54c2706677e04c3f07 Mon Sep 17 00:00:00 2001 From: zebbern <185730623+zebbern@users.noreply.github.com> Date: Sat, 20 Jun 2026 16:25:26 +0200 Subject: [PATCH] test(worker): stabilize workflow parallelism assertion Signed-off-by: zebbern <185730623+zebbern@users.noreply.github.com> --- .../src/temporal/__tests__/workflow-runner.test.ts | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/worker/src/temporal/__tests__/workflow-runner.test.ts b/worker/src/temporal/__tests__/workflow-runner.test.ts index 7fbf2d9a..101704a9 100644 --- a/worker/src/temporal/__tests__/workflow-runner.test.ts +++ b/worker/src/temporal/__tests__/workflow-runner.test.ts @@ -252,13 +252,17 @@ describe('executeWorkflow', () => { const branchStartDelta = Math.abs(branchA.startedAt - branchB.startedAt); expect(branchStartDelta).toBeLessThan(75); - const branchAElapsed = branchA.endedAt - branchA.startedAt; - const branchBElapsed = branchB.endedAt - branchB.startedAt; - expect(branchAElapsed).toBeGreaterThanOrEqual(190); - expect(branchBElapsed).toBeGreaterThanOrEqual(190); + const branchesOverlap = + Math.max(branchA.startedAt, branchB.startedAt) < Math.min(branchA.endedAt, branchB.endedAt); + expect(branchesOverlap).toBe(true); + + expect(merge.startedAt).toBeGreaterThanOrEqual(Math.max(branchA.endedAt, branchB.endedAt) - 5); const totalElapsed = merge.endedAt - start.startedAt; - expect(totalElapsed).toBeLessThan(350); + // A serial execution would take roughly 450ms before merge overhead + // (50ms start + 200ms branchA + 200ms branchB). Keep the assertion about + // scheduler behavior, not timer precision. + expect(totalElapsed).toBeLessThan(450); }); it('produces a deterministic trace sequence across repeated runs', async () => {