code: def test_generator_slow_pinning_requests(monkeypatch, shutdown_only):
      """
      Verify when the Object pinning request from the raylet
      is reported slowly, there's no refernece leak.
      """
      with monkeypatch.context() as m:
          m.setenv(
              "RAY_testing_asio_delay_us",
              "CoreWorkerService.grpc_server.PubsubLongPolling=1000000:1000000",
          )
  
          @ray.remote
          def f():
              yield np.ones(5 * 1024 * 1024)
  
          for ref in f.remote():
              del ref
  
          print(list_objects())
  
imports: import asyncio
  import pytest
  import numpy
  import sys
  import time
  import threading
  import gc
  from unittest.mock import patch, Mock
  import ray
  from ray._private.test_utils import wait_for_condition
  from ray.experimental.state.api import list_objects
  from ray._raylet import ObjectRefGenerator, ObjectRefStreamEndOfStreamError
  from ray.cloudpickle import dumps
  from ray.exceptions import WorkerCrashedError
label_desc: Use image node_id 9 for calling a global function with example usage: test_generator_slow_pinning_requests(monkeypatch, shutdown_only) without return types