code: def milvus_insert_pipe(config):
      return (
          pipe.input("row")
          .map(
              "row",
              "mr",
              ops.ann_insert.milvus_client(
                  host=config.host,
                  port=config.port,
                  collection_name=config.collection_name,
                  user=config.user,
                  password=config.password,
              ),
          )
          .output("mr")
      )
  
imports: from typing import Optional
  from pydantic import BaseModel
  from towhee import ops, pipe, AutoPipes, AutoConfig
label_desc: Use image node_id 1 for calling a global function with example usage: milvus_insert_pipe(config) and returns: pipe