From 108c2ea66652737aa54038f7d71477af625b58eb Mon Sep 17 00:00:00 2001 From: Miles Winter Date: Thu, 22 Sep 2022 19:48:38 -0500 Subject: [PATCH] scheduler heart for acquired locks only (#1710) --- rq/scheduler.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/scheduler.py b/rq/scheduler.py index 850c1bc1..2e470e58 100644 --- 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()