code: def ray_start_reconstruction(request):
      num_nodes = request.param
  
      plasma_store_memory = int(0.5 * 10**9)
  
      cluster = Cluster(
          initialize_head=True,
          head_node_args={
              "num_cpus": 1,
              "object_store_memory": plasma_store_memory // num_nodes,
              "redis_max_memory": 10**8,
              "_system_config": {"object_timeout_milliseconds": 200},
          },
      )
      for i in range(num_nodes - 1):
          cluster.add_node(
              num_cpus=1,
              object_store_memory=plasma_store_memory // num_nodes,
          )
      ray.init(address=cluster.address)
  
      yield plasma_store_memory, num_nodes, cluster
  
      # Clean up the Ray cluster.
      ray.shutdown()
      cluster.shutdown()
  
file_path: ray/python/ray/tests/test_stress_failure.py
imports: import sys
  import time
  import numpy
  import pytest
  import ray
  import ray._private.ray_constants
  from ray._private.test_utils import get_error_message
  from ray.cluster_utils import Cluster, cluster_not_supported
label_desc: Use image node_id 1 for calling a global function with example usage: ray_start_reconstruction(request) without return types