code: def test_replenish_resources(ray_start_regular):
      cluster_resources = ray.cluster_resources()
      available_resources = ray.available_resources()
      assert cluster_resources == available_resources
  
      @ray.remote
      def cpu_task():
          pass
  
      ray.get(cpu_task.remote())
      resources_reset = False
  
      while not resources_reset:
          available_resources = ray.available_resources()
          resources_reset = cluster_resources == available_resources
      assert resources_reset
  
imports: import os
  import time
  import pytest
  import ray
  import ray._private.gcs_utils
  import ray._private.ray_constants
  from ray._raylet import GcsClient
  from ray.core.generated import autoscaler_pb2
  from ray._private.test_utils import convert_actor_state, make_global_state_accessor, wait_for_condition
label_desc: Use image node_id 1 for calling a global function with example usage: test_replenish_resources(ray_start_regular) without return types