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 824b093 Revert "Introduce sensory memory in python."
new b266735 [test][python] Clean up and refactor python e2e tests.
new d3ac575 [test][java] Clean up and refactor java e2e tests.
new 393b9ec [infra] Run e2e tests in ci.
The 3 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:
.github/workflows/ci.yml | 61 ++++-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../test/ChatModelIntegrationAgent.java} | 62 ++++--
.../test/ChatModelIntegrationTest.java} | 77 +++++--
.../test/EmbeddingIntegrationAgent.java} | 33 ++-
.../test/EmbeddingIntegrationTest.java} | 58 ++++-
.../integration/test/FlinkIntegrationAgent.java | 186 ++++++++++++++++
.../integration/test/FlinkIntegrationTest.java | 204 +++++++++++++++++
.../agents/integration/test/MemoryObjectAgent.java | 0
.../agents/integration/test/MemoryObjectTest.java} | 22 +-
.../integration/test/OllamaPreparationUtils.java | 47 ++++
.../agents/integration/test/ReActAgentTest.java} | 57 +++--
.../test_from_datastream_to_datastream.txt | 6 +
.../ground-truth/test_from_datastream_to_table.txt | 6 +
.../ground-truth/test_from_table_to_table.txt | 6 +
.../src/test/resources/log4j2-test.properties | 10 +-
.../src/test/resources/ollama_pull_model.sh | 5 +-
.../agents/integration/test/AgentWithAzureAI.java | 126 -----------
.../integration/test/AgentWithOllamaExample.java | 65 ------
.../agents/integration/test/AgentWithResource.java | 168 --------------
.../integration/test/AgentWithResourceExample.java | 65 ------
.../agents/integration/test/DataStreamAgent.java | 96 --------
.../test/DataStreamIntegrationExample.java | 102 ---------
.../test/DataStreamTableIntegrationExample.java | 93 --------
.../flink/agents/integration/test/SimpleAgent.java | 82 -------
.../flink/agents/integration/test/TableAgent.java | 98 --------
.../integration/test/TableIntegrationExample.java | 99 ---------
.../src/main/resources/log4j2.properties | 25 ---
e2e-test/pom.xml | 4 +-
..._example.py => chat_model_integration_agent.py} | 120 ++++------
.../e2e_tests/chat_model_integration_test.py | 84 +++++++
.../{mcp_test => e2e_tests_mcp}/__init__.py | 0
.../{mcp_test => e2e_tests_mcp}/mcp_server.py | 1 +
.../mcp_example.py => e2e_tests_mcp/mcp_test.py} | 17 +-
.../{my_agent.py => flink_integration_agent.py} | 9 +
.../e2e_tests/flink_intergration_test.py | 247 +++++++++++++++++++++
.../e2e_tests/from_datastream_to_table.py | 108 ---------
.../integrate_datastream_with_agent_example.py | 81 -------
.../integrate_table_with_agent_example.py | 108 ---------
.../integrate_table_with_react_agent_example.py | 127 -----------
.../flink_agents/e2e_tests/react_agent_example.py | 90 --------
python/flink_agents/e2e_tests/react_agent_test.py | 232 +++++++++++++++++++
.../{common_tools.py => react_agent_tools.py} | 0
.../test_from_datastream_to_datastream.txt | 10 +
.../ground_truth/test_from_table_to_table.txt | 10 +
.../resources/ground_truth/test_workflow.txt | 10 +
.../e2e_tests/resources/{ => input}/input_data.txt | 0
.../e2e_tests/scripts/ollama_pull_model.sh | 4 +-
python/flink_agents/e2e_tests/test_utils.py | 68 ++++++
.../{agent_example.py => workflow_test.py} | 34 ++-
tools/build.sh | 36 +--
tools/e2e.sh | 2 +-
.../__init__.py => tools/start_ollama_server.sh | 11 +
tools/ut.sh | 26 ++-
55 files changed, 1576 insertions(+), 1726 deletions(-)
rename e2e-test/{agent-plan-compatibility-test =>
flink-agents-end-to-end-tests-agent-plan-compatibility}/pom.xml (96%)
rename e2e-test/{integration-test =>
flink-agents-end-to-end-tests-integration}/pom.xml (97%)
rename
e2e-test/{integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllama.java
=>
flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/ChatModelIntegrationAgent.java}
(67%)
rename
e2e-test/{integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithAzureAIExample.java
=>
flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/ChatModelIntegrationTest.java}
(52%)
rename
e2e-test/{integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllamaEmbedding.java
=>
flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/EmbeddingIntegrationAgent.java}
(87%)
rename
e2e-test/{integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllamaEmbeddingExample.java
=>
flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/EmbeddingIntegrationTest.java}
(56%)
create mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/FlinkIntegrationAgent.java
create mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/FlinkIntegrationTest.java
rename e2e-test/{integration-test/src/main =>
flink-agents-end-to-end-tests-integration/src/test}/java/org/apache/flink/agents/integration/test/MemoryObjectAgent.java
(100%)
rename
e2e-test/{integration-test/src/main/java/org/apache/flink/agents/integration/test/MemoryObjectExample.java
=>
flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/MemoryObjectTest.java}
(75%)
create mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/OllamaPreparationUtils.java
rename
e2e-test/{integration-test/src/main/java/org/apache/flink/agents/integration/test/ReActAgentExample.java
=>
flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/ReActAgentTest.java}
(77%)
create mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/resources/ground-truth/test_from_datastream_to_datastream.txt
create mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/resources/ground-truth/test_from_datastream_to_table.txt
create mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/resources/ground-truth/test_from_table_to_table.txt
copy {runtime =>
e2e-test/flink-agents-end-to-end-tests-integration}/src/test/resources/log4j2-test.properties
(77%)
copy .github/ISSUE_TEMPLATE/config.yml =>
e2e-test/flink-agents-end-to-end-tests-integration/src/test/resources/ollama_pull_model.sh
(94%)
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithAzureAI.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithOllamaExample.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithResource.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/AgentWithResourceExample.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamAgent.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamIntegrationExample.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamTableIntegrationExample.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/SimpleAgent.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/TableAgent.java
delete mode 100644
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/TableIntegrationExample.java
delete mode 100644
e2e-test/integration-test/src/main/resources/log4j2.properties
rename python/flink_agents/e2e_tests/{chat_model_example.py =>
chat_model_integration_agent.py} (69%)
create mode 100644 python/flink_agents/e2e_tests/chat_model_integration_test.py
rename python/flink_agents/e2e_tests/{mcp_test => e2e_tests_mcp}/__init__.py
(100%)
rename python/flink_agents/e2e_tests/{mcp_test => e2e_tests_mcp}/mcp_server.py
(99%)
rename python/flink_agents/e2e_tests/{mcp_test/mcp_example.py =>
e2e_tests_mcp/mcp_test.py} (92%)
rename python/flink_agents/e2e_tests/{my_agent.py =>
flink_integration_agent.py} (95%)
create mode 100644 python/flink_agents/e2e_tests/flink_intergration_test.py
delete mode 100644 python/flink_agents/e2e_tests/from_datastream_to_table.py
delete mode 100644
python/flink_agents/e2e_tests/integrate_datastream_with_agent_example.py
delete mode 100644
python/flink_agents/e2e_tests/integrate_table_with_agent_example.py
delete mode 100644
python/flink_agents/e2e_tests/integrate_table_with_react_agent_example.py
delete mode 100644 python/flink_agents/e2e_tests/react_agent_example.py
create mode 100644 python/flink_agents/e2e_tests/react_agent_test.py
rename python/flink_agents/e2e_tests/{common_tools.py => react_agent_tools.py}
(100%)
create mode 100644
python/flink_agents/e2e_tests/resources/ground_truth/test_from_datastream_to_datastream.txt
create mode 100644
python/flink_agents/e2e_tests/resources/ground_truth/test_from_table_to_table.txt
create mode 100644
python/flink_agents/e2e_tests/resources/ground_truth/test_workflow.txt
rename python/flink_agents/e2e_tests/resources/{ => input}/input_data.txt
(100%)
copy .github/ISSUE_TEMPLATE/config.yml =>
python/flink_agents/e2e_tests/scripts/ollama_pull_model.sh (94%)
create mode 100644 python/flink_agents/e2e_tests/test_utils.py
rename python/flink_agents/e2e_tests/{agent_example.py => workflow_test.py}
(79%)
copy python/flink_agents/api/agents/__init__.py =>
tools/start_ollama_server.sh (87%)
