code: def test_task_forward(benchmark, num_tasks):
      with _ray_start_cluster(
          do_init=True,
          num_nodes=1,
          num_cpus=16,
          object_store_memory=150 * 1024 * 1024,
      ) as cluster:
          cluster.add_node(
              num_cpus=16,
              object_store_memory=150 * 1024 * 1024,
              resources={"my_resource": 100},
          )
  
          @ray.remote(resources={"my_resource": 0.001})
          def f():
              return 1
  
          # Warm up
          ray.get([f.remote() for _ in range(100)])
          benchmark(benchmark_task_forward, f, num_tasks)
  
file_path: ray/python/ray/tests/perf_integration_tests/test_perf_integration.py
imports: import numpy
  import pytest
  import ray
  from ray.tests.conftest import _ray_start_cluster
label_desc: Use image node_id 6 for calling a global function with example usage: test_task_forward(benchmark, num_tasks) and returns: int