bullmq - npm Package Compare versions

Comparing version 5.4.3 to 5.4.4

dist/cjs/classes/queue.js

@@ -23,5 +23,4 @@ "use strict";
             .then(client => {
-            var _a, _b, _c;
             if (!this.closing) {
-                client.hset(this.keys.meta, 'opts.maxLenEvents', (_c = (_b = (_a = opts === null || opts === void 0 ? void 0 : opts.streams) === null || _a === void 0 ? void 0 : _a.events) === null || _b === void 0 ? void 0 : _b.maxLen) !== null && _c !== void 0 ? _c : 10000);
+                client.hmset(this.keys.meta, this.metaValues);
             }
@@ -55,2 +54,8 @@ })
     }
+    get metaValues() {
+        var _a, _b, _c, _d;
+        return {
+            'opts.maxLenEvents': (_d = (_c = (_b = (_a = this.opts) === null || _a === void 0 ? void 0 : _a.streams) === null || _b === void 0 ? void 0 : _b.events) === null || _c === void 0 ? void 0 : _c.maxLen) !== null && _d !== void 0 ? _d : 10000,
+        };
+    }
     get repeat() {
@@ -57,0 +62,0 @@ return new Promise(async (resolve) => {

dist/cjs/classes/worker.js

@@ -21,2 +21,5 @@ "use strict";
 const maximumBlockTimeout = 10;
+/* 1 millisecond is chosen because the granularity of our timestamps are milliseconds.
+Obviously we can still process much faster than 1 job per millisecond but delays and rate limits
+will never work with more accuracy than 1ms. */
 const minimumBlockTimeout = 0.001;
@@ -23,0 +26,0 @@ /**

dist/esm/classes/queue.d.ts

@@ -73,2 +73,3 @@ import { BaseJobOptions, BulkJobOptions, IoredisListener, QueueOptions, RepeatableJob, RepeatOptions } from '../interfaces';
     jobsOpts: BaseJobOptions;
+    opts: QueueOptions;
     private _repeat?;
@@ -84,2 +85,3 @@ constructor(name: string, opts?: QueueOptions, Connection?: typeof RedisConnection);
     get defaultJobOptions(): JobsOptions;
+    get metaValues(): Record<string, string | number>;
     get repeat(): Promise<Repeat>;
@@ -86,0 +88,0 @@ /**

dist/esm/classes/queue.js

@@ -20,5 +20,4 @@ import { v4 } from 'uuid';
             .then(client => {
-            var _a, _b, _c;
             if (!this.closing) {
-                client.hset(this.keys.meta, 'opts.maxLenEvents', (_c = (_b = (_a = opts === null || opts === void 0 ? void 0 : opts.streams) === null || _a === void 0 ? void 0 : _a.events) === null || _b === void 0 ? void 0 : _b.maxLen) !== null && _c !== void 0 ? _c : 10000);
+                client.hmset(this.keys.meta, this.metaValues);
             }
@@ -52,2 +51,8 @@ })
     }
+    get metaValues() {
+        var _a, _b, _c, _d;
+        return {
+            'opts.maxLenEvents': (_d = (_c = (_b = (_a = this.opts) === null || _a === void 0 ? void 0 : _a.streams) === null || _b === void 0 ? void 0 : _b.events) === null || _c === void 0 ? void 0 : _c.maxLen) !== null && _d !== void 0 ? _d : 10000,
+        };
+    }
     get repeat() {
@@ -54,0 +59,0 @@ return new Promise(async (resolve) => {

dist/esm/classes/worker.js

@@ -18,2 +18,5 @@ import * as fs from 'fs';
 const maximumBlockTimeout = 10;
+/* 1 millisecond is chosen because the granularity of our timestamps are milliseconds.
+Obviously we can still process much faster than 1 job per millisecond but delays and rate limits
+will never work with more accuracy than 1ms. */
 const minimumBlockTimeout = 0.001;
@@ -20,0 +23,0 @@ /**

package.json

 {
   "name": "bullmq",
-  "version": "5.4.3",
+  "version": "5.4.4",
   "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

1547627

increased by0.06%

Lines of code

24629

increased by0.07%

No dependency changes