bull - npm Package Compare versions

Comparing version 3.29.2 to 3.29.3

CHANGELOG.md

@@ -0,1 +1,8 @@
+## [3.29.3](https://github.com/OptimalBits/bull/compare/v3.29.2...v3.29.3) (2021-10-13)
+
+
+### Bug Fixes
+
+* **name-processors:** wait for all processors when closing fixes [#1618](https://github.com/OptimalBits/bull/issues/1618) ([79ce013](https://github.com/OptimalBits/bull/commit/79ce013af695f96ff57106b213982647e0783d3f))
+
 ## [3.29.2](https://github.com/OptimalBits/bull/compare/v3.29.1...v3.29.2) (2021-09-08)
@@ -2,0 +9,0 @@

lib/queue.js

@@ -619,8 +619,8 @@ 'use strict';
   return this._initProcess().then(() => {
-    return this.start(concurrency);
+    return this.start(concurrency, name);
   });
 };
 
-Queue.prototype.start = function(concurrency) {
-  return this.run(concurrency).catch(err => {
+Queue.prototype.start = function(concurrency, name) {
+  return this.run(concurrency, name).catch(err => {
     this.emit('error', err, 'error running queue');
@@ -864,3 +864,3 @@ throw err;
 
-Queue.prototype.run = function(concurrency) {
+Queue.prototype.run = function(concurrency, handlerName) {
   const promises = [];
@@ -879,3 +879,3 @@
           new Promise(resolve => {
-            this.processJobs(concurrency, resolve);
+            this.processJobs(`${handlerName}:${concurrency}`, resolve);
           })
@@ -1285,3 +1285,5 @@ );
 
-  return Promise.all(this.processing).then(() => forcedReconnection);
+  return Promise.all(Object.values(this.processing)).then(
+    () => forcedReconnection
+  );
 };
@@ -1288,0 +1290,0 @@

package.json

 {
   "name": "bull",
-  "version": "3.29.2",
+  "version": "3.29.3",
   "description": "Job manager",
@@ -5,0 +5,0 @@ "engines": {

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

174227

increased by0.23%

Lines of code

3275

increased by0.06%

No dependency changes