bull - npm Package Compare versions

Comparing version 4.8.3 to 4.8.4

CHANGELOG.md

@@ -0,1 +1,8 @@
+## [4.8.4](https://github.com/OptimalBits/bull/compare/v4.8.3...v4.8.4) (2022-06-16)
+
+
+### Bug Fixes
+
+* **worker:** better disconnect when blocking connection ([b9ea7f4](https://github.com/OptimalBits/bull/commit/b9ea7f4780948d4556548e6bf13e2c3271939d12))
+
 ## [4.8.3](https://github.com/OptimalBits/bull/compare/v4.8.2...v4.8.3) (2022-05-12)
@@ -2,0 +9,0 @@

lib/queue.js

@@ -573,3 +573,7 @@ 'use strict';
 Queue.prototype.disconnect = async function() {
-  await Promise.all(this.clients.map(redisClientDisconnect));
+  await Promise.all(
+    this.clients.map(client =>
+      client.blocked ? client.disconnect() : redisClientDisconnect(client)
+    )
+  );
 };
@@ -1194,2 +1198,3 @@
     try {
+      this.bclient.blocked = true;
       const jobId = await this.bclient.brpoplpush(
@@ -1200,2 +1205,3 @@ this.keys.wait,
       );
+      this.bclient.blocked = false;
 
@@ -1202,0 +1208,0 @@ if (jobId) {

package.json

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

README.md

@@ -275,3 +275,3 @@
 
-  // or give a error if error
+  // or give an error if error
   done(new Error('error transcoding'));
@@ -293,3 +293,3 @@
 
-  // or give a error if error
+  // or give an error if error
   done(new Error('error transcoding'));
@@ -311,3 +311,3 @@
 
-  // or give a error if error
+  // or give an error if error
   done(new Error('error transcoding'));
@@ -314,0 +314,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

196967

increased by0.21%

Lines of code

3521

increased by0.17%

No dependency changes