fix(agent): use Runner.run_streamed() when running the agents (#1257)

Author: constantinius

agent/app/agents/manager_agent.py

@@ -87,8 +87,12 @@ async def process_user_request(light: str, maintenance: str) -> str:
     # Create a message with user preferences
     message = f"I want to buy plants for {light} light and {maintenance} maintenance."
 
-    # Run the agent to get recommendations
-    result = await Runner.run(manager_agent, message)
+    # Run the agent with streaming to get recommendations
+    result = Runner.run_streamed(manager_agent, message)
+
+    # Consume the stream
+    async for _ in result.stream_events():
+        pass
 
     logging.debug(f"manager_agent completed purchase: {result.final_output}")
     print(result)

agent/app/agents/plant_expert_agent.py

@@ -53,8 +53,12 @@ async def get_recommendations(light: str, maintenance: str) -> str:
     # Create a message with user preferences
     msg = f"Reccomend plants for {light} light and {maintenance} maintenance."
 
-    # Run the agent
-    result = await Runner.run(plant_expert_agent, msg)
+    # Run the agent with streaming
+    result = Runner.run_streamed(plant_expert_agent, msg)
+
+    # Consume the stream
+    async for _ in result.stream_events():
+        pass
 
     logging.debug(f"PlantExpertAgent provided recommendations: {result.final_output}")
     return str(result.final_output)