worker.monitor_work_horse() should remove job from StartedJobRegistry after it finishes.

This commit is contained in:
Selwin Ong 2021-08-23 20:41:02 +07:00
parent c0dd5f7c98
commit c43b7fd298
1 changed files with 2 additions and 0 deletions

View File

@ -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