code: def _start_new_cluster():
      cluster = Cluster(
          initialize_head=True,
          connect=True,
          head_node_args={
              "num_cpus": 1,
              "_system_config": {
                  "health_check_initial_delay_ms": 0,
                  "health_check_period_ms": 1000,
                  "health_check_failure_threshold": 10,
              },
          },
      )
      return cluster
  
imports: import time
  import os
  import pytest
  import sys
  from unittest.mock import MagicMock
  import ray
  from ray import tune
  from ray.train import CheckpointConfig
  from ray.cluster_utils import Cluster
  from ray.train._internal.storage import StorageContext
  from ray.tune.error import TuneError
  from ray.tune.search import BasicVariantGenerator
  from ray.tune.experiment import Trial
  from ray.tune.execution.tune_controller import TuneController
label_desc: Use image node_id 3 for calling a global function with example usage: _start_new_cluster() and returns: cluster