code: def e2e_milvus(host, c_name):
      """e2e milvus"""
      log.debug(f"pid: {os.getpid()}")
      # connect
      connections.add_connection(default={"host": host, "port": 19530})
      connections.connect(alias="default")
  
      # create
      collection_w = ApiCollectionWrapper()
      collection_w.init_collection(
          name=c_name, schema=cf.gen_default_collection_schema()
      )
  
      # insert
      df = cf.gen_default_dataframe_data()
      mutation_res, _ = collection_w.insert(df)
      assert mutation_res.insert_count == ct.default_nb
      log.debug(collection_w.num_entities)
  
      # create index
      collection_w.create_index(
          ct.default_float_vec_field_name, ct.default_index
      )
      assert collection_w.has_index()[0]
      assert collection_w.index()[0] == Index(
          collection_w.collection,
          ct.default_float_vec_field_name,
          ct.default_index,
      )
  
      # search
      collection_w.load()
      search_res, _ = collection_w.search(
          cf.gen_vectors(1, dim=ct.default_dim),
          ct.default_float_vec_field_name,
          ct.default_search_params,
          ct.default_limit,
      )
      assert len(search_res[0]) == ct.default_limit
      log.debug(search_res[0].ids)
  
      # query
      ids = search_res[0].ids[0]
      term_expr = f"{ct.default_int64_field_name} in [{ids}]"
      query_res, _ = collection_w.query(
          term_expr, output_fields=["*", "%"]
      )
      assert query_res[0][ct.default_int64_field_name] == ids
  
file_path: milvus/tests/python_client/scale/scale_common.py
imports: import os
  from pymilvus import connections, Index, MilvusException
  from utils.util_log import test_log
  from base.collection_wrapper import ApiCollectionWrapper
  from common import common_func
  from common import common_type
label_desc: Use image node_id 1 for calling a global function with example usage: e2e_milvus(host, c_name) without return types