Skip to content

Commit fe9dad5

Browse files
committed
feat: add topk for api
1 parent df8199f commit fe9dad5

File tree

3 files changed

+4
-2
lines changed

3 files changed

+4
-2
lines changed

src/memos/api/product_models.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,7 @@ class SearchRequest(BaseRequest):
150150
user_id: str = Field(..., description="User ID")
151151
query: str = Field(..., description="Search query")
152152
mem_cube_id: str | None = Field(None, description="Cube ID to search in")
153+
top_k: int = Field(10, description="Number of results to return")
153154

154155

155156
class SuggestionRequest(BaseRequest):

src/memos/api/routers/product_router.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -194,6 +194,7 @@ async def search_memories(search_req: SearchRequest):
194194
query=search_req.query,
195195
user_id=search_req.user_id,
196196
install_cube_ids=[search_req.mem_cube_id] if search_req.mem_cube_id else None,
197+
top_k=search_req.top_k,
197198
)
198199
return SearchResponse(message="Search completed successfully", data=result)
199200

src/memos/mem_os/product.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -601,7 +601,7 @@ def user_register(
601601
try:
602602
default_mem_cube.dump(mem_cube_name_or_path)
603603
except Exception as e:
604-
print(e)
604+
logger.error(f"Failed to dump default cube: {e}")
605605

606606
# Register the default cube with MOS
607607
self.register_mem_cube(
@@ -972,7 +972,7 @@ def get_subgraph(
972972
return reformat_memory_list
973973

974974
def search(
975-
self, query: str, user_id: str, install_cube_ids: list[str] | None = None, top_k: int = 20
975+
self, query: str, user_id: str, install_cube_ids: list[str] | None = None, top_k: int = 10
976976
):
977977
"""Search memories for a specific user."""
978978
# Validate user access

0 commit comments

Comments
 (0)