From d3d69408425ee7a5f3353f07afb11353ded91a9b Mon Sep 17 00:00:00 2001 From: Juan Pablo Vial Date: Tue, 15 Jul 2025 23:07:32 -0400 Subject: [PATCH] Add retries when job execute failed --- app/src/Service/Queue.php | 8 ++++++++ 1 file changed, 8 insertions(+) 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;