compile subGraph execute #4593

PlanDoSome · 2026-05-06T07:29:18Z

PlanDoSome
May 6, 2026

@Autowired
    public GraphHumanController(@Qualifier("humanGraph") StateGraph stateGraph) throws GraphStateException {
        CompiledGraph subgraph = stateGraph
                .compile();
        KeyStrategyFactory keyStrategyFactory = KeyStrategy.builder()
                .addStrategy("plan_steps", KeyStrategy.REPLACE)
                .addStrategy("cur_step", KeyStrategy.REPLACE)
                .addPatternStrategy("query", new ReplaceStrategy())
                .addPatternStrategy("thread_id", new ReplaceStrategy())
                .addPatternStrategy("expander_number", new ReplaceStrategy())
                .addPatternStrategy("expander_content", new ReplaceStrategy())
                .addPatternStrategy("feed_back", new ReplaceStrategy())
                .addPatternStrategy("human_next_node", new ReplaceStrategy())
                .addPatternStrategy("translate_language", new ReplaceStrategy())
                .addPatternStrategy("translate_content", new ReplaceStrategy())
                .build();
        StateGraph graph = new StateGraph("plan-execute-agent", keyStrategyFactory);
        graph.addNode("plan", node_async(state -> {
            return Map.of("query", "中国的实力逐渐强大");
        })).addNode("subgraph", subgraph)  // 直接使用编译的子图
                .addEdge(StateGraph.START, "plan")
                .addEdge("plan","subgraph")
                .addEdge("subgraph",StateGraph.END);

        this.compiledGraph =  graph.compile();
    }

使用编译子图执行，在humannode 示例代码上改造，但是执行结果结束后会报错
error:
2026-05-06T15:26:15.086+08:00 ERROR 26196 --- [human-node] [oundedElastic-2] c.a.c.a.g.c.GraphProcess.GraphProcess : Error occurred during streaming

java.lang.ClassCastException: class org.springframework.ai.chat.messages.AssistantMessage cannot be cast to class java.util.List (org.springframework.ai.chat.messages.AssistantMessage is in unnamed module of loader 'app'; java.util.List is in module java.base of loader 'bootstrap')
at com.alibaba.cloud.ai.graph.executor.NodeExecutor.lambda$transformFluxToGraphResponse$7(NodeExecutor.java:330) ~[spring-ai-alibaba-graph-core-1.1.2.2.jar:1.1.2.2]
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.FluxDefer] :
reactor.core.publisher.Flux.defer(Flux.java:810)
com.alibaba.cloud.ai.graph.executor.NodeExecutor.transformFluxToGraphResponse(NodeExecutor.java:317)
Error has been observed at the following site(s):
*_________________________________________________Flux.defer ⇢ at com.alibaba.cloud.ai.graph.executor.NodeExecutor.transformFluxToGraphResponse(NodeExecutor.java:317)
*__________________________________________Flux.concatWith ⇢ at com.alibaba.cloud.ai.graph.executor.NodeExecutor.transformFluxToGraphResponse(NodeExecutor.java:317)
| Flux.map ⇢ at com.alibaba.cloud.ai.graph.executor.NodeExecutor.processGraphResponseFlux(NodeExecutor.java:433)
| Flux.filter ⇢ at com.alibaba.cloud.ai.graph.executor.NodeExecutor.processGraphResponseFlux(NodeExecutor.java:446)
*____________________________________________Flux.concatWith ⇢ at com.alibaba.cloud.ai.graph.executor.NodeExecutor.processGraphResponseFlux(NodeExecutor.java:507)
*___________________________________________Mono.flatMapMany ⇢ at com.alibaba.cloud.ai.graph.executor.NodeExecutor.executeNode(NodeExecutor.java:127)
*__________________________________________Mono.fromFuture ⇢ at com.alibaba.cloud.ai.graph.CompiledGraph.lambda$streamFromInitialNode$28(CompiledGraph.java:591)
| Mono.onErrorMap ⇢ at com.alibaba.cloud.ai.graph.CompiledGraph.lambda$streamFromInitialNode$28(CompiledGraph.java:591)
| Mono.flux ⇢ at com.alibaba.cloud.ai.graph.CompiledGraph.lambda$streamFromInitialNode$28(CompiledGraph.java:591)
*__MonoCompletionStage$MonoCompletionStageSubscription.apply ⇢ at java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:934)
*_____________________________________________Flux.flatMap ⇢ at com.alibaba.cloud.ai.graph.CompiledGraph.streamFromInitialNode(CompiledGraph.java:582)
| Flux.doOnNext ⇢ at com.alibaba.cloud.ai.graph.controller.GraphProcess.GraphProcess.processStream(GraphProcess.java:46)
| Flux.doOnComplete ⇢ at com.alibaba.cloud.ai.graph.controller.GraphProcess.GraphProcess.processStream(GraphProcess.java:61)
Original Stack Trace:
at com.alibaba.cloud.ai.graph.executor.NodeExecutor.lambda$transformFluxToGraphResponse$7(NodeExecutor.java:330) ~[spring-ai-alibaba-graph-core-1.1.2.2.jar:1.1.2.2]
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:46) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.Flux.subscribe(Flux.java:8891) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:238) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2230) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:152) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:85) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onComplete(FluxFilterFuseable.java:171) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:209) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2230) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onComplete(MonoFlatMapMany.java:261) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:209) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:209) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2230) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onComplete(MonoFlatMapMany.java:261) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:209) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2230) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onComplete(MonoFlatMapMany.java:261) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:209) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onComplete(FluxFilterFuseable.java:171) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onComplete(FluxMapFuseable.java:350) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:209) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2230) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:152) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:85) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onComplete(FluxFilterFuseable.java:171) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxHandleFuseable$HandleFuseableConditionalSubscriber.onComplete(FluxHandleFuseable.java:605) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onComplete(FluxMapFuseable.java:350) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxHandleFuseable$HandleFuseableConditionalSubscriber.onComplete(FluxHandleFuseable.java:605) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:128) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onComplete(FluxMapFuseable.java:350) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxHandleFuseable$HandleFuseableConditionalSubscriber.onComplete(FluxHandleFuseable.java:605) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:128) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onComplete(FluxPeekFuseable.java:595) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPublishOn$PublishOnConditionalSubscriber.doComplete(FluxPublishOn.java:1106) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPublishOn$PublishOnConditionalSubscriber.checkTerminated(FluxPublishOn.java:1140) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPublishOn$PublishOnConditionalSubscriber.runAsync(FluxPublishOn.java:996) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.publisher.FluxPublishOn$PublishOnConditionalSubscriber.run(FluxPublishOn.java:1079) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84) ~[reactor-core-3.7.12.jar:3.7.12]
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37) ~[reactor-core-3.7.12.jar:3.7.12]
at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:317) ~[na:na]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java) ~[na:na]
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[na:na]
at java.base/java.lang.Thread.run(Thread.java:1583) ~[na:na]

PlanDoSome · 2026-05-06T07:34:25Z

PlanDoSome
May 6, 2026
Author

直接调用这个接口http://localhost:8080/graph/human/expand
看控制台即可

0 replies

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

compile subGraph execute #4593

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{editor}}'s edit

{{editor}}'s edit

Uh oh!

Replies: 1 comment

Uh oh!

{{title}}

Uh oh!

Select a reply

Uh oh!

Uh oh!

compile subGraph execute #4593

Uh oh!

Uh oh!

PlanDoSome May 6, 2026

Replies: 1 comment

Uh oh!

PlanDoSome May 6, 2026 Author

PlanDoSome
May 6, 2026

PlanDoSome
May 6, 2026
Author