da-daken opened a new pull request, #926: URL: https://github.com/apache/flink-agents/pull/926
<!-- * Thank you very much for contributing to Flink Agents. * Please add the relevant components in the PR title. E.g., [api], [runtime], [java], [python], [hotfix], etc. --> <!-- Please link the PR to the relevant issue(s). Hotfix doesn't need this. --> Linked issue: https://github.com/apache/flink-agents/issues/925 ### Purpose of change Add parallel execution capability for tool calls via a new public API (`RunnerContext.durableExecuteAllAsync()`), which submits a batch of tool calls concurrently to an async thread pool and returns results in the original order after all complete. The execution is durable: the state of in-flight calls is persisted, so that upon recovery (e.g., from checkpoint) the system correctly restores and completes the pending calls, ensuring no duplicate or lost invocations. ### Tests - Unit tests to verify the ordering and consistency of parallel execution results. - Integration tests to validate correctness under concurrent scenarios. - Fault-tolerance tests to ensure that after a simulated failure and recovery, the state of parallel executions is correctly restored and all results are eventually returned exactly once. ### API - Introduce a new public API `RunnerContext.durableExecuteAllAsync()` for batch parallel execution of tool calls. - Expose the parallel execution capability without breaking compatibility with the existing synchronous API. ### Documentation <!-- Do not remove this section. Check the proper box only. --> - [x] `doc-needed` <!-- Your PR changes impact docs --> - [ ] `doc-not-needed` <!-- Your PR changes do not impact docs --> - [ ] `doc-included` <!-- Your PR already contains the necessary documentation updates --> -- 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]
