Loading packages/3gpp-ai/threegpp_ai/lightrag/shared_storage.py +8 −0 Original line number Diff line number Diff line Loading @@ -267,6 +267,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: data: Dict of {chunk_id: {text, embedding, metadata}} **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. """ logger.debug("Upserting %d items to shared %s", len(data), self.namespace) Loading Loading @@ -310,6 +311,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: ids: List of chunk IDs **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: List of embedding data dicts Loading @@ -333,6 +335,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): query: Query text (will be embedded externally) top_k: Number of results to return filter: Optional filter dict (not used in shared storage) **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: List of (chunk_id, similarity_score) tuples Loading @@ -353,6 +356,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: query: Query string top_k: Number of results **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: List of (chunk_id, score) tuples Loading @@ -364,6 +368,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: id: Chunk identifier **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: Embedding data dict or None Loading @@ -375,6 +380,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: ids: List of chunk IDs **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: Dict of {chunk_id: embedding_vector} Loading @@ -392,6 +398,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: keys: Set of keys to check **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: Set of keys that exist in storage (will be filtered out) Loading Loading @@ -430,6 +437,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: ids: List of chunk IDs to delete **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. """ for chunk_id in ids: if chunk_id in self._data["data"]: Loading Loading
packages/3gpp-ai/threegpp_ai/lightrag/shared_storage.py +8 −0 Original line number Diff line number Diff line Loading @@ -267,6 +267,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: data: Dict of {chunk_id: {text, embedding, metadata}} **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. """ logger.debug("Upserting %d items to shared %s", len(data), self.namespace) Loading Loading @@ -310,6 +311,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: ids: List of chunk IDs **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: List of embedding data dicts Loading @@ -333,6 +335,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): query: Query text (will be embedded externally) top_k: Number of results to return filter: Optional filter dict (not used in shared storage) **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: List of (chunk_id, similarity_score) tuples Loading @@ -353,6 +356,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: query: Query string top_k: Number of results **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: List of (chunk_id, score) tuples Loading @@ -364,6 +368,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: id: Chunk identifier **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: Embedding data dict or None Loading @@ -375,6 +380,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: ids: List of chunk IDs **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: Dict of {chunk_id: embedding_vector} Loading @@ -392,6 +398,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: keys: Set of keys to check **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. Returns: Set of keys that exist in storage (will be filtered out) Loading Loading @@ -430,6 +437,7 @@ class SharedNanoVectorDBStorage(BaseVectorStorage): Args: ids: List of chunk IDs to delete **kwargs: Additional keyword arguments for compatibility with LightRAG storage interface. """ for chunk_id in ids: if chunk_id in self._data["data"]: Loading