diff --git a/src/JobQueue/JobQueueRepository.php b/src/JobQueue/JobQueueRepository.php index d82cd95f..f5397152 100644 --- a/src/JobQueue/JobQueueRepository.php +++ b/src/JobQueue/JobQueueRepository.php @@ -102,6 +102,13 @@ public function purgeProcessedJobs() : void public function updateJobStatus(int $id, JobStatus $status) : void { - $this->dbConnection->update('job_queue', ['job_status' => (string)$status], ['id' => $id]); + $this->dbConnection->update( + 'job_queue', + [ + 'job_status' => (string)$status, + 'updated_at' => (string)DateTime::create(), + ], + ['id' => $id], + ); } }