code: def test_object_store_memory_reporting():
      try:
          ray.init(num_cpus=1, object_store_memory=500 * MB)
          wait_for_condition(lambda: object_store_memory(500 * MB))
          x1 = ray.put(np.zeros(150 * 1024 * 1024, dtype=np.uint8))
          wait_for_condition(lambda: object_store_memory(350 * MB))
          x2 = ray.put(np.zeros(75 * 1024 * 1024, dtype=np.uint8))
          wait_for_condition(lambda: object_store_memory(275 * MB))
          del x1
          del x2
          wait_for_condition(lambda: object_store_memory(500 * MB))
      finally:
          ray.shutdown()
  
file_path: ray/python/ray/tests/test_memory_scheduling.py
imports: import numpy
  import time
  import ray
  from ray._private.test_utils import wait_for_condition
label_desc: Use image node_id 3 for calling a global function with example usage: test_object_store_memory_reporting() without return types