fix(jobprocessor): set job enqueud to true for future jobs

simllll · simllll · commit a3d42032011f · 2020-10-20T20:09:04.000+02:00
diff --git a/src/JobProcessor.ts b/src/JobProcessor.ts
@@ -392,6 +392,7 @@ export class JobProcessor {
 				setTimeout(() => {
 					this.jobProcessing();
 				}, runIn);
+				jobEnqueued = true;
 			}
 			if (this.localQueueProcessing < this.maxConcurrency && jobEnqueued) {
 				// additionally run again and check if there are more jobs that we can process right now (as long concurrency not reached)

Original file line number	Diff line number	Diff line change
`@@ -392,6 +392,7 @@ export class JobProcessor {`
`392`	`392`	`setTimeout(() => {`
`393`	`393`	`this.jobProcessing();`
`394`	`394`	`}, runIn);`
	`395`	`+ jobEnqueued = true;`
`395`	`396`	`}`
`396`	`397`	`if (this.localQueueProcessing < this.maxConcurrency && jobEnqueued) {`
`397`	`398`	`// additionally run again and check if there are more jobs that we can process right now (as long concurrency not reached)`