bullmq - npm Package Compare versions

Comparing version 1.11.1 to 1.11.2

CHANGELOG.md

@@ -0,1 +1,8 @@
+## [1.11.2](https://github.com/taskforcesh/bullmq/compare/v1.11.1...v1.11.2) (2020-12-15)
+
+
+### Bug Fixes
+
+* promote jobs to the right "list" when paused ([d3df615](https://github.com/taskforcesh/bullmq/commit/d3df615d37b1114c02eacb45f23643ee2f05374d))
+
 ## [1.11.1](https://github.com/taskforcesh/bullmq/compare/v1.11.0...v1.11.1) (2020-12-15)
@@ -2,0 +9,0 @@

dist/classes/scripts.js

@@ -275,2 +275,3 @@ /**
             queue.keys.wait,
+            queue.keys.paused,
             queue.keys.priority,
@@ -277,0 +278,0 @@ queue.keys.events,

dist/test/test_job.js

@@ -261,2 +261,13 @@ /*eslint-env node */
         });
+        mocha_1.it('should promote delayed job to the right queue if queue is paused', async () => {
+            const normalJob = await queue.add('normal', { foo: 'bar' });
+            const delayedJob = await queue.add('delayed', { foo: 'bar' }, { delay: 1 });
+            await queue.pause();
+            await delayedJob.promote();
+            await queue.resume();
+            const waitingJobsCount = await queue.getWaitingCount();
+            chai_1.expect(waitingJobsCount).to.be.equal(2);
+            const delayedJobsNewState = await delayedJob.getState();
+            chai_1.expect(delayedJobsNewState).to.be.equal('waiting');
+        });
     });
@@ -263,0 +274,0 @@ // TODO:

package.json

 {
   "name": "bullmq",
-  "version": "1.11.1",
+  "version": "1.11.2",
   "description": "Queue for messages and jobs based on Redis",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

src/classes/scripts.ts

@@ -433,2 +433,3 @@ /**
       queue.keys.wait,
+      queue.keys.paused,
       queue.keys.priority,
@@ -435,0 +436,0 @@ queue.keys.events,

src/test/test_job.ts

@@ -341,2 +341,20 @@ /*eslint-env node */
     });
+
+    it('should promote delayed job to the right queue if queue is paused', async () => {
+      const normalJob = await queue.add('normal', { foo: 'bar' });
+      const delayedJob = await queue.add(
+        'delayed',
+        { foo: 'bar' },
+        { delay: 1 },
+      );
+
+      await queue.pause();
+      await delayedJob.promote();
+      await queue.resume();
+
+      const waitingJobsCount = await queue.getWaitingCount();
+      expect(waitingJobsCount).to.be.equal(2);
+      const delayedJobsNewState = await delayedJob.getState();
+      expect(delayedJobsNewState).to.be.equal('waiting');
+    });
   });
@@ -343,0 +361,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1091721

increased by0.22%

Lines of code

17839

increased by0.16%

No dependency changes