From 25e05381cbaf100a766e34fb7b0272a78e53e7d7 Mon Sep 17 00:00:00 2001 From: Untone Date: Fri, 13 Oct 2023 11:36:44 +0300 Subject: [PATCH] redis-multi-exec-fix-2 --- resolvers/chats.py | 2 +- services/redis.py | 5 ++--- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/resolvers/chats.py b/resolvers/chats.py index 4eb84c9..5f6cf99 100644 --- a/resolvers/chats.py +++ b/resolvers/chats.py @@ -53,7 +53,7 @@ async def create_chat(_, info, title="", members=None): members.append(int(author_id)) await redis.execute('MULTI') - + # NOTE: private chats has no title # reuse private chat created before if exists if len(members) == 2 and title == "": diff --git a/services/redis.py b/services/redis.py index f45659f..3aa5f08 100644 --- a/services/redis.py +++ b/services/redis.py @@ -11,6 +11,8 @@ class RedisCache: async def connect(self): self._redis = aredis.StrictRedis.from_url(self._uri, decode_responses=True) + response = await self._redis.execute('PING') + print(f"[redis] PING response: {response}") async def disconnect(self): self._redis.connection_pool.disconnect() @@ -52,9 +54,6 @@ class RedisCache: print(f"[redis] MGET {key} {keys}") return await self._redis.mget(key, *keys) - async def pipeline(self): - print(f"[redis] pipeline") - return await self._redis.pipeline() redis = RedisCache()