fix(worker): run stalled check directly first time

taskforcesh · Feb 23, 2023 · f71ec03 · f71ec03
1 parent 49e860c
commit f71ec03
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/classes/worker.ts b/src/classes/worker.ts
@@ -358,6 +358,7 @@ export class Worker<
 
   async run() {
     if (!this.stalledCheckTimer && !this.opts.skipStalledCheck) {
+      await this.runStalledJobsCheck();
       this.stalledCheckTimer = setInterval(() => {
         this.runStalledJobsCheck();
       }, this.opts.stalledInterval);