Fix priority tests

Author: ericallam

internal-packages/run-engine/src/engine/tests/priority.test.ts

@@ -76,7 +76,7 @@ describe("RunEngine priority", () => {
 
         expect(runs.length).toBe(priorities.length);
 
-        await setTimeout(500);
+        await engine.runQueue.processMasterQueueForEnvironment(authenticatedEnvironment.id, 5);
 
         //dequeue 4 times, in order
         const dequeue: DequeuedMessage[] = [];
@@ -88,13 +88,26 @@ describe("RunEngine priority", () => {
           dequeue.push(...items);
         }
         expect(dequeue.length).toBe(4);
+
+        console.log(
+          "runs",
+          runs.map((r) => r.friendlyId)
+        );
+        console.log(
+          "dequeued run IDs",
+          dequeue.map((d) => d.run.friendlyId)
+        );
+
         expect(dequeue[0].run.friendlyId).toBe(runs[4].friendlyId);
         expect(dequeue[1].run.friendlyId).toBe(runs[3].friendlyId);
         expect(dequeue[2].run.friendlyId).toBe(runs[1].friendlyId);
         expect(dequeue[3].run.friendlyId).toBe(runs[0].friendlyId);
 
         //wait 2 seconds (because of the negative priority)
         await setTimeout(2_000);
+
+        await engine.runQueue.processMasterQueueForEnvironment(authenticatedEnvironment.id, 1);
+
         const dequeue2 = await engine.dequeueFromWorkerQueue({
           consumerId: "test_12345",
           workerQueue: "main",