From 0c47a8edf467aae0f6b0cd5a48609b8b35238af0 Mon Sep 17 00:00:00 2001 From: Rony Lutsky Date: Thu, 22 Sep 2022 06:50:11 +0300 Subject: [PATCH] fix log (#1709) --- rq/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/worker.py b/rq/worker.py index f996e6b3..122e16e5 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -840,7 +840,7 @@ class Worker: if job_status is None: # Job completed and its ttl has expired return - elif job_status == JobStatus.STOPPED: + elif self._stopped_job_id == job.id: # Work-horse killed deliberately self.log.warning('Job stopped by user, moving job to FailedJobRegistry') self.handle_job_failure(