limit accumulation of any particular job

mgregson · Jan 30, 2016 · 5d0278c · 5d0278c
1 parent 8b2ea5b
commit 5d0278c
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/lib/agenda.js b/lib/agenda.js
@@ -486,7 +486,13 @@ function processJobs(extraJob) {
 
       if (jobs) {
         enqueueJobs(jobs);
-        if(jobQueue.length < 2*self._maxConcurrency)
+        var jobOccurrenceCount = 0;
+        jobQueue.forEach(function(queued_job){
+          if(queued_job.name === name)
+            jobOccurrenceCount++;
+        });
+        if(jobQueue.length < 2*self._maxConcurrency &&
+           jobOccurrenceCount < definitions[name].concurrency)
           jobQueueFilling(name);
         jobProcessing();
       }