enhance: Add schema update time verification to insert and upsert to …

…use cache (#2598) enhance: Add schema update time verification to insert and upsert to use cache issue: milvus-io/milvus#39093 --------- Signed-off-by: Xianhui.Lin <[email protected]>
milvus-io · Jan 24, 2025 · c5a3c18 · c5a3c18
1 parent f5eec1c
commit c5a3c18
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pymilvus/client/grpc_handler.py b/pymilvus/client/grpc_handler.py
@@ -801,10 +801,10 @@ def upsert_rows(
         response = rf.result()
         if response.status.error_code == common_pb2.SchemaMismatch:
             schema = self.update_schema(collection_name, timeout)
-            request = self._prepare_row_insert_request(
+            request = self._prepare_row_upsert_request(
                 collection_name, entities, partition_name, schema, timeout, **kwargs
             )
-            response = self._stub.Insert(request=request, timeout=timeout)
+            response = self._stub.Upsert(request=request, timeout=timeout)
         check_status(response.status)
         m = MutationResult(response)
         ts_utils.update_collection_ts(collection_name, m.timestamp)