diff --git a/events/sse.py b/events/sse.py
index 405c43f..c126e49 100644
--- a/events/sse.py
+++ b/events/sse.py
@@ -28,8 +28,9 @@ 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}")
+    logger.info(f"Sending data to {user_id} user quesues are {user_queues}")
     if user_id in user_queues:
+        logger.info(f"Queued {user_id}")
         # Format as SSE message once
         message = f"data: {json.dumps(data)}\n\n".encode('utf-8')