Skip to content

Commit 091cfc7

Browse files
nv-pranjaldshubhadeepd
authored andcommitted
Remove text field from milvus query for list/delete API
1 parent 1465fdc commit 091cfc7

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

RAG/src/chain_server/utils.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -521,7 +521,7 @@ def get_docs_vectorstore_langchain(vectorstore: VectorStore) -> List[str]:
521521
elif settings.vector_store.name == "milvus":
522522
# Getting all the ID's > 0
523523
if vectorstore.col:
524-
milvus_data = vectorstore.col.query(expr="pk >= 0", output_fields=["pk", "source", "text"])
524+
milvus_data = vectorstore.col.query(expr="pk >= 0", output_fields=["pk", "source"])
525525
filenames = set([extract_filename(metadata) for metadata in milvus_data])
526526
return filenames
527527
except Exception as e:
@@ -586,7 +586,7 @@ def del_docs_vectorstore_langchain(vectorstore: VectorStore, filenames: List[str
586586
logger.info(f"Deleted documents with filenames {filename}")
587587
elif settings.vector_store.name == "milvus":
588588
# Getting all the ID's > 0
589-
milvus_data = vectorstore.col.query(expr="pk >= 0", output_fields=["pk", "source", "text"])
589+
milvus_data = vectorstore.col.query(expr="pk >= 0", output_fields=["pk", "source"])
590590
for filename in filenames:
591591
# get ids with filename in metadata
592592
ids_list = [metadata["pk"] for metadata in milvus_data if extract_filename(metadata) == filename]

0 commit comments

Comments
 (0)