We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 6ff4b90 + 824a9ba commit 04b985fCopy full SHA for 04b985f
django_lightweight_queue/backends/reliable_redis.py
@@ -55,7 +55,7 @@ def startup(self, queue: QueueName) -> None:
55
# Without this the startup process can end up racing against workers on
56
# other machines which are validly re-populating their processing queues
57
# as they work on jobs.
58
- current_processing_queue_keys = set(self.client.keys(pattern))
+ current_processing_queue_keys = set(self.client.scan_iter(pattern))
59
expected_processing_queue_keys = set(
60
self._processing_key(queue, worker_number).encode()
61
for worker_number in get_worker_numbers(queue)
0 commit comments