diff --git a/resolvers/listener.py b/resolvers/listener.py index 95b762c..00f826a 100644 --- a/resolvers/listener.py +++ b/resolvers/listener.py @@ -34,6 +34,7 @@ async def handle_notification(n: ServiceMessage, channel: str): async def listen_task(pattern): + logger.info(f' listening {pattern} ...') async for message_data, channel in redis.listen(pattern): try: if message_data: