From 2e7b7ab2a4cbe127ed7a9a786070726c16e497b3 Mon Sep 17 00:00:00 2001 From: Untone Date: Sun, 26 Nov 2023 21:31:52 +0300 Subject: [PATCH] worker-fix --- resolvers/listener.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/resolvers/listener.py b/resolvers/listener.py index f4d2f57..7ee19d8 100644 --- a/resolvers/listener.py +++ b/resolvers/listener.py @@ -19,6 +19,9 @@ async def handle_reaction(notification: dict[str, str | int]): async def reactions_worker(): async for message in redis.listen("reaction"): - msg = json.loads((await message).get("data", "")) - if msg: - await handle_reaction(msg) + message = await message + if message: + msg_data = message.get("data") + if msg_data: + msg = json.loads(msg_data) + await handle_reaction(msg)