deleting the running state in case of error so that the job is indeed…

… retried
dominictarr · Aug 13, 2013 · 00e2803 · 00e2803
1 parent a2c547b
commit 00e2803
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/index.js b/index.js
@@ -56,6 +56,7 @@ module.exports = function (input, jobs, map, work) {
       done = true
       if(err) {
         return setTimeout(function () {
+          delete running[hash]
           doJob(data)
         //hardcoded timeout WTF
         }, 50)