code: def milvus_insert_pipe(config):
      return (
          pipe.input("vec")
          .map(
              "vec",
              "rows",
              ops.ann_search.milvus_client(
                  host=config.host,
                  port=config.port,
                  collection_name=config.collection_name,
                  user=config.user,
                  password=config.password,
                  **config.search_params,
              ),
          )
          .output("rows")
      )
  
imports: from typing import Dict, Optional, Any
  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