This is an automated email from the ASF dual-hosted git repository.
wenjin272 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
from 54f8c69a [ci][integrations] Consolidate vector store tests (#1061)
add 0417dad3 [Feature] Parallel Tool Call Execution (#926)
No new revisions were added by this update.
Summary of changes:
.../agents/api/agents/AgentExecutionOptions.java | 47 ++
.../apache/flink/agents/api/context/Outcome.java | 36 +-
.../flink/agents/api/context/RunnerContext.java | 16 +
docs/content/docs/development/tool_use.md | 42 ++
docs/content/docs/operations/configuration.md | 6 +-
.../pom.xml | 34 +
.../integration/test/AsyncExecutionAgent.java | 526 +++++++++++++++
.../integration/test/AsyncExecutionTest.java | 310 +++++++++
.../flink/agents/plan/actions/ToolCallAction.java | 275 ++++++--
.../plan/actions/ChatModelActionRoutingTest.java | 16 +
.../agents/plan/actions/ToolCallActionTest.java | 201 +++++-
python/flink_agents/api/core_options.py | 30 +
python/flink_agents/api/runner_context.py | 51 +-
python/flink_agents/api/tests/test_core_options.py | 13 +
.../flink_agents/plan/actions/tool_call_action.py | 176 ++++-
.../plan/tests/actions/test_tool_call_action.py | 241 ++++++-
.../check_java_python_config_options_parity.py | 5 +-
python/flink_agents/runtime/durable_execution.py | 10 +
.../flink_agents/runtime/flink_runner_context.py | 465 ++++++++++++-
.../test_flink_runner_context_reconcilable.py | 727 ++++++++++++++++++++-
.../agents/runtime/async/BatchExecutionResult.java | 48 ++
.../runtime/async/ContinuationActionExecutor.java | 38 ++
.../runtime/context/JavaRunnerContextImpl.java | 185 ++++++
.../agents/runtime/context/RunnerContextImpl.java | 225 ++++++-
.../runtime/operator/ActionTaskContextManager.java | 2 +-
.../runtime/async/ContinuationActionExecutor.java | 201 +++++-
.../agents/runtime/async/ContinuationContext.java | 40 ++
.../context/DurableExecutionContextTest.java | 135 +++-
...vaRunnerContextImplDurableExecuteAsyncTest.java | 590 +++++++++++++++++
.../RunnerContextImplDurableExecuteTest.java | 58 +-
.../flink/agents/runtime/memory/MemoryRefTest.java | 11 +
31 files changed, 4539 insertions(+), 221 deletions(-)
copy
runtime/src/main/java/org/apache/flink/agents/runtime/memory/MemoryValueObservation.java
=> api/src/main/java/org/apache/flink/agents/api/context/Outcome.java (55%)
create mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/async/BatchExecutionResult.java
