fix: update consumerPool test assertion for optional timing parameter

nicktrn · nicktrn · commit 2219d11f4f90 · 2026-03-27T11:16:55.000Z
diff --git a/packages/core/src/v3/runEngineWorker/supervisor/consumerPool.test.ts b/packages/core/src/v3/runEngineWorker/supervisor/consumerPool.test.ts
@@ -498,7 +498,7 @@ describe("RunQueueConsumerPool", () => {
         await testConsumers[0].onDequeue(messages);
       }
 
-      expect(mockOnDequeue).toHaveBeenCalledWith(messages);
+      expect(mockOnDequeue).toHaveBeenCalledWith(messages, undefined);
 
       advanceTimeAndProcessMetrics(1100);
       const metrics = pool.getMetrics();

Original file line number	Diff line number	Diff line change
`@@ -498,7 +498,7 @@ describe("RunQueueConsumerPool", () => {`
`498`	`498`	`await testConsumers[0].onDequeue(messages);`
`499`	`499`	`}`
`500`	`500`
`501`		`- expect(mockOnDequeue).toHaveBeenCalledWith(messages);`
	`501`	`+ expect(mockOnDequeue).toHaveBeenCalledWith(messages, undefined);`
`502`	`502`
`503`	`503`	`advanceTimeAndProcessMetrics(1100);`
`504`	`504`	`const metrics = pool.getMetrics();`