diff --git a/backend/open_webui/utils/tether.py b/backend/open_webui/utils/tether.py index 95b95ab3af..c42598724b 100644 --- a/backend/open_webui/utils/tether.py +++ b/backend/open_webui/utils/tether.py @@ -219,6 +219,8 @@ class Hub: async_mode=True, decode_responses=False, ) + # RedisCluster can't route a pubsub subscribe until initialize() fills its slot cache. + await self.redis.initialize() pubsub = self.redis.pubsub() await pubsub.subscribe(self.channel(self.worker)) self.listener = asyncio.create_task(self.listen(pubsub))