Update app.py

app.py

@@ -299,18 +299,37 @@ def chatbot_response_streaming(message: str, history: List, session_id: str, fil
                             "status": event.get("status", "running"),
                             "executor": event.get("executor", "unknown")
                         }
+                        
+                        # Add observation if available (tool output)
+                        if "observation" in event:
+                            step_info["observation"] = event.get("observation")
+                        
+                        # Add tool input if available
+                        if "input" in event:
+                            step_info["input"] = event.get("input")
+                        
                         steps_completed.append(step_info)
                         executor_used = event.get("executor", executor_used)
                         
+                        # Create more informative status message
+                        status_message = f"📍 Step {event.get('step', 0)}: {event.get('tool', 'processing')}"
+                        if event.get('status') == 'completed' and 'observation' in event:
+                            obs_preview = str(event.get('observation'))[:100]
+                            status_message += f" ✅\n   Output: {obs_preview}..."
+                        elif event.get('status') == 'executing':
+                            status_message += " ⏳"
+                        
                         progress_status = {
                             "status": "executing",
-                            "message": f"📍 Step {event.get('step', 0)}: {event.get('tool', 'processing')}...",
+                            "message": status_message,
                             "pipeline": plan.get("pipeline_name", ""),
                             "executor": executor_used,
+                            "current_step": step_info,
                             "steps_completed": steps_completed
                         }
                         accumulated_response = f"```json\n{json.dumps(progress_status, indent=2)}\n```"
                         yield format_chat_history(history, message, accumulated_response)
+
                     
                     # Final result
                     elif event_type == "final":