code: def test_core_worker_error_message():
      script = """
  import ray
  import sys
  
  ray.init(local_mode=True)
  
  # In local mode this generates an ERROR level log.
  ray._private.utils.push_error_to_driver(
      ray._private.worker.global_worker, "type", "Hello there")
      """
  
      proc = run_string_as_driver_nonblocking(script)
      err_str = proc.stderr.read().decode("ascii")
  
      assert "Hello there" in err_str, err_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 17 for calling a global function with example usage: test_core_worker_error_message() without return types