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 785c5f97 [fix][plan] Fix parsing exception in ChatModelAction (#634)
add 29305662 [api][integrations] Refactor vector store API
add b20b2960 [integrations] Add support for Mem0 vector stores.
add 3951823c [api][runtime] Support Mem0-based long-term memory
No new revisions were added by this update.
Summary of changes:
.../PythonCollectionManageableVectorStore.java | 19 +-
.../api/vectorstores/python/PythonVectorStore.java | 2 +-
.../PythonCollectionManageableVectorStoreTest.java | 49 +-
.../test/VectorStoreCrossLanguageAgent.java | 26 +-
python/flink_agents/api/memory/long_term_memory.py | 232 ++++-----
.../api/memory/tests/test_long_term_memory.py | 38 --
.../flink_agents/api/vector_stores/vector_store.py | 229 +++++++--
.../e2e_tests_integration/long_term_memory_test.py | 131 ++---
.../vector_store_cross_language_agent.py | 14 +-
.../resources/long_term_memory_test/input.txt | 4 +
.../vector_stores}/__init__.py | 0
.../vector_stores/chroma/chroma_vector_store.py | 425 ++++++++--------
.../chroma/tests/test_chroma_vector_store.py | 239 ++++++++-
.../vector_stores/mem0}/__init__.py | 0
.../vector_stores/mem0/mem0_vector_store.py | 217 +++++++++
.../vector_stores/mem0}/tests/__init__.py | 0
.../mem0/tests/test_mem0_vector_store.py | 310 ++++++++++++
python/flink_agents/plan/tests/test_agent_plan.py | 15 +-
.../flink_agents/runtime/flink_runner_context.py | 47 +-
.../flink_agents/runtime/java/java_vector_store.py | 68 ++-
.../runtime/memory/compaction_functions.py | 191 --------
.../runtime/memory/mem0}/__init__.py | 0
.../memory/mem0/flink_agents_mem0_adapters.py | 430 +++++++++++++++++
.../runtime/memory/mem0/mem0_long_term_memory.py | 462 ++++++++++++++++++
.../runtime/memory/mem0}/tests/__init__.py | 0
.../mem0/tests/test_mem0_long_term_memory.py | 537 +++++++++++++++++++++
.../tests/test_vector_store_long_term_memory.py | 263 ----------
.../memory/vector_store_long_term_memory.py | 328 -------------
python/flink_agents/runtime/python_java_utils.py | 9 -
python/pyproject.toml | 1 +
30 files changed, 2853 insertions(+), 1433 deletions(-)
delete mode 100644
python/flink_agents/api/memory/tests/test_long_term_memory.py
create mode 100644
python/flink_agents/e2e_tests/resources/long_term_memory_test/input.txt
rename python/flink_agents/{api/memory/tests =>
integrations/vector_stores}/__init__.py (100%)
rename python/flink_agents/{runtime/memory/tests =>
integrations/vector_stores/mem0}/__init__.py (100%)
create mode 100644
python/flink_agents/integrations/vector_stores/mem0/mem0_vector_store.py
copy python/{_build_backend =>
flink_agents/integrations/vector_stores/mem0}/tests/__init__.py (100%)
create mode 100644
python/flink_agents/integrations/vector_stores/mem0/tests/test_mem0_vector_store.py
delete mode 100644 python/flink_agents/runtime/memory/compaction_functions.py
copy python/{_build_backend/tests =>
flink_agents/runtime/memory/mem0}/__init__.py (100%)
create mode 100644
python/flink_agents/runtime/memory/mem0/flink_agents_mem0_adapters.py
create mode 100644
python/flink_agents/runtime/memory/mem0/mem0_long_term_memory.py
copy python/{_build_backend =>
flink_agents/runtime/memory/mem0}/tests/__init__.py (100%)
create mode 100644
python/flink_agents/runtime/memory/mem0/tests/test_mem0_long_term_memory.py
delete mode 100644
python/flink_agents/runtime/memory/tests/test_vector_store_long_term_memory.py
delete mode 100644
python/flink_agents/runtime/memory/vector_store_long_term_memory.py
