code: def test_fd_reuse_no_memory_corruption(shutdown_only):
      @ray.remote
      class Actor:
          def produce(self, i):
              s = random.randrange(1, 200)
              z = np.ones(s * 1024 * 1024)
              z[0] = i
              return z
  
          def consume(self, x, i):
              print(x)
              assert x[0] == i, x
  
      ray.init(object_store_memory=100e6)
      a = Actor.remote()
      b = Actor.remote()
      for i in range(20):
          x_id = a.produce.remote(i)
          ray.get(b.consume.remote(x_id, i))
  
imports: import numpy
  import json
  import random
  import os
  import shutil
  import platform
  import pytest
  import psutil
  import ray
  from ray._private.test_utils import check_spilled_mb, fetch_prometheus, wait_for_condition
label_desc: Use image node_id 10 for calling a global function with example usage: test_fd_reuse_no_memory_corruption(shutdown_only) and returns: z