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 989a92e3 [hotfix] Make Ollama embedding test actually run in CI (#686)
new 4e4689fc [api][plan][runtime] Cross-language Function descriptors and
FunctionTool
new cc4362df [api][java] Introduce YAML API for declaring agents
The 2 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:
api/pom.xml | 4 +
.../org/apache/flink/agents/api/AgentBuilder.java | 15 +
.../agents/api/AgentsExecutionEnvironment.java | 37 ++
.../org/apache/flink/agents/api/agents/Agent.java | 34 +-
.../apache/flink/agents/api/function/Function.java | 16 +-
.../flink/agents/api/function/JavaFunction.java | 113 ++++++
.../flink/agents/api/function/PythonFunction.java | 76 ++++
.../api/resource/python/PythonResourceAdapter.java | 32 ++
.../flink/agents/api/tools/FunctionTool.java | 29 +-
.../org/apache/flink/agents/api/tools/Tool.java | 13 +-
.../org/apache/flink/agents/api/yaml/Aliases.java | 185 +++++++++
.../{tools/ToolType.java => yaml/Language.java} | 44 +--
.../apache/flink/agents/api/yaml/YamlLoader.java | 416 +++++++++++++++++++++
.../flink/agents/api/yaml/spec/ActionSpec.java | 74 ++++
.../flink/agents/api/yaml/spec/AgentActionRef.java | 73 ++++
.../flink/agents/api/yaml/spec/AgentSpec.java | 124 ++++++
.../flink/agents/api/yaml/spec/DescriptorSpec.java | 72 ++++
.../spec/PromptMessage.java} | 40 +-
.../flink/agents/api/yaml/spec/PromptSpec.java | 61 +++
.../spec/SkillsSpec.java} | 39 +-
.../flink/agents/api/yaml/spec/ToolSpec.java | 63 ++++
.../agents/api/yaml/spec/YamlAgentsDocument.java | 117 ++++++
.../agents/api/AgentBuilderApplyByNameTest.java | 112 ++++++
.../agents/api/agents/AgentAddActionTest.java | 79 ++++
.../FunctionTest.java} | 22 +-
.../agents/api/function/JavaFunctionTest.java | 78 ++++
.../agents/api/function/PythonFunctionTest.java | 51 +++
.../flink/agents/api/tools/FunctionToolTest.java | 61 +++
.../apache/flink/agents/api/yaml/AliasesTest.java | 77 ++++
.../apache/flink/agents/api/yaml/LanguageTest.java | 50 +++
.../flink/agents/api/yaml/LoaderTargets.java} | 21 +-
.../agents/api/yaml/YamlLoaderBuildAgentsTest.java | 154 ++++++++
.../agents/api/yaml/YamlLoaderBuildersTest.java | 147 ++++++++
.../agents/api/yaml/YamlLoaderFunctionTest.java | 81 ++++
.../agents/api/yaml/YamlLoaderLoadYamlTest.java | 145 +++++++
.../api/yaml/YamlPythonFixtureParityTest.java | 75 ++++
.../flink/agents/api/yaml/spec/ActionSpecTest.java | 71 ++++
.../flink/agents/api/yaml/spec/AgentSpecTest.java | 67 ++++
.../agents/api/yaml/spec/DescriptorSpecTest.java | 67 ++++
.../flink/agents/api/yaml/spec/PromptSpecTest.java | 88 +++++
.../agents/api/yaml/spec/SchemaParityTest.java | 249 ++++++++++++
.../spec/SkillsSpecTest.java} | 27 +-
.../flink/agents/api/yaml/spec/ToolSpecTest.java | 59 +++
.../api/yaml/spec/YamlAgentsDocumentTest.java | 49 +++
.../test/resources/yaml/fixtures/dup_agent.yaml | 13 +
.../test/resources/yaml/fixtures/multi_agent.yaml | 13 +
.../resources/yaml}/fixtures/multi_file_a.yaml | 4 +-
.../resources/yaml}/fixtures/multi_file_b.yaml | 4 +-
.../test/resources/yaml/fixtures/single_agent.yaml | 7 +
.../resources/yaml}/fixtures/with_descriptors.yaml | 7 +-
.../test/resources/yaml}/fixtures/with_shared.yaml | 9 +-
.../test/resources/yaml}/fixtures/with_skills.yaml | 0
.../yaml}/fixtures/with_tools_and_prompts.yaml | 4 +-
.../yaml/python-parity}/yaml_test_agent.yaml | 0
.../integration/test/yaml/YamlChatActions.java | 149 ++++++++
.../test/yaml/YamlLoaderIntegrationTest.java | 188 ++++++++++
.../src/test/resources/yaml}/yaml_multi_agent.yaml | 26 +-
.../src/test/resources/yaml}/yaml_test_agent.yaml | 19 +-
.../resource/test/YamlCrossLanguageActions.java | 66 ++++
...anguageTest.java => YamlCrossLanguageTest.java} | 70 ++--
.../resources/yaml/yaml_cross_language_agent.yaml | 56 +++
.../org/apache/flink/agents/plan/AgentPlan.java | 157 +++++++-
.../flink/agents/plan/tools/FunctionTool.java | 101 +++--
.../tools/FunctionToolSetPythonAdapterTest.java | 84 +++++
python/flink_agents/api/tools/utils.py | 9 +-
.../yaml_cross_language_actions.py | 16 +
python/flink_agents/runtime/python_java_utils.py | 43 +++
.../apache/flink/agents/runtime/ResourceCache.java | 6 +
.../runtime/env/RemoteExecutionEnvironment.java | 26 +-
.../python/utils/PythonResourceAdapterImpl.java | 23 ++
.../flink/agents/runtime/ResourceCacheTest.java | 10 +
71 files changed, 4391 insertions(+), 226 deletions(-)
copy
runtime/src/main/java/org/apache/flink/agents/runtime/feedback/FeedbackConsumer.java
=> api/src/main/java/org/apache/flink/agents/api/function/Function.java (63%)
create mode 100644
api/src/main/java/org/apache/flink/agents/api/function/JavaFunction.java
create mode 100644
api/src/main/java/org/apache/flink/agents/api/function/PythonFunction.java
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/Aliases.java
copy api/src/main/java/org/apache/flink/agents/api/{tools/ToolType.java =>
yaml/Language.java} (53%)
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/YamlLoader.java
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/spec/ActionSpec.java
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/spec/AgentActionRef.java
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/spec/AgentSpec.java
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/spec/DescriptorSpec.java
copy api/src/main/java/org/apache/flink/agents/api/{EventContext.java =>
yaml/spec/PromptMessage.java} (53%)
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/spec/PromptSpec.java
copy api/src/main/java/org/apache/flink/agents/api/{EventContext.java =>
yaml/spec/SkillsSpec.java} (53%)
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/spec/ToolSpec.java
create mode 100644
api/src/main/java/org/apache/flink/agents/api/yaml/spec/YamlAgentsDocument.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/AgentBuilderApplyByNameTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/agents/AgentAddActionTest.java
copy api/src/test/java/org/apache/flink/agents/api/{memory/MemorySetTest.java
=> function/FunctionTest.java} (61%)
create mode 100644
api/src/test/java/org/apache/flink/agents/api/function/JavaFunctionTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/function/PythonFunctionTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/tools/FunctionToolTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/AliasesTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/LanguageTest.java
copy
api/src/{main/java/org/apache/flink/agents/api/logger/EventLoggerOpenParams.java
=> test/java/org/apache/flink/agents/api/yaml/LoaderTargets.java} (61%)
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/YamlLoaderBuildAgentsTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/YamlLoaderBuildersTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/YamlLoaderFunctionTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/YamlLoaderLoadYamlTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/YamlPythonFixtureParityTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/spec/ActionSpecTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/spec/AgentSpecTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/spec/DescriptorSpecTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/spec/PromptSpecTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/spec/SchemaParityTest.java
copy api/src/test/java/org/apache/flink/agents/api/{memory/MemorySetTest.java
=> yaml/spec/SkillsSpecTest.java} (53%)
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/spec/ToolSpecTest.java
create mode 100644
api/src/test/java/org/apache/flink/agents/api/yaml/spec/YamlAgentsDocumentTest.java
create mode 100644 api/src/test/resources/yaml/fixtures/dup_agent.yaml
create mode 100644 api/src/test/resources/yaml/fixtures/multi_agent.yaml
copy {python/flink_agents/api/yaml/tests =>
api/src/test/resources/yaml}/fixtures/multi_file_a.yaml (62%)
copy {python/flink_agents/api/yaml/tests =>
api/src/test/resources/yaml}/fixtures/multi_file_b.yaml (62%)
create mode 100644 api/src/test/resources/yaml/fixtures/single_agent.yaml
copy {python/flink_agents/api/yaml/tests =>
api/src/test/resources/yaml}/fixtures/with_descriptors.yaml (58%)
copy {python/flink_agents/api/yaml/tests =>
api/src/test/resources/yaml}/fixtures/with_shared.yaml (56%)
copy {python/flink_agents/api/yaml/tests =>
api/src/test/resources/yaml}/fixtures/with_skills.yaml (100%)
copy {python/flink_agents/api/yaml/tests =>
api/src/test/resources/yaml}/fixtures/with_tools_and_prompts.yaml (63%)
copy {python/flink_agents/e2e_tests/resources =>
api/src/test/resources/yaml/python-parity}/yaml_test_agent.yaml (100%)
create mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/yaml/YamlChatActions.java
create mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/yaml/YamlLoaderIntegrationTest.java
copy {python/flink_agents/e2e_tests/resources =>
e2e-test/flink-agents-end-to-end-tests-integration/src/test/resources/yaml}/yaml_multi_agent.yaml
(55%)
copy {python/flink_agents/e2e_tests/resources =>
e2e-test/flink-agents-end-to-end-tests-integration/src/test/resources/yaml}/yaml_test_agent.yaml
(54%)
create mode 100644
e2e-test/flink-agents-end-to-end-tests-resource-cross-language/src/test/java/org/apache/flink/agents/resource/test/YamlCrossLanguageActions.java
copy
e2e-test/flink-agents-end-to-end-tests-resource-cross-language/src/test/java/org/apache/flink/agents/resource/test/{ChatModelCrossLanguageTest.java
=> YamlCrossLanguageTest.java} (58%)
create mode 100644
e2e-test/flink-agents-end-to-end-tests-resource-cross-language/src/test/resources/yaml/yaml_cross_language_agent.yaml
create mode 100644
plan/src/test/java/org/apache/flink/agents/plan/tools/FunctionToolSetPythonAdapterTest.java
