Merge pull request #1 from dccunha/dc/fix/using_scan_at_cleanup

Using SCAN instead of KEYS at remove_queue
resque · Jun 4, 2019 · a7d8a01 · a7d8a01
2 parents 3636a72 + 0b64d02
commit a7d8a01
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/resque/unique_in_queue/queue.rb b/lib/resque/unique_in_queue/queue.rb
@@ -64,8 +64,9 @@ def destroy(queue, klass, *args)
       end
 
       def cleanup(queue)
-        keys = redis.keys("#{Resque::UniqueInQueue.configuration&.unique_in_queue_key_base}:queue:#{queue}:job:*")
-        redis.del(*keys) if keys.any?
+        pattern = "#{Resque::UniqueInQueue.configuration&.unique_in_queue_key_base}:queue:#{queue}:job:*"
+        keys = redis.scan_each(match: pattern, count: 1_000_000).to_a
+        redis.del(keys) if keys.any?
       end
 
       private