@nftx/queue - npm Package Compare versions

Comparing version 1.14.0 to 1.14.1

CHANGELOG.md

@@ -6,2 +6,13 @@ # Change Log
 
+## [1.14.1](https://github.com/NFTX-project/nftxjs/compare/v1.14.0...v1.14.1) (2024-02-01)
+
+
+### Bug Fixes
+
+* add retry and error handling settings to queues ([03fe4d0](https://github.com/NFTX-project/nftxjs/commit/03fe4d0ebbe7deb58043e2822f0328d4221c5bd9))
+
+
+
+
+
 # [1.14.0](https://github.com/NFTX-project/nftxjs/compare/v1.13.2...v1.14.0) (2024-02-01)
@@ -8,0 +19,0 @@

dist/cjs/queue.js

@@ -115,3 +115,12 @@ 'use strict';
   return NftxQueue.queues[queueName] || new NftxQueue(queueName, {
-    connection: getConnection$1(queueName)
+    connection: getConnection$1(queueName),
+    defaultJobOptions: {
+      attempts: 5,
+      removeOnComplete: true,
+      removeOnFail: true,
+      backoff: {
+        type: 'exponential',
+        delay: 30000
+      }
+    }
   });
@@ -212,3 +221,3 @@ };
     } = job;
-    callback({
+    return callback({
       payload: data,
@@ -230,3 +239,3 @@ type: name
     } = job;
-    callback({
+    return callback({
       type: name,
@@ -233,0 +242,0 @@ payload: data

dist/es/queue.js

@@ -107,3 +107,12 @@ import IORedis from 'ioredis';
   return NftxQueue.queues[queueName] || new NftxQueue(queueName, {
-    connection: getConnection$1(queueName)
+    connection: getConnection$1(queueName),
+    defaultJobOptions: {
+      attempts: 5,
+      removeOnComplete: true,
+      removeOnFail: true,
+      backoff: {
+        type: 'exponential',
+        delay: 30000
+      }
+    }
   });
@@ -204,3 +213,3 @@ };
     } = job;
-    callback({
+    return callback({
       payload: data,
@@ -222,3 +231,3 @@ type: name
     } = job;
-    callback({
+    return callback({
       type: name,
@@ -225,0 +234,0 @@ payload: data

package.json

 {
   "name": "@nftx/queue",
-  "version": "1.14.0",
+  "version": "1.14.1",
   "description": "",
@@ -5,0 +5,0 @@ "homepage": "https://github.com/NFTX-project/nftxjs",

src/listeners/onNetworkSignal.ts

@@ -15,3 +15,3 @@ import createWorker from './createWorker';
     const { name, data } = job;
-    callback({ payload: data, type: name as any });
+    return callback({ payload: data, type: name as any });
   });
@@ -18,0 +18,0 @@ };

src/listeners/onSignal.ts

@@ -11,3 +11,3 @@ import { SIGNAL_QUEUE_NAME } from '../constants';
     const { name, data } = job;
-    callback({ type: name as any, payload: data });
+    return callback({ type: name as any, payload: data });
   });
@@ -14,0 +14,0 @@ };

src/queues/getQueue.ts

@@ -26,3 +26,14 @@ import { Queue, QueueOptions } from 'bullmq';
     NftxQueue.queues[queueName] ||
-    new NftxQueue(queueName, { connection: getConnection(queueName) })
+    new NftxQueue(queueName, {
+      connection: getConnection(queueName),
+      defaultJobOptions: {
+        attempts: 5,
+        removeOnComplete: true,
+        removeOnFail: true,
+        backoff: {
+          type: 'exponential',
+          delay: 30000,
+        },
+      },
+    })
   );
@@ -29,0 +40,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

36131

increased by2.5%

Lines of code

957

increased by3.13%

No dependency changes