Merge branch 'dev' of github.com:pursues/MemOS into dev

# Conflicts:
#	docker/requirements.txt

Author: pursues

docker/requirements.txt

@@ -1,18 +1,21 @@
 annotated-types==0.7.0
-anyio==4.11.0
-attrs==25.4.0
-Authlib==1.6.5
-beartype==0.22.5
-cachetools==6.2.2
-certifi==2025.11.12
-cffi==2.0.0
-charset-normalizer==3.4.4
-chonkie==1.1.0
-click==8.3.0
+anyio==4.9.0
+async-timeout==5.0.1
+attrs==25.3.0
+authlib==1.6.0
+beautifulsoup4==4.13.4
+certifi==2025.7.14
+cffi==1.17.1
+charset-normalizer==3.4.2
+chonkie==1.1.1
+click==8.2.1
+cobble==0.1.4
+colorama==0.4.6
+coloredlogs==15.0.1
 concurrent-log-handler==0.9.28
-cryptography==46.0.3
-cyclopts==4.2.3
-diskcache==5.6.3
+cryptography==45.0.5
+cyclopts==3.22.2
+defusedxml==0.7.1
 distro==1.9.0
 dnspython==2.8.0
 docstring_parser==0.17.0

poetry.lock

@@ -4,7 +4,7 @@
 ##############################################################################
 
 name = "MemoryOS"
-version = "1.1.3"
+version = "2.0.0"
 description = "Intelligence Begins with Memory"
 license = {text = "Apache-2.0"}
 readme = "README.md"

pyproject.toml

@@ -1,4 +1,4 @@
-__version__ = "1.1.3"
+__version__ = "2.0.0"
 
 from memos.configs.mem_cube import GeneralMemCubeConfig
 from memos.configs.mem_os import MOSConfig

src/memos/__init__.py

@@ -200,7 +200,6 @@ def init_server() -> dict[str, Any]:
     )
 
     logger.debug("Memory manager initialized")
-
     tokenizer = FastTokenizer()
     # Initialize text memory
     text_mem = SimpleTreeTextMemory(

src/memos/api/handlers/component_init.py

@@ -318,7 +318,7 @@ def _vector_recall(
         query_embedding: list[list[float]],
         memory_scope: str,
         top_k: int = 20,
-        max_num: int = 5,
+        max_num: int = 20,
         status: str = "activated",
         cube_name: str | None = None,
         search_filter: dict | None = None,

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

@@ -4,6 +4,7 @@
 from pathlib import Path
 from typing import Any
 
+
 import numpy as np
 
 from memos.dependency import require_python_package

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

@@ -284,6 +284,49 @@ def _parse_task(
 
         return parsed_goal, query_embedding, context, query
 
+    @timed
+    def _retrieve_simple(
+        self,
+        query: str,
+        top_k: int,
+        search_filter: dict | None = None,
+        user_name: str | None = None,
+        **kwargs,
+    ):
+        """Retrieve from by keywords and embedding"""
+        query_words = []
+        if self.tokenizer:
+            query_words = self.tokenizer.tokenize_mixed(query)
+        else:
+            query_words = query.strip().split()
+        query_words = [query, *query_words]
+        logger.info(f"[SIMPLESEARCH] Query words: {query_words}")
+        query_embeddings = self.embedder.embed(query_words)
+
+        items = self.graph_retriever.retrieve_from_mixed(
+            top_k=top_k * 2,
+            memory_scope=None,
+            query_embedding=query_embeddings,
+            search_filter=search_filter,
+            user_name=user_name,
+            use_fast_graph=self.use_fast_graph,
+        )
+        logger.info(f"[SIMPLESEARCH] Items count: {len(items)}")
+        documents = [getattr(item, "memory", "") for item in items]
+        documents_embeddings = self.embedder.embed(documents)
+        similarity_matrix = cosine_similarity_matrix(documents_embeddings)
+        selected_indices, _ = find_best_unrelated_subgroup(documents, similarity_matrix)
+        selected_items = [items[i] for i in selected_indices]
+        logger.info(
+            f"[SIMPLESEARCH] after unrelated subgroup selection items count: {len(selected_items)}"
+        )
+        return self.reranker.rerank(
+            query=query,
+            query_embedding=query_embeddings[0],
+            graph_results=selected_items,
+            top_k=top_k,
+        )
+
     @timed
     def _retrieve_paths(
         self,
@@ -367,7 +410,6 @@ def _retrieve_paths(
                         mode=mode,
                     )
                 )
-
             results = []
             for t in tasks:
                 results.extend(t.result())