code: def test_operations(
      self, request_duration, is_check, collection_name
  ):
      # start the monitor threads to check the milvus ops
      log.info("*********************Test Start**********************")
      log.info(connections.get_connection_addr("default"))
      # event_records = EventRecords()
      c_name = (
          collection_name
          if collection_name
          else cf.gen_unique_str("Checker_")
      )
      # event_records.insert("init_health_checkers", "start")
      self.init_health_checkers(collection_name=c_name)
      # event_records.insert("init_health_checkers", "finished")
      cc.start_monitor_threads(self.health_checkers)
      log.info("*********************Load Start**********************")
      request_duration = (
          request_duration.replace("h", "*3600+")
          .replace("m", "*60+")
          .replace("s", "")
      )
      if request_duration[-1] == "+":
          request_duration = request_duration[:-1]
      request_duration = eval(request_duration)
      for i in range(10):
          sleep(request_duration // 10)
          for k, v in self.health_checkers.items():
              v.check_result()
              # log.info(v.check_result())
      wait_pods_ready(
          self.milvus_ns,
          f"app.kubernetes.io/instance={self.release_name}",
      )
      time.sleep(60)
      ra = ResultAnalyzer()
      ra.get_stage_success_rate()
      if is_check:
          assert_statistic(self.health_checkers)
          assert_expectations()
      log.info(
          "*********************Chaos Test Completed**********************"
      )
  
imports: import time
  import pytest
  import json
  from time import sleep
  from pymilvus import connections
  from chaos.checker import InsertChecker, UpsertChecker, FlushChecker, SearchChecker, QueryChecker, DeleteChecker, Op, ResultAnalyzer
  from utils.util_k8s import wait_pods_ready, get_milvus_instance_name
  from utils.util_log import test_log
  from chaos import chaos_commons
  from common import common_func
  from common.milvus_sys import MilvusSys
  from chaos.chaos_commons import assert_statistic
  from common.common_type import CaseLabel
  from chaos import constants
  from delayed_assert import assert_expectations
label_desc: Use image node_id 4 for calling the TestOperations obj's underlying member method code with example usage: obj.test_operations(request_duration, is_check, collection_name) without return types