code: def ray_start_sharded(request):
      # TODO(ekl) enable this again once GCS supports sharding.
      # num_redis_shards = request.param
  
      # Start the Ray processes.
      ray.init(
          object_store_memory=int(0.5 * 10**9),
          num_cpus=10,
          # _num_redis_shards=num_redis_shards,
          _redis_max_memory=10**8,
      )
  
      yield None
  
      # The code after the yield will run as teardown code.
      ray.shutdown()
  
file_path: ray/python/ray/tests/test_stress_sharded.py
imports: import numpy
  import pytest
  import ray
label_desc: Use image node_id 1 for calling a global function with example usage: ray_start_sharded(request) without return types