code: def test_dedup_logs():
      script = """
  import ray
  import time
  
  @ray.remote
  def verbose():
      print(f"hello world, id={time.time()}")
      time.sleep(1)
  
  ray.init(num_cpus=4)
  ray.get([verbose.remote() for _ in range(10)])
  """
  
      proc = run_string_as_driver_nonblocking(script)
      out_str = proc.stdout.read().decode("ascii")
  
      assert out_str.count("hello") == 2
      assert out_str.count("RAY_DEDUP_LOGS") == 1
      assert out_str.count("[repeated 9x across cluster]") == 1
  
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 1 for calling a global function with example usage: test_dedup_logs() without return types