diff --git a/events/sse.py b/events/sse.py index 3e0da8a..d27a14a 100644 --- a/events/sse.py +++ b/events/sse.py @@ -58,6 +58,7 @@ def sse_response_for_user(user_id: str): # Get message from queue (blocks until available) logger.info(f"blocking on get for {user_id} user") message = user_queue.get() + logger.info(f"-------received message {message}") yield message except GeneratorExit: # Clean up when client disconnects