- Remove redundant collection listing check
This commit is contained in:
parent
fc8ca1a706
commit
0b2c3d06c7
2 changed files with 1 additions and 12 deletions
|
|
@ -589,18 +589,6 @@ class MilvusVectorDBStorage(BaseVectorStorage):
|
|||
"""Create collection if not exists and check existing collection compatibility"""
|
||||
|
||||
try:
|
||||
# First, list all collections to see what actually exists
|
||||
try:
|
||||
all_collections = self._client.list_collections()
|
||||
logger.debug(
|
||||
f"[{self.workspace}] All collections in database: {all_collections}"
|
||||
)
|
||||
except Exception as list_error:
|
||||
logger.warning(
|
||||
f"[{self.workspace}] Could not list collections: {list_error}"
|
||||
)
|
||||
all_collections = []
|
||||
|
||||
# Check if our specific collection exists
|
||||
collection_exists = self._client.has_collection(self.final_namespace)
|
||||
logger.info(
|
||||
|
|
|
|||
|
|
@ -545,6 +545,7 @@ class LightRAG:
|
|||
self.doc_status,
|
||||
):
|
||||
if storage:
|
||||
# logger.debug(f"Initializing storage: {storage}")
|
||||
await storage.initialize()
|
||||
|
||||
self._storages_status = StoragesStatus.INITIALIZED
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue