test: fix flaky drained worker delayed-job assertion

Author: Copilot

tests/worker.test.ts

@@ -1698,9 +1698,32 @@ describe('workers', () => {
       );
       await worker.waitUntilReady();
 
+      let bulkStart = 0;
+      let bulkCompletedCount = 0;
+
+      const completing2 = new Promise<void>(resolve => {
+        worker.on('completed', job => {
+          if (!bulkStart) {
+            return;
+          }
+
+          bulkCompletedCount += 1;
+
+          if (bulkCompletedCount === 2) {
+            const timeDiff = Date.now() - bulkStart;
+            expect(timeDiff).toBeGreaterThanOrEqual(4000);
+            expect(timeDiff).toBeLessThan(4500);
+            expect(job.delay).toBe(0);
+            resolve();
+          }
+        });
+      });
+
       // after this event, worker should be drained
       const completing = new Promise<void>(resolve => {
         worker.once('completed', async () => {
+          bulkStart = Date.now();
+
           await queue.addBulk([
             { name: 'test1', data: { idx: 0, foo: 'bar' } },
             {
@@ -1718,20 +1741,6 @@ describe('workers', () => {
 
       await completing;
 
-      const now = Date.now();
-      const completing2 = new Promise<void>(resolve => {
-        worker.on(
-          'completed',
-          after(2, job => {
-            const timeDiff = Date.now() - now;
-            expect(timeDiff).toBeGreaterThanOrEqual(4000);
-            expect(timeDiff).toBeLessThan(4500);
-            expect(job.delay).toBe(0);
-            resolve();
-          }),
-        );
-      });
-
       await completing2;
       await worker.close();
     });