This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-agents.git
commit e9927dd61c59c1ca48a42f75d91fb5f742eb7069 Author: WenjinXie <[email protected]> AuthorDate: Fri Jan 9 11:18:41 2026 +0800 [hotfix] Fixes and clean-ups for long-term memory in python. --- python/flink_agents/api/memory/long_term_memory.py | 2 +- python/flink_agents/runtime/memory/compaction_functions.py | 14 ++++++++------ .../memory/tests/test_vector_store_long_term_memory.py | 4 ++-- 3 files changed, 11 insertions(+), 9 deletions(-) diff --git a/python/flink_agents/api/memory/long_term_memory.py b/python/flink_agents/api/memory/long_term_memory.py index 7d61182..da673c8 100644 --- a/python/flink_agents/api/memory/long_term_memory.py +++ b/python/flink_agents/api/memory/long_term_memory.py @@ -81,7 +81,7 @@ class LongTermMemoryOptions: """Config options for ReActAgent.""" BACKEND = ConfigOption( - key="long-term-memory.", + key="long-term-memory.backend", config_type=LongTermMemoryBackend, default=None, ) diff --git a/python/flink_agents/runtime/memory/compaction_functions.py b/python/flink_agents/runtime/memory/compaction_functions.py index e895900..731f5fa 100644 --- a/python/flink_agents/runtime/memory/compaction_functions.py +++ b/python/flink_agents/runtime/memory/compaction_functions.py @@ -101,12 +101,14 @@ def summarize( else: item = summarization - create_time_list = [ - items[index].created_time.start - if items[index].compacted - else items[index].created_time - for index in indices - ] + create_time_list = [] + for index in indices: + if items[index].compacted: + create_time_list.append(items[index].create_time.start) + create_time_list.append(items[index].create_time.end) + else: + create_time_list.append(items[index].create_time) + start = min(create_time_list).isoformat() end = max(create_time_list).isoformat() last_accessed_time = max( diff --git a/python/flink_agents/runtime/memory/tests/test_vector_store_long_term_memory.py b/python/flink_agents/runtime/memory/tests/test_vector_store_long_term_memory.py index 016135e..9eb3c8b 100644 --- a/python/flink_agents/runtime/memory/tests/test_vector_store_long_term_memory.py +++ b/python/flink_agents/runtime/memory/tests/test_vector_store_long_term_memory.py @@ -200,9 +200,9 @@ def test_compact( # noqa:D103 ChatMessage(role=MessageRole.USER, content="What is flink?"), ChatMessage( role=MessageRole.ASSISTANT, - content="Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. Flink has been designed to run in all common cluster environments, perform computations at in-memory speed and at any scale.?", + content="Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. Flink has been designed to run in all common cluster environments, perform computations at in-memory speed and at any scale.", ), - ChatMessage(role=MessageRole.USER, content="What is flink agnets?"), + ChatMessage(role=MessageRole.USER, content="What is flink agents?"), ChatMessage( role=MessageRole.ASSISTANT, content="Apache Flink Agents is a brand-new sub-project from the Apache Flink community, providing an open-source framework for building event-driven streaming agents.",
