mirror of
https://gitee.com/wanwujie/deer-flow
synced 2026-04-18 12:04:45 +08:00
fix: fix multi-round issue
This commit is contained in:
@@ -199,6 +199,7 @@ def _execute_agent_step(
|
||||
) -> Command[Literal["research_team"]]:
|
||||
"""Helper function to execute a step using the specified agent."""
|
||||
current_plan = state.get("current_plan")
|
||||
observations = state.get("observations", [])
|
||||
|
||||
# Find the first unexecuted step
|
||||
for step in current_plan.steps:
|
||||
@@ -244,7 +245,7 @@ def _execute_agent_step(
|
||||
name=agent_name,
|
||||
)
|
||||
],
|
||||
"observations": [response_content],
|
||||
"observations": observations + [response_content],
|
||||
},
|
||||
goto="research_team",
|
||||
)
|
||||
|
||||
@@ -14,7 +14,7 @@ class State(MessagesState):
|
||||
|
||||
# Runtime Variables
|
||||
locale: str = "en-US"
|
||||
observations: Annotated[list[str], operator.add] = []
|
||||
observations: list[str] = []
|
||||
plan_iterations: int = 0
|
||||
current_plan: Plan | str = None
|
||||
final_report: str = ""
|
||||
|
||||
Reference in New Issue
Block a user