Merge pull request 'perf: replace Redis KEYS with SCAN for cache invalidation (#98)' (#101) from ai/major-domo-v2-98 into next-release

Reviewed-on: #101
2026-03-20 15:26:42 +00:00 · 2026-03-20 15:26:42 +00:00 · 8d97e1dd17
commit 8d97e1dd17
parent 52fa56cb69 df9e9bedbe
1 changed files with 5 additions and 3 deletions
--- a/utils/cache.py
+++ b/utils/cache.py
@ -188,9 +188,11 @@ class CacheManager:
            
        try:
            pattern = f"{prefix}:*"
-            keys = await client.keys(pattern)
-            if keys:
-                deleted = await client.delete(*keys)
+            keys_to_delete = []
+            async for key in client.scan_iter(match=pattern):
+                keys_to_delete.append(key)
+            if keys_to_delete:
+                deleted = await client.delete(*keys_to_delete)
                logger.info(f"Cleared {deleted} cache keys with prefix '{prefix}'")
                return deleted
        except Exception as e: