code: def test_submitting_tasks(ray_start_combination):
      _, _, cluster = ray_start_combination
  
      @ray.remote
      def f(x):
          return x
  
      for _ in range(1):
          ray.get([f.remote(1) for _ in range(1000)])
  
      for _ in range(10):
          ray.get([f.remote(1) for _ in range(100)])
  
      for _ in range(100):
          ray.get([f.remote(1) for _ in range(10)])
  
      for _ in range(1000):
          ray.get([f.remote(1) for _ in range(1)])
  
      assert cluster.remaining_processes_alive()
  
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 2 for calling a global function with example usage: test_submitting_tasks(ray_start_combination) and returns: x