code: def start_cluster(
      name, enable_auto_recovery=False, clean_auto_recovery=False
  ):
      script = get_script_path("H2O_START_SCRIPT")
      notify_file = "notify_" + name
      driver_log_file = "driver_" + name + ".log"
      clouding_dir = get_workdir() + "_clouding_" + name
      job_name = os.getenv("H2O_JOB_NAME") + "_" + name
      args = [
          script,
          "--cluster-name",
          name,
          "--clouding-dir",
          clouding_dir,
          "--notify-file",
          notify_file,
          "--driver-log-file",
          driver_log_file,
          "--hadoop-version",
          os.getenv("H2O_HADOOP"),
          "--job-name",
          job_name,
          "--nodes",
          "3",
          "--xmx",
          "8G",
      ]
      if enable_auto_recovery:
          recovery_dir = get_workdir() + "_recovery"
          args.append("--auto-recovery-dir")
          args.append(recovery_dir)
          if clean_auto_recovery:
              args.append("--auto-recovery-cleanup")
          args.append("--proxy")
      else:
          args.append("--disown")
      notify_file_path = os.getenv("H2O_HOME") + "/" + notify_file
      if os.path.exists(notify_file_path):
          os.remove(notify_file_path)
      run_script(args)
      with open(notify_file_path) as f:
          cluster_url = f.readline()
      return "http://" + cluster_url.rstrip()
  
file_path: h2o-3/h2o-hadoop-common/tests_fault_tolerance/python/fault_tolerance_utils.py
imports: import os
  import subprocess
  from subprocess import PIPE, STDOUT, CalledProcessError
label_desc: Use image node_id 4 for calling a global function with example usage: start_cluster(name, enable_auto_recovery, clean_auto_recovery) and returns: unknown