FIX CRITICAL: Remove emoji from print statements causing Unicode encoding errors

src/api/app.py

@@ -192,7 +192,7 @@ 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}")
+    print(f"[SSE] ENDPOINT: Client connected for session_id={session_id}")
     
     async def event_generator():
         try:
@@ -331,7 +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}")
+        print(f"[SSE] SET agent.http_session_key = {session_key}")
         
         try:
             # Agent's session memory should resolve file_path from context
@@ -450,7 +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)")
+        print(f"[SSE] 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,10 +3039,10 @@ 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}")
+                    print(f"[SSE] 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}")
+                        print(f"[SSE] 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,
@@ -3050,7 +3050,7 @@ You are a DOER. Complete workflows based on user intent."""
                             'arguments': tool_args
                         })
                     else:
-                        print(f"⚠️ SKIPPING EMIT: No session key available")
+                        print(f"[SSE] WARNING: SKIPPING EMIT: No session key available")
                     
                     # Execute tool
                     tool_result = self._execute_tool(tool_name, tool_args)

src/progress_manager.py

@@ -36,7 +36,7 @@ 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]}")
+        print(f"[SSE] PROGRESS_MANAGER EMIT: session={session_id}, event_type={event.get('type')}, msg={event.get('message', '')[:50]}")
         
         # Add timestamp
         event['timestamp'] = datetime.now().isoformat()
@@ -48,11 +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])}")
+        print(f"[SSE] 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}")
+            print(f"[SSE] Found {len(self._queues[session_id])} subscribers for {session_id}")
             dead_queues = []
             for queue in self._queues[session_id]:
                 try: