diff --git a/unstructured/ingest/v2/processes/connectors/milvus.py b/unstructured/ingest/v2/processes/connectors/milvus.py
index 22feeefe4d..2615563d67 100644
--- a/unstructured/ingest/v2/processes/connectors/milvus.py
+++ b/unstructured/ingest/v2/processes/connectors/milvus.py
@@ -182,7 +182,7 @@ def upload_json(self, content: UploadContent) -> None:
     def run(self, contents: list[UploadContent], **kwargs: Any) -> None:
         if self.upload_config.num_of_processes == 1:
             for content in contents:
-                self.upload_csv(content=content)
+                self.upload(content=content)
 
         else:
             with mp.Pool(