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)