test: waitUntilReady in test cases

taskforcesh · Oct 16, 2024 · d0c4015 · d0c4015
1 parent 6e20049
commit d0c4015
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/classes/queue.ts b/src/classes/queue.ts
@@ -715,12 +715,10 @@ export class Queue<
    *
    * @param maxCount - Max quantity of jobs to be moved to wait per iteration.
    */
-  async migrateDeprecatedPausedKey(maxCount: number = 1000): Promise<void> {
+  async migrateDeprecatedPausedKey(maxCount = 1000): Promise<void> {
     let cursor = 0;
     do {
-      cursor = await this.scripts.migrateDeprecatedPausedKey(
-        maxCount
-      );
+      cursor = await this.scripts.migrateDeprecatedPausedKey(maxCount);
     } while (cursor);
   }
 }
diff --git a/tests/test_clean.ts b/tests/test_clean.ts
@@ -28,8 +28,8 @@ describe('Cleaner', () => {
     queueName = `test-${v4()}`;
     queue = new Queue(queueName, { connection, prefix });
     queueEvents = new QueueEvents(queueName, { connection, prefix });
-    await queueEvents.waitUntilReady();
     await queue.waitUntilReady();
+    await queueEvents.waitUntilReady();
   });
 
   afterEach(async function () {

diff --git a/tests/test_sandboxed_process.ts b/tests/test_sandboxed_process.ts
@@ -28,6 +28,7 @@ describe('Sandboxed process using child processes', () => {
       queueName = `test-${v4()}`;
       queue = new Queue(queueName, { connection, prefix });
       queueEvents = new QueueEvents(queueName, { connection, prefix });
+      await queue.waitUntilReady();
       await queueEvents.waitUntilReady();
     });
 
@@ -696,6 +697,7 @@ function sandboxProcessTests(
         drainDelay: 1,
         useWorkerThreads,
       });
+      await worker.waitUntilReady();
 
       const completing = new Promise<void>((resolve, reject) => {
         worker.on('completed', async (job: Job, value: any) => {