@vendure/job-queue-plugin - npm Package Compare versions

Comparing version 2.0.0-beta.1 to 2.0.0-beta.2

package.json

 {
     "name": "@vendure/job-queue-plugin",
-    "version": "2.0.0-beta.1",
+    "version": "2.0.0-beta.2",
     "license": "MIT",
@@ -26,4 +26,4 @@ "main": "package/index.js",
         "@google-cloud/pubsub": "^2.8.0",
-        "@vendure/common": "^2.0.0-beta.1",
-        "@vendure/core": "^2.0.0-beta.1",
+        "@vendure/common": "2.0.0-beta.2",
+        "@vendure/core": "2.0.0-beta.2",
         "bullmq": "^3.6.1",
@@ -34,3 +34,3 @@ "ioredis": "^5.3.0",
     },
-    "gitHead": "1283d87f0fe171a174507bfa1926520e1fbc97b1"
+    "gitHead": "30a297e9afabcfd129d30c843cabd1b5761046a6"
 }

package/bullmq/bullmq-job-queue-strategy.js

@@ -64,2 +64,3 @@ "use strict";
                 try {
+                    // eslint-disable-next-line
                     job.on('progress', _job => bullJob.updateProgress(_job.progress));
@@ -180,2 +181,3 @@ const result = await processFn(job);
     }
+    // TODO V2: actually make it use the olderThan parameter
     async removeSettledJobs(queueNames, olderThan) {
@@ -193,2 +195,3 @@ try {
     }
+    // eslint-disable-next-line @typescript-eslint/require-await
     async start(queueName, process) {
@@ -201,6 +204,6 @@ this.queueNameProcessFnMap.set(queueName, process);
                 .on('closing', e => core_1.Logger.verbose(`BullMQ Worker closing: ${e}`, constants_1.loggerCtx))
-                .on('closed', () => core_1.Logger.verbose(`BullMQ Worker closed`))
+                .on('closed', () => core_1.Logger.verbose('BullMQ Worker closed'))
                 .on('failed', (job, error) => {
-                var _a;
-                core_1.Logger.warn(`Job ${job === null || job === void 0 ? void 0 : job.id} [${job === null || job === void 0 ? void 0 : job.name}] failed (attempt ${job === null || job === void 0 ? void 0 : job.attemptsMade} of ${(_a = job === null || job === void 0 ? void 0 : job.opts.attempts) !== null && _a !== void 0 ? _a : 1})`);
+                var _a, _b, _c, _d;
+                core_1.Logger.warn(`Job ${(_a = job === null || job === void 0 ? void 0 : job.id) !== null && _a !== void 0 ? _a : '(unknown id)'} [${(_b = job === null || job === void 0 ? void 0 : job.name) !== null && _b !== void 0 ? _b : 'unknown name'}] failed (attempt ${(_c = job === null || job === void 0 ? void 0 : job.attemptsMade) !== null && _c !== void 0 ? _c : 'unknown'} of ${(_d = job === null || job === void 0 ? void 0 : job.opts.attempts) !== null && _d !== void 0 ? _d : 1})`);
             })
@@ -211,3 +214,4 @@ .on('stalled', (jobId) => {
                 .on('completed', (job) => {
-                core_1.Logger.debug(`Job ${job.id} [${job.name}] completed`);
+                var _a;
+                core_1.Logger.debug(`Job ${(_a = job === null || job === void 0 ? void 0 : job.id) !== null && _a !== void 0 ? _a : 'unknown id'} [${job.name}] completed`);
             });
@@ -220,6 +224,3 @@ }
             try {
-                await Promise.all([
-                    this.queue.disconnect(),
-                    this.worker.disconnect(),
-                ]);
+                await Promise.all([this.queue.disconnect(), this.worker.disconnect()]);
             }
@@ -226,0 +227,0 @@ catch (e) {

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

71104

increased by0.75%

Lines of code

1107

increased by0.18%

No dependency changes