diff --git a/agentuniverse/agent/plan/planner/react_planner/stream_callback.py b/agentuniverse/agent/plan/planner/react_planner/stream_callback.py index e96f9519..e417bb3d 100644 --- a/agentuniverse/agent/plan/planner/react_planner/stream_callback.py +++ b/agentuniverse/agent/plan/planner/react_planner/stream_callback.py @@ -54,7 +54,7 @@ def on_tool_end( """If not the final action, print out observation.""" if observation_prefix is not None: self.queueStream.put_nowait({ - " type": "ReAct", + "type": "ReAct", "data": { "output": '\n' + observation_prefix + output, "agent_info": self.agent_info @@ -62,7 +62,7 @@ def on_tool_end( }) else: self.queueStream.put_nowait({ - " type": "ReAct", + "type": "ReAct", "data": { "output": '\n Observation:' + output, "agent_info": self.agent_info @@ -83,7 +83,7 @@ def on_agent_finish( ) -> None: """Run on agent end.""" self.queueStream.put_nowait({ - " type": "ReAct", + "type": "ReAct", "data": { "output": '\nThought:' + finish.output, "agent_info": self.agent_info