Fix: Use SCAN instead of KEYS for Redis cluster compatibility (#19871)

2025-12-11 20:05:19 +00:00 · 2025-12-12 03:30:51 +08:00 · 2025-12-12 03:30:51 +08:00 · 8e661a4e73
commit 8e661a4e73
parent 379f888c9d
1 changed files with 3 additions and 1 deletions
--- a/backend/open_webui/socket/utils.py
+++ b/backend/open_webui/socket/utils.py
@ -190,7 +190,9 @@ class YdocManager:

    async def remove_user_from_all_documents(self, user_id: str):
        if self._redis:
-            keys = await self._redis.keys(f"{self._redis_key_prefix}:*")
+            keys = []
+            async for key in self._redis.scan_iter(match=f"{self._redis_key_prefix}:*", count=100):
+                keys.append(key)
            for key in keys:
                if key.endswith(":users"):
                    await self._redis.srem(key, user_id)