ADD COMPREHENSIVE DEBUG LOGGING - will show exactly where SSE breaks

src/api/app.py

@@ -192,6 +192,8 @@ async def stream_progress(session_id: str):
         - token_update: Token budget updates
         - analysis_complete: When the entire workflow finishes
     """
+    print(f"🌊 SSE ENDPOINT: Client connected for session_id={session_id}")
+    
     async def event_generator():
         try:
             # Send initial connection event
@@ -329,6 +331,7 @@ async def run_analysis(
         
         # Set HTTP session key for SSE streaming (so orchestrator emits to correct stream)
         agent.http_session_key = session_key
+        print(f"🔑 SET agent.http_session_key = {session_key}")
         
         try:
             # Agent's session memory should resolve file_path from context
@@ -447,6 +450,7 @@ async def run_analysis(
         
         # Set HTTP session key for SSE streaming (so orchestrator emits to correct stream)
         agent.http_session_key = session_key
+        print(f"\ud83d\udd11 SET agent.http_session_key = {session_key} (file upload)")
         
         # Call existing agent logic
         logger.info(f"Starting analysis with task: {task_description}")

src/orchestrator.py

@@ -3039,13 +3039,18 @@ You are a DOER. Complete workflows based on user intent."""
                     if not session_key_for_emit and hasattr(self, 'session') and self.session:
                         session_key_for_emit = self.session.session_id
                     
+                    print(f"🔍 DEBUG EMIT: http_session_key={getattr(self, 'http_session_key', 'NOT SET')}, session={hasattr(self, 'session')}, final_key={session_key_for_emit}")
+                    
                     if session_key_for_emit:
+                        print(f"🚀 EMITTING tool_executing for session: {session_key_for_emit}, tool: {tool_name}")
                         progress_manager.emit(session_key_for_emit, {
                             'type': 'tool_executing',
                             'tool': tool_name,
                             'message': f"🔧 Executing: {tool_name}",
                             'arguments': tool_args
                         })
+                    else:
+                        print(f"⚠️ SKIPPING EMIT: No session key available")
                     
                     # Execute tool
                     tool_result = self._execute_tool(tool_name, tool_args)

src/progress_manager.py

@@ -36,6 +36,8 @@ class ProgressManager:
             session_id: Session identifier
             event: Event data (must include 'type' and 'message')
         """
+        print(f"📡 PROGRESS_MANAGER EMIT: session={session_id}, event_type={event.get('type')}, msg={event.get('message', '')[:50]}")
+        
         # Add timestamp
         event['timestamp'] = datetime.now().isoformat()
         
@@ -46,8 +48,11 @@ class ProgressManager:
         if len(self._history[session_id]) > 500:
             self._history[session_id] = self._history[session_id][-500:]
         
+        print(f"📝 History stored, total events for {session_id}: {len(self._history[session_id])}")
+        
         # Send to all active subscribers
         if session_id in self._queues:
+            print(f"✅ Found {len(self._queues[session_id])} subscribers for {session_id}")
             dead_queues = []
             for queue in self._queues[session_id]:
                 try: