Emit event if the job has been started (for demonstration - the 'star…

…ted' property needs to be written).
OptimalBits · Oct 17, 2016 · 417ba9d · 417ba9d
1 parent abd20ac
commit 417ba9d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/queue.js b/lib/queue.js
@@ -522,6 +522,9 @@ Queue.prototype.processStalledJob = function() {
   return scripts.getStalledJob(this).then(function(job){
     if (job) {
       return _this.getJobFromId(job).then(function(job){
+        if (job.started) {
+          _this.emit('stalled', job);
+        }
         return _this.processJob(job, true /* Renew the lock */);
       });
     }