code: def test_scheduling_strategy_overrides(
      ray_start_10_cpus_shared, restore_data_context
  ):
      input_op = InputDataBuffer(
          make_ref_bundles([[i] for i in range(100)])
      )
      op = MapOperator.create(
          _mul2_map_data_prcessor,
          input_op=input_op,
          name="TestMapper",
          compute_strategy=TaskPoolStrategy(),
          ray_remote_args={
              "num_gpus": 2,
              "scheduling_strategy": "DEFAULT",
          },
      )
      assert op._ray_remote_args == {
          "num_gpus": 2,
          "scheduling_strategy": "DEFAULT",
      }
  
      ray.data.DataContext.get_current().scheduling_strategy = "DEFAULT"
      op = MapOperator.create(
          _mul2_map_data_prcessor,
          input_op=input_op,
          name="TestMapper",
          compute_strategy=TaskPoolStrategy(),
          ray_remote_args={"num_gpus": 2},
      )
      assert op._ray_remote_args == {"num_gpus": 2}
  
file_path: ray/python/ray/data/tests/test_executor_resource_management.py
imports: import pytest
  import ray
  from ray.data._internal.compute import ActorPoolStrategy, TaskPoolStrategy
  from ray.data._internal.execution.interfaces import ExecutionOptions, ExecutionResources
  from ray.data._internal.execution.operators.input_data_buffer import InputDataBuffer
  from ray.data._internal.execution.operators.map_operator import MapOperator
  from ray.data._internal.execution.util import make_ref_bundles
  from ray.data.tests.conftest import *
  from ray.data.tests.test_operators import _mul2_map_data_prcessor
  from ray.data.tests.util import run_op_tasks_sync
label_desc: Use image node_id 3 for calling a global function with example usage: test_scheduling_strategy_overrides(ray_start_10_cpus_shared, restore_data_context) without return types