diff options
| author | Selwin Ong <selwin.ong@gmail.com> | 2021-08-23 20:41:02 +0700 |
|---|---|---|
| committer | Selwin Ong <selwin.ong@gmail.com> | 2021-08-23 20:41:02 +0700 |
| commit | c43b7fd298f9a782dcff55b1beb0335f510696d8 (patch) | |
| tree | 63971e888e414a26f9e855a897e172f96247f466 | |
| parent | c0dd5f7c982f881c561e0ab5b3ba7f57e67d0ca8 (diff) | |
| download | rq-logging-additions.tar.gz | |
worker.monitor_work_horse() should remove job from StartedJobRegistry after it finishes.logging-additions
| -rw-r--r-- | rq/worker.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/rq/worker.py b/rq/worker.py index e78f0ea..bf4b416 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -830,6 +830,8 @@ class Worker: self.heartbeat() self.set_current_job_working_time(0) + queue.started_job_registry.remove(job) + self._horse_pid = 0 # Set horse PID to 0, horse has finished working if ret_val == os.EX_OK: # The process exited normally. return |