diff --git a/packages/redis-worker/src/mollifier/drainer.test.ts b/packages/redis-worker/src/mollifier/drainer.test.ts index 045ef7915..c8f68977f 100644 --- a/packages/redis-worker/src/mollifier/drainer.test.ts +++ b/packages/redis-worker/src/mollifier/drainer.test.ts @@ -1243,7 +1243,11 @@ describe("MollifierDrainer.start/stop", () => { await drainer.stop({ timeoutMs: 500 }); const stopElapsed = Date.now() - stopStart; - expect(stopElapsed).toBeGreaterThanOrEqual(500); + // Allow a small jitter window below `timeoutMs` — Node's setTimeout can + // fire a millisecond or two early under CI load. The behaviour we're + // pinning is "stop honors the deadline instead of waiting for the hung + // handler indefinitely", not millisecond-precise timing. + expect(stopElapsed).toBeGreaterThanOrEqual(450); expect(stopElapsed).toBeLessThan(2_000); } finally { await buffer.close();