code: def sleep():
      time.sleep(999)
  
file_path: ray/python/ray/data/tests/test_streaming_executor_resource_limits.py
imports: import collections
  import math
  import time
  from unittest.mock import patch
  import pytest
  import ray
  from ray.data._internal.execution.interfaces import ExecutionOptions, ExecutionResources
  from ray.data._internal.execution.operators.map_transformer import create_map_transformer_from_block_fn
  from ray.data._internal.execution.streaming_executor import StreamingExecutor
  from ray.data._internal.execution.streaming_executor_state import DEFAULT_OBJECT_STORE_MEMORY_LIMIT_FRACTION, DownstreamMemoryInfo, TopologyResourceUsage
  from ray.data._internal.execution.util import make_ref_bundles
  from ray.data.tests.conftest import *
label_desc: Use image node_id 1 for calling a global function with example usage: sleep() without return types