From f552b543f63643d5696e082a521d148c515e5977 Mon Sep 17 00:00:00 2001 From: jyong <718720800@qq.com> Date: Wed, 17 Dec 2025 19:08:36 +0800 Subject: [PATCH] add qdrant to tidb --- api/core/rag/datasource/vdb/vector_factory.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/api/core/rag/datasource/vdb/vector_factory.py b/api/core/rag/datasource/vdb/vector_factory.py index 9ad0c45687..9c66fd1e5f 100644 --- a/api/core/rag/datasource/vdb/vector_factory.py +++ b/api/core/rag/datasource/vdb/vector_factory.py @@ -331,7 +331,7 @@ class Vector: collection_exist_cache_key = f"vector_indexing_{self._vector_processor.collection_name}" redis_client.delete(collection_exist_cache_key) - def _get_embeddings(self) -> Embeddings: + def _get_embeddings(self) -> Embeddings | None: model_manager = ModelManager() try: embedding_model = model_manager.get_model_instance( @@ -342,7 +342,6 @@ class Vector: ) return CacheEmbedding(embedding_model) except Exception as e: - logger.exception("Error getting embeddings: %s", e) # return default embeddings try: default_embeddings = model_manager.get_default_model_instance( @@ -351,8 +350,8 @@ class Vector: ) return CacheEmbedding(default_embeddings) except Exception as e: - logger.exception("Error getting default embeddings: %s", e) - raise e + logger.info("Error getting default embeddings: %s", e) + return None def _filter_duplicate_texts(self, texts: list[Document]) -> list[Document]: for text in texts.copy():