code: def wait_signal_to_apply_chaos():
      all_db_file = glob.glob("/tmp/ci_logs/event_records*.parquet")
      log.info(f"all files {all_db_file}")
      ready_apply_chaos = True
      timeout = 10 * 60
      t0 = time.time()
      for f in all_db_file:
          while True and (time.time() - t0 < timeout):
              try:
                  df = pd.read_parquet(f)
                  log.debug(f"read {f}:result\n {df}")
                  result = df[
                      (df["event_name"] == "init_chaos")
                      & (df["event_status"] == "ready")
                  ]
                  if len(result) > 0:
                      log.info(f"{f}: {result}")
                      ready_apply_chaos = True
                      break
                  else:
                      ready_apply_chaos = False
              except Exception as e:
                  log.error(f"read_parquet error: {e}")
                  ready_apply_chaos = False
              time.sleep(10)
  
      return ready_apply_chaos
  
file_path: milvus/tests/python_client/utils/util_common.py
imports: import glob
  import time
  from yaml import full_load
  import json
  import pandas
  from utils.util_log import test_log
label_desc: Use image node_id 8 for calling a global function with example usage: wait_signal_to_apply_chaos() and returns: ready_apply_chaos