scriptoriumadmin/ReMe
1
0
Fork 0
mirror of https://github.com/agentscope-ai/ReMe.git synced 2026-10-10 03:30:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 7

refactor(vector_store): replace async_iter_workspace_nodes with async_list_workspace_nodes

Browse source
This commit is contained in:
jinli.yl 2026-01-08 16:39:28 +08:00
parent 59aa253e85
commit cf8ee9f88e
3 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
reme_ai/__init__.py
View file

@ -30,4 +30,4 @@ __all__ = [
"vector_store",
]
__version__ = "0.2.0.6"
__version__ = "0.2.0.7"

2
reme_ai/vector_store/delete_memory_op.py
View file

@ -44,7 +44,7 @@ class DeleteMemoryOp(BaseAsyncOp):
workspace_id: str = self.context.workspace_id
freq_threshold: int = self.context.freq_threshold
utility_threshold: float = self.context.utility_threshold
nodes: Iterable[VectorNode] = self.vector_store.iter_workspace_nodes(workspace_id=workspace_id)
nodes: Iterable[VectorNode] = await self.vector_store.async_list_workspace_nodes(workspace_id=workspace_id)
deleted_memory_ids = []
for node in nodes:

2
reme_ai/vector_store/vector_store_action_op.py
View file

@ -80,7 +80,7 @@ class VectorStoreActionOp(BaseAsyncOp):
def node_to_memory(node: VectorNode) -> dict:
return vector_node_to_memory(node).model_dump()
result = await self.vector_store.async_iter_workspace_nodes(workspace_id=workspace_id)
result = await self.vector_store.async_list_workspace_nodes(workspace_id=workspace_id)
result = [node_to_memory(node) for node in result]
elif action == "load":