better-queue - npm Package Compare versions

Comparing version 3.8.5 to 3.8.6

lib/queue.js

@@ -27,2 +27,3 @@ var uuid = require('uuid');
   self.precondition = opts.precondition || function (cb) { cb(null, true) };
+  self.setImmediate = opts.setImmediate || setImmediate;
   self.id = opts.id || 'id';
@@ -286,3 +287,3 @@ self.priority = opts.priority || null;
     self._isWriting = false;
-    setImmediate(function () {
+    self.setImmediate(function () {
       self._writeNextTask();
@@ -484,3 +485,3 @@ })
     }
-    setImmediate(function () {
+    self.setImmediate(function () {
       self._processNextIfAllowed();
@@ -631,3 +632,3 @@ })
       } else {
-        setImmediate(function () {
+        self.setImmediate(function () {
           self.emit('task_retry', taskId, self._retries[taskId]);
@@ -693,3 +694,3 @@ self._queueTask(taskId, batch[taskId], tickets[taskId]);
     } else {
-      setImmediate(function () {
+      self.setImmediate(function () {
         finishAndGetNext()
@@ -696,0 +697,0 @@ })

package.json

 {
   "name": "better-queue",
-  "version": "3.8.5",
+  "version": "3.8.6",
   "description": "Better Queue for NodeJS",
@@ -5,0 +5,0 @@ "main": "lib/queue.js",

test/basic.js

@@ -26,4 +26,4 @@ var assert = require('assert');
     }, { autoResume: true })
-    q.on('task_failed', function (taskId, msg) {
-      assert.equal(msg, "failed");
+    q.on('task_failed', function (taskId, err) {
+      assert.equal(err.message, "failed");
       done();
@@ -30,0 +30,0 @@ })

No alert changes

Improved metrics

Total package byte prevSize

77843

increased by0.11%

Lines of code

2029

increased by0.05%

No dependency changes