diff options
| author | Selwin Ong <selwin.ong@gmail.com> | 2021-11-16 22:24:04 +0700 |
|---|---|---|
| committer | Selwin Ong <selwin.ong@gmail.com> | 2021-11-16 22:24:04 +0700 |
| commit | 5b8c107bc43d2895a20e93f6133918bd01f21b5b (patch) | |
| tree | cc69501cd5d9722bea228f1416820de48fa28b35 | |
| parent | e7be61a455caa7b8717d01518931e15288bdd3d9 (diff) | |
| download | rq-fix-result-ttl-0.tar.gz | |
Fixed a bug in worker.maintain_heartbeats().fix-result-ttl-0
| -rw-r--r-- | rq/worker.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/rq/worker.py b/rq/worker.py index 8411f9b..cac6bdb 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -885,7 +885,7 @@ class Worker: ttl = self.get_heartbeat_ttl(job) job.heartbeat(utcnow(), ttl, pipeline=pipeline, xx=True) results = pipeline.execute() - if results[3] == 1: + if results[2] == 1: self.connection.delete(job.key) def main_work_horse(self, job, queue): |