bullmq - npm Package Compare versions

Comparing version 4.14.4 to 4.15.0

dist/cjs/classes/child-processor.js

@@ -25,5 +25,6 @@ "use strict";
     async init(processorFile) {
+        var _a;
         let processor;
         try {
-            processor = require(processorFile);
+            processor = await (_a = processorFile, Promise.resolve().then(() => require(_a)));
             if (processor.default) {
@@ -30,0 +31,0 @@ // support es2015 module.

dist/cjs/classes/index.js

@@ -8,3 +8,3 @@ "use strict";
 tslib_1.__exportStar(require("./child-processor"), exports);
-tslib_1.__exportStar(require("./delayed-error"), exports);
+tslib_1.__exportStar(require("./errors"), exports);
 tslib_1.__exportStar(require("./flow-producer"), exports);
@@ -23,5 +23,3 @@ tslib_1.__exportStar(require("./job"), exports);
 tslib_1.__exportStar(require("./scripts"), exports);
-tslib_1.__exportStar(require("./unrecoverable-error"), exports);
-tslib_1.__exportStar(require("./waiting-children-error"), exports);
 tslib_1.__exportStar(require("./worker"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/classes/job.js

@@ -10,3 +10,3 @@ "use strict";
 const scripts_1 = require("./scripts");
-const unrecoverable_error_1 = require("./unrecoverable-error");
+const unrecoverable_error_1 = require("./errors/unrecoverable-error");
 const logger = (0, util_1.debuglog)('bull');
@@ -13,0 +13,0 @@ const optsDecodeMap = {

dist/cjs/classes/worker.js

@@ -17,7 +17,5 @@ "use strict";
 const async_fifo_queue_1 = require("./async-fifo-queue");
-const delayed_error_1 = require("./delayed-error");
-const waiting_children_error_1 = require("./waiting-children-error");
+const errors_1 = require("./errors");
 // 10 seconds is the maximum time a BRPOPLPUSH can block.
 const maximumBlockTimeout = 10;
-const RATE_LIMIT_ERROR = 'bullmq:rateLimitExceeded';
 /**
@@ -32,3 +30,3 @@ *
     static RateLimitError() {
-        return new Error(RATE_LIMIT_ERROR);
+        return new errors_1.RateLimitError();
     }
@@ -364,9 +362,9 @@ constructor(name, processor, opts = {}, Connection) {
                 try {
-                    if (err.message == RATE_LIMIT_ERROR) {
+                    if (err.message == errors_1.RATE_LIMIT_ERROR) {
                         this.limitUntil = await this.moveLimitedBackToWait(job, token);
                         return;
                     }
-                    if (err instanceof delayed_error_1.DelayedError ||
+                    if (err instanceof errors_1.DelayedError ||
                         err.message == 'DelayedError' ||
-                        err instanceof waiting_children_error_1.WaitingChildrenError ||
+                        err instanceof errors_1.WaitingChildrenError ||
                         err.name == 'WaitingChildrenError') {
@@ -373,0 +371,0 @@ return;

dist/esm/classes/child-processor.js

@@ -24,3 +24,3 @@ import { ParentCommand } from '../enums';
         try {
-            processor = require(processorFile);
+            processor = await import(processorFile);
             if (processor.default) {
@@ -27,0 +27,0 @@ // support es2015 module.

dist/esm/classes/index.d.ts

@@ -5,3 +5,3 @@ export * from './async-fifo-queue';
 export * from './child-processor';
-export * from './delayed-error';
+export * from './errors';
 export * from './flow-producer';
@@ -18,4 +18,2 @@ export * from './job';
 export * from './scripts';
-export * from './unrecoverable-error';
-export * from './waiting-children-error';
 export * from './worker';

dist/esm/classes/index.js

@@ -5,3 +5,3 @@ export * from './async-fifo-queue';
 export * from './child-processor';
-export * from './delayed-error';
+export * from './errors';
 export * from './flow-producer';
@@ -20,5 +20,3 @@ export * from './job';
 export * from './scripts';
-export * from './unrecoverable-error';
-export * from './waiting-children-error';
 export * from './worker';
 //# sourceMappingURL=index.js.map

dist/esm/classes/job.js

@@ -7,3 +7,3 @@ import { __rest } from "tslib";
 import { Scripts } from './scripts';
-import { UnrecoverableError } from './unrecoverable-error';
+import { UnrecoverableError } from './errors/unrecoverable-error';
 const logger = debuglog('bull');
@@ -10,0 +10,0 @@ const optsDecodeMap = {

dist/esm/classes/worker.js

@@ -14,7 +14,5 @@ import * as fs from 'fs';
 import { AsyncFifoQueue } from './async-fifo-queue';
-import { DelayedError } from './delayed-error';
-import { WaitingChildrenError } from './waiting-children-error';
+import { DelayedError, RateLimitError, RATE_LIMIT_ERROR, WaitingChildrenError, } from './errors';
 // 10 seconds is the maximum time a BRPOPLPUSH can block.
 const maximumBlockTimeout = 10;
-const RATE_LIMIT_ERROR = 'bullmq:rateLimitExceeded';
 /**
@@ -29,3 +27,3 @@ *
     static RateLimitError() {
-        return new Error(RATE_LIMIT_ERROR);
+        return new RateLimitError();
     }
@@ -32,0 +30,0 @@ constructor(name, processor, opts = {}, Connection) {

package.json

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

New alerts

Dynamic require

Supply chain risk

Dynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.

Found 1 instance in 1 package

Fixed alerts

Dynamic require

Supply chain risk

Dynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1425052

increased by0.23%

Number of package files

648

increased by1.57%

Lines of code

22441

increased by0.21%

Number of low supply chain risk alerts

7

decreased by-12.5%

No dependency changes