bulkwriter to skip function output fields

Signed-off-by: Buqian Zheng <[email protected]>

Author: zhengbuqian

pymilvus/bulk_writer/buffer.py

@@ -52,6 +52,8 @@ def __init__(
         for field in schema.fields:
             if field.is_primary and field.auto_id:
                 continue
+            if field.is_function_output:
+                continue
             self._buffer[field.name] = []
             self._fields[field.name] = field
 

pymilvus/bulk_writer/bulk_writer.py

@@ -194,6 +194,11 @@ def _verify_row(self, row: dict):
                     )
                 else:
                     continue
+            if field.is_function_output:
+                if field.name in row:
+                    self._throw(f"Field '{field.name}' is function output, no need to provide")
+                else:
+                    continue
 
             if field.name not in row:
                 self._throw(f"The field '{field.name}' is missed in the row")