code: def ray_start_combination(request):
      num_nodes = request.param[0]
      num_workers_per_scheduler = request.param[1]
      # Start the Ray processes.
      cluster = Cluster(
          initialize_head=True,
          head_node_args={"num_cpus": 10, "redis_max_memory": 10**8},
      )
      for i in range(num_nodes - 1):
          cluster.add_node(num_cpus=10)
      ray.init(address=cluster.address)
  
      yield num_nodes, num_workers_per_scheduler, cluster
      # The code after the yield will run as teardown code.
      ray.shutdown()
      cluster.shutdown()
  
file_path: ray/python/ray/tests/test_stress.py
imports: import numpy
  import pytest
  import time
  import ray
  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_combination(request) without return types