code: def ray_start_workers_separate_multinode(request):
      num_nodes = request.param[0]
      num_initial_workers = request.param[1]
      # Start the Ray processes.
      cluster = Cluster()
      for _ in range(num_nodes):
          cluster.add_node(num_cpus=num_initial_workers)
      ray.init(address=cluster.address)
  
      yield num_nodes, num_initial_workers
      # The code after the yield will run as teardown code.
      ray.shutdown()
      cluster.shutdown()
  
file_path: ray/python/ray/tests/test_component_failures_2.py
imports: import signal
  import sys
  import time
  import pytest
  import ray
  import ray._private.ray_constants
  from ray._private.test_utils import get_other_nodes, wait_for_condition
  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_workers_separate_multinode(request) without return types