code: def __init__(self, *args, **kwargs):
      self.request_type = "grpc"
      connection_type = kwargs.get("connection_type")
      if connection_type == "single":
          self.m = kwargs.get("m")
      elif connection_type == "multi":
          host = kwargs.get("host")
          port = kwargs.get("port")
          collection_name = kwargs.get("collection_name")
          self.m = MilvusClient(
              host=host, port=port, collection_name=collection_name
          )
  
file_path: milvus/tests/benchmark/milvus_benchmark/runners/locust_task.py
imports: import time
  import logging
  from locust import User, events
  from milvus_benchmark.client import MilvusClient
label_desc: Use image node_id 1 to create a new MilvusTask object from inherited base classes: object with example: obj = MilvusTask()