fix log (#1709)

2 years ago · 0c47a8edf4
parent 153d29cce7
commit 0c47a8edf4
1 changed files with 1 additions and 1 deletions
--- 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(