Skip to content

Commit b3c9e84

Browse files
fridayLCaralHsi
andauthored
fix: fix context error and empty embedding (#817)
fix: fix context Co-authored-by: CaralHsi <caralhsi@gmail.com>
1 parent 5349674 commit b3c9e84

2 files changed

Lines changed: 5 additions & 2 deletions

File tree

src/memos/memories/textual/tree_text_memory/retrieve/searcher.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -674,6 +674,8 @@ def _retrieve_simple(
674674
)
675675
logger.info(f"[SIMPLESEARCH] Items count: {len(items)}")
676676
documents = [getattr(item, "memory", "") for item in items]
677+
if not documents:
678+
return []
677679
documents_embeddings = self.embedder.embed(documents)
678680
similarity_matrix = cosine_similarity_matrix(documents_embeddings)
679681
selected_indices, _ = find_best_unrelated_subgroup(documents, similarity_matrix)

src/memos/multi_mem_cube/composite_cube.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,10 @@
11
from __future__ import annotations
22

3-
from concurrent.futures import ThreadPoolExecutor, as_completed
3+
from concurrent.futures import as_completed
44
from dataclasses import dataclass
55
from typing import TYPE_CHECKING, Any
66

7+
from memos.context.context import ContextThreadPoolExecutor
78
from memos.multi_mem_cube.views import MemCubeView
89

910

@@ -52,7 +53,7 @@ def _search_single_cube(view: SingleCubeView) -> dict[str, Any]:
5253
return view.search_memories(search_req)
5354

5455
# parallel search for each cube
55-
with ThreadPoolExecutor(max_workers=2) as executor:
56+
with ContextThreadPoolExecutor(max_workers=2) as executor:
5657
future_to_view = {
5758
executor.submit(_search_single_cube, view): view for view in self.cube_views
5859
}

0 commit comments

Comments
 (0)