replaces #keys with #scan_each to list runners

mosquito-cr · Jun 14, 2024 · afa61c7 · afa61c7
1 parent 5736c41
commit afa61c7
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/src/mosquito/redis_backend.cr b/src/mosquito/redis_backend.cr
@@ -131,9 +131,13 @@ module Mosquito
 
     def self.list_runners : Array(String)
       runner_prefix = build_key(LIST_OF_QUEUES_KEY)
-      Redis.instance.keys("#{runner_prefix}:*")
-        .map(&.as(String))
-        .map(&.sub(runner_prefix, ""))
+      keys = [] of String
+
+      Redis.instance.scan_each("#{runner_prefix}:*") do |key|
+        keys << key.as(String).sub(runner_prefix, "")
+      end
+
+      keys
     end
 
     # is this even a good idea?