diff --git a/app/src/Service/Queue.php b/app/src/Service/Queue.php index 755e6dc..3d082a7 100644 --- a/app/src/Service/Queue.php +++ b/app/src/Service/Queue.php @@ -59,6 +59,8 @@ class Queue extends Ideal\Service try { if (!$worker->execute($job)) { $this->logger->debug("Could not execute job {$job->id}"); + $job->retries++; + $this->jobService->update($job); return false; } if (!$this->jobService->execute($job)) { @@ -67,6 +69,12 @@ class Queue extends Ideal\Service } } catch (Exception $exception) { $this->logger->warning("Could not run job {$job->id}", ['exception' => $exception]); + $job->retries++; + try { + $this->jobService->update($job); + } catch (Update $exception) { + $this->logger->error($exception->getMessage(), ['job' => $job, 'exception' => $exception]); + } return false; } return true;