scheduler heart for acquired locks only (#1710)

2022-09-22 19:48:38 -05:00 · 2022-09-22 19:48:38 -05:00 · 108c2ea666
parent fd116b33db
commit 108c2ea666
1 changed files with 1 additions and 1 deletions
--- a/rq/scheduler.py
+++ b/rq/scheduler.py
@ -184,7 +184,7 @@ class RQScheduler:
                       ", ".join(self.acquired_locks))
        if len(self._queue_names) > 1:
            with self.connection.pipeline() as pipeline:
-                for name in self._queue_names:
+                for name in self._acquired_locks:
                    key = self.get_locking_key(name)
                    pipeline.expire(key, self.interval + 60)
                pipeline.execute()