code: def test_default_large_cache(start_cluster, option: str, source: str):
      """Check small files aren't GC'ed when using the default large cache."""
      NUM_NODES = 3
      cluster, address = start_cluster
      for i in range(NUM_NODES - 1):  # Head node already added.
          cluster.add_node(
              num_cpus=1,
              runtime_env_dir_name=f"node_{i}_runtime_resources",
          )
  
      if option == "working_dir":
          ray.init(address, runtime_env={"working_dir": source})
      elif option == "py_modules":
          if source != S3_PACKAGE_URI:
              source = str(Path(source) / "test_module")
          ray.init(address, runtime_env={"py_modules": [source]})
  
      @ray.remote
      def f():
          pass
  
      # Wait for runtime env to be set up. This can be accomplished by getting
      # the result of a task.
      ray.get(f.remote())
      ray.shutdown()
  
      # TODO(architkulkarni): We should start several tasks with other files and
      # check that all of the files are there, since GC is only triggered
      # when we attempt to create a URI that exceeds the threshold.
      assert not check_local_files_gced(cluster)
  
      ray.init(address)
  
      @ray.remote(num_cpus=1)
      class A:
          def check(self):
              import test_module
  
              test_module.one()
  
      if option == "working_dir":
          A = A.options(runtime_env={"working_dir": S3_PACKAGE_URI})
      else:
          A = A.options(runtime_env={"py_modules": [S3_PACKAGE_URI]})
  
      _ = A.remote()
      ray.shutdown()
      assert not check_local_files_gced(cluster)
  
file_path: ray/python/ray/tests/test_runtime_env_working_dir_4.py
imports: import os
  from pathlib import Path
  import sys
  import pytest
  from pytest_lazyfixture import lazy_fixture
  import ray
  from ray._private.test_utils import wait_for_condition, check_local_files_gced
  from ray.exceptions import GetTimeoutError
label_desc: Use image node_id 1 for calling a global function with example usage: test_default_large_cache(start_cluster, option, source) without return types