diff --git a/events/sse.py b/events/sse.py
index 31df9ed..405c43f 100644
--- a/events/sse.py
+++ b/events/sse.py
@@ -28,6 +28,7 @@ def get_queue(user_id: str, connection_id: str) -> queue.Queue:
 
 def send_to_user(user_id: str, data: Dict[str, Any]):
     """Send data to all connections for a specific user."""
+    logger.info(f"Sending data to {user_id}")
     if user_id in user_queues:
         # Format as SSE message once
         message = f"data: {json.dumps(data)}\n\n".encode('utf-8')