code: def test_bulk_insert_perf(self):
      # start the monitor threads to check the milvus ops
      log.info("*********************Test Start**********************")
      log.info(connections.get_connection_addr("default"))
      self.init_health_checkers()
      cc.start_monitor_threads(self.health_checkers)
      # wait 600s
      while self.health_checkers[Op.bulk_insert].total() <= 10:
          sleep(constants.WAIT_PER_OP)
      assert_statistic(self.health_checkers)
  
      assert_expectations()
      for k, checker in self.health_checkers.items():
          checker.check_result()
          checker.terminate()
  
      log.info(
          "*********************Test Completed**********************"
      )
  
file_path: milvus/tests/python_client/bulk_insert/test_bulk_insert_perf_with_cohere_dataset.py
imports: import pytest
  import threading
  from time import sleep
  from pymilvus import connections, DataType, FieldSchema, CollectionSchema
  from chaos.checker import BulkInsertChecker, Op
  from utils.util_log import test_log
  from chaos import chaos_commons
  from common.common_type import CaseLabel
  from common import common_func
  from chaos import constants
  from delayed_assert import expect, assert_expectations
label_desc: Use image node_id 4 for calling the TestBUlkInsertPerf obj's underlying member method code with example usage: obj.test_bulk_insert_perf() without return types