yunfengzhou-hub commented on code in PR #1114:
URL: https://github.com/apache/flink-agents/pull/1114#discussion_r4026757722
##########
plan/src/main/java/org/apache/flink/agents/plan/actions/ToolCallAction.java:
##########
@@ -197,21 +218,32 @@ private static void executeParallel(
Map<String, Boolean> success,
Map<String, String> error,
Map<String, ToolResponse> responses) {
- List<DurableCallable<ToolResponse>> callables = new
ArrayList<>(executions.size());
+ // Sub-agent calls already run through durable execution inside the
setup, so they stay
+ // synchronous here and only the tool calls enter the durable batch.
+ List<ToolCallExecution> toolExecutions = new ArrayList<>();
for (ToolCallExecution execution : executions) {
+ if (execution.agent != null) {
+ dispatchAgentExecution(execution, ctx, success, error,
responses);
Review Comment:
Thanks for the reminder. This code was developed before the batch tool-call
feature, along with #938, so we missed this feature. I've added support for
parallel tool calls.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
