fix(core): Correctly defer incomplete jobs on shutdown

vendure-ecommerce · Mar 30, 2021 · d3fa83a · d3fa83a
1 parent e9b18fe
commit d3fa83a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/packages/core/src/job-queue/polling-job-queue-strategy.ts b/packages/core/src/job-queue/polling-job-queue-strategy.ts
@@ -71,7 +71,7 @@ class ActiveQueue<Data extends JobData<Data> = {}> {
                                 },
                             )
                             .finally(() => {
-                                if (!this.running) {
+                                if (!this.running && nextJob.state !== JobState.PENDING) {
                                     return;
                                 }
                                 nextJob.off('progress', onProgress);