From c43b7fd298f9a782dcff55b1beb0335f510696d8 Mon Sep 17 00:00:00 2001
From: Selwin Ong <selwin.ong@gmail.com>
Date: Mon, 23 Aug 2021 20:41:02 +0700
Subject: [PATCH] worker.monitor_work_horse() should remove job from
 StartedJobRegistry after it finishes.

---
 rq/worker.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/rq/worker.py b/rq/worker.py
index e78f0ea8..bf4b4162 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