code: def test_large_dir_upload_message(start_cluster, option):
      cluster, address = start_cluster
      with tempfile.TemporaryDirectory() as tmp_dir:
          filepath = os.path.join(tmp_dir, "test_file.txt")
  
          # Ensure forward slashes to prevent escapes in the text passed
          # to stdin (for Windows tests this matters)
          tmp_dir = str(Path(tmp_dir).as_posix())
  
          if option == "working_dir":
              driver_script = f"""
  import ray
  ray.init("{address}", runtime_env={{"working_dir": "{tmp_dir}"}})
  """
          else:
              driver_script = f"""
  import ray
  ray.init("{address}", runtime_env={{"py_modules": ["{tmp_dir}"]}})
  """
  
          with open(filepath, "w") as f:
              f.write("Hi")
  
          output = run_string_as_driver(driver_script)
          assert "Pushing file package" in output
          assert "Successfully pushed file package" in output
  
file_path: ray/python/ray/tests/test_runtime_env_working_dir_2.py
imports: import os
  from pathlib import Path
  import sys
  import tempfile
  import pytest
  from ray._private.test_utils import chdir, run_string_as_driver
  import ray
  from ray._private.runtime_env import RAY_WORKER_DEV_EXCLUDES
  from ray._private.runtime_env.packaging import GCS_STORAGE_MAX_SIZE
  from ray.exceptions import RuntimeEnvSetupError
  from ray._private.runtime_env.packaging import get_uri_for_directory, upload_package_if_needed
  from ray._private.utils import get_directory_size_bytes
label_desc: Use image node_id 4 for calling a global function with example usage: test_large_dir_upload_message(start_cluster, option) without return types