Only emit 'stalled' event if there were stalled jobs.

OptimalBits · Oct 15, 2016 · 4124ecf · 4124ecf
1 parent 00e213a
commit 4124ecf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/queue.js b/lib/queue.js
@@ -547,7 +547,9 @@ Queue.prototype.processStalledJobs = function(grace){
     return this.closing;
   } else{
     return scripts.processStalledJobs(this, grace).then(function(jobs){
-      _this.emit('stalled', jobs);
+      if(jobs.length > 0){
+        _this.emit('stalled', jobs);
+      }
       return null;
     }).catch(function(err){
       console.error(err);