code: def start_tasks(num_task, num_cpu_per_task, task_duration):
      ray.get(
          [
              simple_task.options(num_cpus=num_cpu_per_task).remote(
                  task_duration
              )
              for _ in range(num_task)
          ]
      )
  
file_path: ray/release/benchmarks/distributed/test_scheduling.py
imports: import ray
  import argparse
  from time import time, sleep
  from math import floor
  from ray._private.test_utils import safe_write_to_results_json
  import ray._private.test_utils
label_desc: Use image node_id 2 for calling a global function with example usage: start_tasks(num_task, num_cpu_per_task, task_duration) without return types