async-queue-improved
Advanced tools
Comparing version 0.0.6 to 0.0.7
11
index.js
@@ -14,4 +14,10 @@ var async = require('async'), | ||
if (!err) return callback.apply(null, arguments) | ||
if (!task.retries) return callback(err) | ||
if (!err.timeout) return callback.apply(null, arguments) | ||
if (!task.retries) { | ||
// store the error | ||
queue.errors.push({ err: err, task: task }) | ||
return callback(err) | ||
} | ||
// console.error(err.stack || err) | ||
@@ -32,4 +38,3 @@ task.attempts = task.attempts || 0 | ||
var err = new Error("Task " + task.id + " has timed out (timeout was " + task.timeout + "ms)") | ||
// store the error | ||
queue.errors.push({ err: err, task: task }) | ||
err.timeout = true | ||
// pass the error to a callback | ||
@@ -36,0 +41,0 @@ retryCallback(err) |
{ | ||
"name": "async-queue-improved", | ||
"version": "0.0.6", | ||
"version": "0.0.7", | ||
"description": "Improved queue based `async` package", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
5225
139