test: remove keys from other queues (#3131)

Author: roggervalf

tests/test_concurrency.ts

@@ -258,8 +258,6 @@ describe('Concurrency', () => {
           'completed',
           // after every job has been completed
           after(numJobs, async () => {
-            await worker.close();
-
             try {
               const timeDiff = new Date().getTime() - startTime;
               expect(timeDiff).to.be.gte(
@@ -342,8 +340,6 @@ describe('Concurrency', () => {
             'completed',
             // after every job has been completed
             after(numJobs, async () => {
-              await worker.close();
-
               try {
                 const timeDiff = new Date().getTime() - startTime;
                 expect(timeDiff).to.be.gte(numJobs * dynamicLimit);

tests/test_flow.ts

@@ -1076,6 +1076,8 @@ describe('flows', () => {
       await worker.close();
       await childrenWorker.close();
       await grandchildrenWorker.close();
+      await removeAllQueueData(new IORedis(redisHost), childrenQueueName);
+      await removeAllQueueData(new IORedis(redisHost), grandchildrenQueueName);
     });
   });
 
@@ -1468,6 +1470,7 @@ describe('flows', () => {
       await flow.close();
 
       await removeAllQueueData(new IORedis(redisHost), parentQueueName);
+      await removeAllQueueData(new IORedis(redisHost), grandchildrenQueueName);
     }).timeout(8000);
   });
 
@@ -2372,6 +2375,11 @@ describe('flows', () => {
         await flow.close();
         await worker.close();
         await grandchildrenWorker.close();
+        await removeAllQueueData(new IORedis(redisHost), childrenQueueName);
+        await removeAllQueueData(
+          new IORedis(redisHost),
+          grandchildrenQueueName,
+        );
       });
     });
 

tests/test_worker.ts

@@ -3339,6 +3339,7 @@ describe('workers', function () {
           await worker.close();
           await childrenWorker.close();
           await parentQueue.close();
+          await removeAllQueueData(new IORedis(redisHost), parentQueueName);
         });
 
         describe('when skip attempt option is provided as true', () => {
@@ -3461,6 +3462,7 @@ describe('workers', function () {
             await worker.close();
             await childrenWorker.close();
             await parentQueue.close();
+            await removeAllQueueData(new IORedis(redisHost), parentQueueName);
           });
         });
       });