code: def test_disable_driver_logs_breakpoint():
      script = """
  import time
  import os
  import ray
  import sys
  import threading
  
  ray.init(num_cpus=2)
  
  @ray.remote
  def f():
      while True:
          time.sleep(1)
          print("hello there")
          sys.stdout.flush()
  
  def kill():
      time.sleep(5)
      sys.stdout.flush()
      time.sleep(1)
      os._exit(0)
  
  t = threading.Thread(target=kill)
  t.start()
  x = f.remote()
  time.sleep(2)  # Enough time to print one hello.
  ray.util.rpdb._driver_set_trace()  # This should disable worker logs.
  # breakpoint()  # Only works in Py3.7+
      """
  
      proc = run_string_as_driver_nonblocking(script)
      out_str = proc.stdout.read().decode("ascii")
      num_hello = out_str.count("hello")
      assert num_hello >= 1, out_str
      assert num_hello < 3, out_str
      assert "Temporarily disabling Ray worker logs" in out_str, out_str
  
imports: import os
  import re
  import signal
  import subprocess
  import sys
  import time
  import pytest
  import ray
  from ray._private.test_utils import run_string_as_driver, run_string_as_driver_nonblocking, wait_for_condition
label_desc: Use image node_id 18 for calling a global function with example usage: test_disable_driver_logs_breakpoint() without return types