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 2a4d808 [integration] Configure the model name uniformly in
ChatModelSetup. (#224)
new 5356574 [hotfix] Move test purpose example to e2e tests package in
python.
new 5bf126d [hotfix] Move test purpose example to e2e test module in java.
new 2332d10 [runtime][python] Fix npe when integrate agent from
datastream to table.
new b23c57f [runtime][java] Auto create StreamTableEnvironment when need.
The 4 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:
.../agents/api/AgentsExecutionEnvironment.java | 35 +++++++++----
{examples => e2e-test/integration-test}/pom.xml | 7 ++-
.../agents/integration/test}/AgentWithOllama.java | 2 +-
.../integration/test}/AgentWithOllamaExample.java | 2 +-
.../integration/test}/AgentWithResource.java | 2 +-
.../test}/AgentWithResourceExample.java | 2 +-
.../agents/integration/test}/DataStreamAgent.java | 4 +-
.../test}/DataStreamIntegrationExample.java | 2 +-
.../test/DataStreamTableIntegrationExample.java | 57 +++++++++-------------
.../integration/test}/MemoryObjectAgent.java | 2 +-
.../integration/test}/MemoryObjectExample.java | 2 +-
.../integration/test}/ReActAgentExample.java | 5 +-
.../agents/integration/test}/SimpleAgent.java | 2 +-
.../flink/agents/integration/test}/TableAgent.java | 2 +-
.../integration/test}/TableIntegrationExample.java | 6 +--
e2e-test/pom.xml | 1 +
python/flink_agents/api/execution_environment.py | 9 ++--
python/flink_agents/{api => e2e_tests}/__init__.py | 0
.../{examples => e2e_tests}/agent_example.py | 0
.../{examples => e2e_tests}/chat_model_example.py | 0
.../{examples => e2e_tests}/common_tools.py | 0
.../from_datastream_to_table.py} | 44 ++++++++++++++---
.../integrate_datastream_with_agent_example.py | 2 +-
.../integrate_table_with_agent_example.py | 6 +--
.../integrate_table_with_react_agent_example.py | 6 +--
.../{examples => e2e_tests}/my_agent.py | 29 +++++++++++
.../{examples => e2e_tests}/react_agent_example.py | 2 +-
.../resources/input_data.txt | 0
.../runtime/local_execution_environment.py | 13 +++--
.../runtime/remote_execution_environment.py | 49 +++++++++++++++----
.../runtime/env/RemoteExecutionEnvironment.java | 41 +++++++++++-----
31 files changed, 225 insertions(+), 109 deletions(-)
copy {examples => e2e-test/integration-test}/pom.xml (93%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/AgentWithOllama.java
(99%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/AgentWithOllamaExample.java
(98%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/AgentWithResource.java
(99%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/AgentWithResourceExample.java
(98%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/DataStreamAgent.java
(96%)
copy {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/DataStreamIntegrationExample.java
(98%)
rename
examples/src/main/java/org/apache/flink/agents/examples/DataStreamIntegrationExample.java
=>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test/DataStreamTableIntegrationExample.java
(62%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/MemoryObjectAgent.java
(98%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/MemoryObjectExample.java
(97%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/ReActAgentExample.java
(98%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/SimpleAgent.java
(98%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/TableAgent.java
(98%)
rename {examples/src/main/java/org/apache/flink/agents/examples =>
e2e-test/integration-test/src/main/java/org/apache/flink/agents/integration/test}/TableIntegrationExample.java
(96%)
copy python/flink_agents/{api => e2e_tests}/__init__.py (100%)
rename python/flink_agents/{examples => e2e_tests}/agent_example.py (100%)
rename python/flink_agents/{examples => e2e_tests}/chat_model_example.py (100%)
rename python/flink_agents/{examples => e2e_tests}/common_tools.py (100%)
copy python/flink_agents/{examples/integrate_datastream_with_agent_example.py
=> e2e_tests/from_datastream_to_table.py} (69%)
rename python/flink_agents/{examples =>
e2e_tests}/integrate_datastream_with_agent_example.py (97%)
rename python/flink_agents/{examples =>
e2e_tests}/integrate_table_with_agent_example.py (95%)
rename python/flink_agents/{examples =>
e2e_tests}/integrate_table_with_react_agent_example.py (96%)
rename python/flink_agents/{examples => e2e_tests}/my_agent.py (83%)
rename python/flink_agents/{examples => e2e_tests}/react_agent_example.py (97%)
rename python/flink_agents/{examples => e2e_tests}/resources/input_data.txt
(100%)
