This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
from 6066182 [Feature][Java] Add MCP support in Java (#356)
new ee3f40f [test] Revise the question and tool description to improve
test stability
new 3bbb5af [api] Move agent api to agents module.
new 8a9ad0f [plan] Use sensory memory for tool call context.
new 51c1502 [plan] Refactor built-in chat action.
new 4012835 [plan] Support error handling strategy for chat action.
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/flink/agents/api/AgentBuilder.java | 1 +
.../flink/agents/api/{ => agents}/Agent.java | 21 +-
...nfigOptions.java => AgentExecutionOptions.java} | 13 +-
.../flink/agents/api/agents/OutputSchema.java | 134 +++++++++
.../apache/flink/agents/api/agents/ReActAgent.java | 170 +----------
.../flink/agents/api/event/ChatRequestEvent.java | 17 +-
.../flink/agents/api/agents/ReActAgentTest.java | 5 +-
.../api/resource/ResourceDescriptorTest.java | 2 +-
.../test/ChatModelIntegrationAgent.java | 6 +-
.../integration/test/ChatModelIntegrationTest.java | 2 +-
.../test/EmbeddingIntegrationAgent.java | 2 +-
.../integration/test/FlinkIntegrationAgent.java | 2 +-
.../agents/integration/test/MemoryObjectAgent.java | 2 +-
.../agents/integration/test/ReActAgentTest.java | 12 +-
.../test/VectorStoreIntegrationAgent.java | 2 +-
.../resource/test/ChatModelCrossLanguageAgent.java | 6 +-
.../resource/test/ChatModelCrossLanguageTest.java | 2 +-
.../examples/agents/ProductSuggestionAgent.java | 2 +-
.../examples/agents/ReviewAnalysisAgent.java | 2 +-
plan/pom.xml | 16 +
.../org/apache/flink/agents/plan/AgentPlan.java | 2 +-
.../flink/agents/plan/actions/ChatModelAction.java | 321 ++++++++++++++-------
.../agents/plan/AgentPlanDeclareChatModelTest.java | 2 +-
.../agents/plan/AgentPlanDeclareMCPServerTest.java | 2 +-
.../agents/plan/AgentPlanDeclareToolFieldTest.java | 2 +-
.../plan/AgentPlanDeclareToolMethodTest.java | 2 +-
.../apache/flink/agents/plan/AgentPlanTest.java | 2 +-
.../flink/agents/plan/FunctionToolPlanTest.java | 2 +-
.../plan/compatibility/GenerateAgentPlanJson.java | 2 +-
.../serializer/AgentPlanJsonSerializerTest.java | 2 +-
python/flink_agents/api/{ => agents}/agent.py | 2 +
python/flink_agents/api/agents/react_agent.py | 121 +-------
python/flink_agents/api/agents/types.py | 67 +++++
python/flink_agents/api/core_options.py | 24 ++
python/flink_agents/api/events/chat_event.py | 4 +
python/flink_agents/api/execution_environment.py | 2 +-
.../chat_model_integration_agent.py | 2 +-
.../e2e_tests_mcp/mcp_test.py | 2 +-
.../flink_integration_agent.py | 2 +-
.../python_event_logging_test.py | 2 +-
.../e2e_tests_integration/react_agent_test.py | 10 +-
.../e2e_tests_integration/workflow_test.py | 2 +-
.../chat_model_cross_language_agent.py | 2 +-
.../e2e_tests/long_term_memory_test.py | 2 +-
.../quickstart/agents/product_suggestion_agent.py | 2 +-
.../quickstart/agents/review_analysis_agent.py | 2 +-
.../flink_agents/examples/rag/rag_agent_example.py | 2 +-
.../flink_agents/plan/actions/chat_model_action.py | 301 +++++++++++++------
python/flink_agents/plan/agent_plan.py | 2 +-
.../python_agent_plan_compatibility_test_agent.py | 2 +-
.../flink_agents/plan/tests/resources/action.json | 2 +-
python/flink_agents/plan/tests/test_agent_plan.py | 2 +-
.../runtime/local_execution_environment.py | 2 +-
python/flink_agents/runtime/local_runner.py | 2 +-
.../runtime/remote_execution_environment.py | 2 +-
.../runtime/tests/test_built_in_actions.py | 2 +-
.../runtime/tests/test_get_resource_in_action.py | 2 +-
.../tests/test_local_execution_environment.py | 2 +-
.../runtime/env/RemoteExecutionEnvironment.java | 2 +-
.../apache/flink/agents/runtime/RescalingTest.java | 2 +-
60 files changed, 814 insertions(+), 519 deletions(-)
rename api/src/main/java/org/apache/flink/agents/api/{ => agents}/Agent.java
(89%)
rename
api/src/main/java/org/apache/flink/agents/api/agents/{ReActAgentConfigOptions.java
=> AgentExecutionOptions.java} (72%)
create mode 100644
api/src/main/java/org/apache/flink/agents/api/agents/OutputSchema.java
rename python/flink_agents/api/{ => agents}/agent.py (99%)
create mode 100644 python/flink_agents/api/agents/types.py
