diff --git a/services/presence.py b/services/presence.py index d4e068a..00c131a 100644 --- a/services/presence.py +++ b/services/presence.py @@ -9,5 +9,6 @@ async def notify_message(message: Message, chat_id: str): data = {"payload": message, "kind": "new_message"} try: await redis.publish(channel_name, json.dumps(data)) + print(f"[services.presence] notification was sent successfully {data}") except Exception as e: print(f"Failed to publish to channel {channel_name}: {e}")