fix tests

Author: ericallam

packages/redis-worker/src/fair-queue/tests/fairQueue.test.ts

@@ -386,14 +386,25 @@ describe("FairQueue", () => {
           { timeout: 15000 }
         );
 
-        // Check that messages were interleaved (not all t1 before t2)
-        const firstFive = processed.slice(0, 5);
-        const t1InFirstFive = firstFive.filter((p) => p.tenant === "t1").length;
-        const t2InFirstFive = firstFive.filter((p) => p.tenant === "t2").length;
-
-        // DRR should ensure some interleaving
-        expect(t1InFirstFive).toBeGreaterThan(0);
-        expect(t2InFirstFive).toBeGreaterThan(0);
+        // With two-stage architecture, fairness is at the claiming level, not processing order.
+        // Both tenants' queues are serviced in the same scheduler round, but messages are
+        // pushed to a shared worker queue and processed in FIFO order.
+        // The fairness guarantee is that both tenants' messages ARE processed, not that
+        // they're interleaved in the processing order.
+        const t1Count = processed.filter((p) => p.tenant === "t1").length;
+        const t2Count = processed.filter((p) => p.tenant === "t2").length;
+
+        // DRR ensures both tenants get their messages claimed and processed
+        expect(t1Count).toBe(5);
+        expect(t2Count).toBe(5);
+
+        // Verify all messages were processed
+        expect(processed.filter((p) => p.tenant === "t1").map((p) => p.value)).toEqual(
+          expect.arrayContaining(["t1-0", "t1-1", "t1-2", "t1-3", "t1-4"])
+        );
+        expect(processed.filter((p) => p.tenant === "t2").map((p) => p.value)).toEqual(
+          expect.arrayContaining(["t2-0", "t2-1", "t2-2", "t2-3", "t2-4"])
+        );
 
         await queue.close();
       }