fix: check for pending jobs

whatwedo · Aug 15, 2023 · fcc782e · fcc782e
1 parent d3ef159
commit fcc782e
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/Manager/ExecutionManager.php b/src/Manager/ExecutionManager.php
@@ -96,6 +96,16 @@ public function isRunNeeded(CronInterface $cronJob, int $checkInterval = 15): bo
             return false;
         }
 
+        // Check for pending
+        $pendingExcecution = $this->getPendingExecution($cronJob);
+        if ($pendingExcecution) {
+            $this->logger->debug(sprintf('%s has pending exection. Scheduling it now.', $cronJob::class));
+            $this->cleanupPending($cronJob);
+
+            return true;
+        }
+
+
         $nextExecutionDate =  (new CronExpression($cronJob->getExpression()))
             ->getNextRunDate('-' . $checkInterval .' seconds');