fix(delayed): remove marker after being consumed (#1620) fixes #1615

taskforcesh · Jan 7, 2023 · 9fce0f0 · 9fce0f0
1 parent 4a6db4d
commit 9fce0f0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/classes/worker.ts b/src/classes/worker.ts
@@ -486,7 +486,6 @@ export class Worker<
     // block timeout.
     if (jobId && jobId.startsWith('0:')) {
       this.blockTimeout = parseInt(jobId.split(':')[1]);
-      return;
     }
     const [jobData, id, limitUntil, delayUntil] =
       await this.scripts.moveToActive(token, jobId);

diff --git a/tests/test_delay.ts b/tests/test_delay.ts
@@ -122,7 +122,6 @@ describe('Delayed jobs', function () {
           const delayedJobs = await queue.getDelayed();
           expect(delayedJobs.length).to.be.equal(1);
           expect(publishHappened).to.be.eql(true);
-          await worker.close();
           resolve();
         } catch (err) {
           reject(err);
@@ -147,6 +146,10 @@ describe('Delayed jobs', function () {
 
     await delayed;
     await completed;
+
+    const count = await queue.getJobCountByTypes('active');
+    expect(count).to.be.equal(0);
+
     await queueEvents.close();
     await worker.close();
   });