fix: logging from last commit

daneren2005 · Oct 16, 2024 · 5facd36 · 5facd36
1 parent 980571f
commit 5facd36
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/Resque/Job.php b/lib/Resque/Job.php
@@ -214,7 +214,7 @@ public function perform()
 			$removed = Resque::redis()->lrem('working:' . $this->queue, 0, $this->payload['id']);
 			Resque::redis()->del('job:' . $this->payload['id'] . ':worker');
 			if($removed <= 0) {
-				$this->logger->log(Psr\Log\LogLevel::WARNING, $this->payload['id'] . ' was not removed from working: ' . $this->queue . ', retrying in 250ms.');
+				$this->worker->logger->log(Psr\Log\LogLevel::WARNING, $this->payload['id'] . ' was not removed from working: ' . $this->queue . ', retrying in 250ms.');
 				usleep(250000);
 
 				$removed = Resque::redis()->lrem('working:' . $this->queue, 0, $this->payload['id']);