code: def test_reference_global_import_does_not_leak_worker_upon_driver_exit(
      call_ray_start,
  ):
      driver = """
  import ray
  import numpy as np
  import tensorflow
  
  @ray.remote(max_retries=0)
  def leak_repro(obj):
      tensorflow
      return []
  
  refs = []
  for i in range(100_000):
      refs.append(leak_repro.remote(i))
  
  ray.get(refs)
    """
      try:
          run_string_as_driver(driver)
      except subprocess.CalledProcessError:
          pass
  
      ray.init(address=call_ray_start)
  
      def no_object_leaks():
          objects = list_objects(_explain=True, timeout=3)
          return len(objects) == 0
  
      wait_for_condition(
          no_object_leaks, timeout=10, retry_interval_ms=1000
      )
  
file_path: ray/python/ray/tests/test_node_manager.py
imports: import ray
  from ray.util.state import list_workers
  from ray._private.test_utils import get_load_metrics_report, run_string_as_driver, run_string_as_driver_nonblocking, wait_for_condition, get_resource_usage
  import pytest
  import os
  from ray.util.state import list_objects
  import subprocess
  from ray._private.utils import get_num_cpus
  import time
  import sys
label_desc: Use image node_id 7 for calling a global function with example usage: test_reference_global_import_does_not_leak_worker_upon_driver_exit(call_ray_start) and returns: unknown