From 4de7c9fe1b540c8683995ce892df53b073d53113 Mon Sep 17 00:00:00 2001 From: Untone Date: Fri, 13 Oct 2023 12:25:54 +0300 Subject: [PATCH] redis-multi-exec-fix-5 --- services/redis.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/services/redis.py b/services/redis.py index 0f244c5..e10f15b 100644 --- a/services/redis.py +++ b/services/redis.py @@ -9,16 +9,17 @@ class RedisCache: self.pubsub_channels = [] self._redis = None self._pubsub = None + self.loop = asyncio.get_event_loop() async def connect(self): - self._redis = aredis.StrictRedis.from_url(self._uri, decode_responses=True) - await self._redis.connection_pool.connect() + self._redis = aredis.StrictRedis.from_url(self._uri, decode_responses=True, loop=self.loop) + await self._redis.connection_pool.get_connection() self._pubsub = self._redis.pubsub() response = await self.execute('PING') print(f"[redis] PING response: {response}") async def disconnect(self): - self._redis.connection_pool.disconnect() + self._redis.connection_pool.re self._redis = None self._pubsub = None