bullmq - npm Package Compare versions

Comparing version 5.1.11 to 5.1.12

dist/cjs/classes/redis-connection.js

@@ -195,5 +195,13 @@ "use strict";
                     await this.initializing;
-                    if (!this.shared) {
+                }
+                if (!this.shared) {
+                    if (status == 'initializing') {
+                        // If we have not still connected to Redis, we need to disconnect.
+                        this._client.disconnect();
+                    }
+                    else {
                         await this._client.quit();
                     }
+                    // As IORedis does not update this status properly, we do it ourselves.
+                    this._client['status'] = 'end';
                 }
@@ -200,0 +208,0 @@ }

dist/cjs/scripts/addDelayedJob-6.js

@@ -44,3 +44,2 @@ "use strict";
 local data = ARGV[2]
-local opts = cmsgpack.unpack(ARGV[3])
 local parentKey = args[5]
@@ -259,2 +258,3 @@ local repeatJobKey = args[9]
 local maxEvents = getOrSetMaxEvents(metaKey)
+local opts = cmsgpack.unpack(ARGV[3])
 local parentDependenciesKey = args[7]
@@ -261,0 +261,0 @@ local timestamp = args[4]

dist/esm/classes/redis-connection.js

@@ -192,5 +192,13 @@ import { EventEmitter } from 'events';
                     await this.initializing;
-                    if (!this.shared) {
+                }
+                if (!this.shared) {
+                    if (status == 'initializing') {
+                        // If we have not still connected to Redis, we need to disconnect.
+                        this._client.disconnect();
+                    }
+                    else {
                         await this._client.quit();
                     }
+                    // As IORedis does not update this status properly, we do it ourselves.
+                    this._client['status'] = 'end';
                 }
@@ -197,0 +205,0 @@ }

dist/esm/scripts/addDelayedJob-6.js

@@ -41,3 +41,2 @@ const content = `--[[
 local data = ARGV[2]
-local opts = cmsgpack.unpack(ARGV[3])
 local parentKey = args[5]
@@ -256,2 +255,3 @@ local repeatJobKey = args[9]
 local maxEvents = getOrSetMaxEvents(metaKey)
+local opts = cmsgpack.unpack(ARGV[3])
 local parentDependenciesKey = args[7]
@@ -258,0 +258,0 @@ local timestamp = args[4]

package.json

 {
   "name": "bullmq",
-  "version": "5.1.11",
+  "version": "5.1.12",
   "description": "Queue for messages and jobs based on Redis",
@@ -5,0 +5,0 @@ "homepage": "https://bullmq.io/",

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

1498520

increased by0.05%

Lines of code

23769

increased by0.07%

No dependency changes