code: def foreach_worker(self, fn):
          
          results = ray.get([w.foreach_worker.remote(fn) for w in self.workers])
          return results
docs: Apply the given function to each remote worker.
  
          Returns:
              List of results from applying the function.