test: add test case in worker

taskforcesh · Apr 10, 2024 · e31f71f · e31f71f
1 parent 917ff96
commit e31f71f
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 9 deletions.
diff --git a/tests/test_queue.ts b/tests/test_queue.ts
@@ -387,15 +387,6 @@ describe('queues', function () {
     });
   });
 
-  describe('when 0.002 is used as blocktimeout', () => {
-    it('should not block forever', async () => {
-      const client = await queue.client;
-      await client.bzpopmin(`key`, 0.002);
-
-      expect(true).to.be.true;
-    });
-  });
-
   describe('.removeDeprecatedPriorityKey', () => {
     it('removes old priority key', async () => {
       const client = await queue.client;

diff --git a/tests/test_worker.ts b/tests/test_worker.ts
@@ -816,6 +816,25 @@ describe('workers', function () {
     await worker.close();
   });
 
+  describe('when 0.002 is used as blocktimeout', () => {
+    it('should not block forever', async () => {
+      const worker = new Worker(queueName, async () => {}, {
+        connection,
+        prefix,
+      });
+      await worker.waitUntilReady();
+      const client = await worker.client;
+      if (isRedisVersionLowerThan(worker.redisVersion, '7.0.8')) {
+        await client.bzpopmin(`key`, 0.002);
+      } else {
+        await client.bzpopmin(`key`, 0.001);
+      }
+
+      expect(true).to.be.true;
+      await worker.close();
+    });
+  });
+
   describe('when closing a worker', () => {
     it('process a job that throws an exception after worker close', async () => {
       const jobError = new Error('Job Failed');