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