diff --git a/src/main/java/com/alibaba/cloud/ai/example/deepresearch/config/DeepResearchConfiguration.java b/src/main/java/com/alibaba/cloud/ai/example/deepresearch/config/DeepResearchConfiguration.java index 1c28272..b71e7fa 100644 --- a/src/main/java/com/alibaba/cloud/ai/example/deepresearch/config/DeepResearchConfiguration.java +++ b/src/main/java/com/alibaba/cloud/ai/example/deepresearch/config/DeepResearchConfiguration.java @@ -260,7 +260,7 @@ public StateGraph deepResearch(ChatClient researchAgent) throws GraphStateExcept Map.of("planner", "planner", "research_team", "research_team", END, END)) .addConditionalEdges("research_team", edge_async(new ResearchTeamDispatcher()), Map.of("professional_kb_decision", "professional_kb_decision", "parallel_executor", - "parallel_executor", END, END)) + "parallel_executor", "planner", "planner", END, END)) .addConditionalEdges("professional_kb_decision", edge_async(new ProfessionalKbDispatcher()), Map.of("professional_kb_rag", "professional_kb_rag", "reporter", "reporter", END, END)) .addEdge("professional_kb_rag", "reporter") diff --git a/src/main/java/com/alibaba/cloud/ai/example/deepresearch/node/ResearchTeamNode.java b/src/main/java/com/alibaba/cloud/ai/example/deepresearch/node/ResearchTeamNode.java index 577d7db..78cff07 100644 --- a/src/main/java/com/alibaba/cloud/ai/example/deepresearch/node/ResearchTeamNode.java +++ b/src/main/java/com/alibaba/cloud/ai/example/deepresearch/node/ResearchTeamNode.java @@ -54,7 +54,7 @@ public Map apply(OverAllState state) throws Exception { public boolean areAllExecutionResultsPresent(Plan plan) { if (CollectionUtils.isEmpty(plan.getSteps())) { - return false; + return true; } return plan.getSteps()