Update services/pipeline_executor.py

services/pipeline_executor.py

@@ -174,7 +174,12 @@ Execute each component by calling the corresponding tool."""
         tool_results = {}
         has_called_tools = False
         step_count = 0
-        max_iterations = 1  # Only try once, wait for response
+        
+        # Set max_iterations based on number of components (with buffer for retries)
+        num_components = len(pipeline.get('components', []))
+        max_iterations = max(1, num_components + 2)  # Components + 2 buffer for Final Answer
+        
+        print(f"📋 Pipeline has {num_components} components, max_iterations={max_iterations}")
         
         yield {
             "type": "status",