Fix: MilvusClient.insert() does not pass **kwargs to underlying insert_rows() call (#3076)

thangTang · web-flow · commit afff26cbbd46 · 2025-11-18T11:31:35.000+08:00
Fix #3075 Signed-off-by: tianhang.tang <tangtianhang099@gmail.com>
diff --git a/pymilvus/milvus_client/async_milvus_client.py b/pymilvus/milvus_client/async_milvus_client.py
@@ -287,7 +287,7 @@ async def insert(
         conn = self._get_connection()
         # Insert into the collection.
         res = await conn.insert_rows(
-            collection_name, data, partition_name=partition_name, timeout=timeout
+            collection_name, data, partition_name=partition_name, timeout=timeout, **kwargs
         )
         return OmitZeroDict(
             {
diff --git a/pymilvus/milvus_client/milvus_client.py b/pymilvus/milvus_client/milvus_client.py
@@ -221,7 +221,7 @@ def insert(
         # Insert into the collection.
         try:
             res = conn.insert_rows(
-                collection_name, data, partition_name=partition_name, timeout=timeout
+                collection_name, data, partition_name=partition_name, timeout=timeout, **kwargs
             )
         except Exception as ex:
             raise ex from ex

Original file line number	Diff line number	Diff line change
`@@ -287,7 +287,7 @@ async def insert(`
`287`	`287`	`conn = self._get_connection()`
`288`	`288`	`# Insert into the collection.`
`289`	`289`	`res = await conn.insert_rows(`
`290`		`- collection_name, data, partition_name=partition_name, timeout=timeout`
	`290`	`+ collection_name, data, partition_name=partition_name, timeout=timeout, **kwargs`
`291`	`291`	`)`
`292`	`292`	`return OmitZeroDict(`
`293`	`293`	`{`
Original file line number	Diff line number	Diff line change
`@@ -221,7 +221,7 @@ def insert(`
`221`	`221`	`# Insert into the collection.`
`222`	`222`	`try:`
`223`	`223`	`res = conn.insert_rows(`
`224`		`- collection_name, data, partition_name=partition_name, timeout=timeout`
	`224`	`+ collection_name, data, partition_name=partition_name, timeout=timeout, **kwargs`
`225`	`225`	`)`
`226`	`226`	`except Exception as ex:`
`227`	`227`	`raise ex from ex`