9e68b77796c1478973f5236adfc09f3399721659,rllib/evaluation/worker_set.py,WorkerSet,stop,#WorkerSet#,145

Before Change

        Stop all rollout workers.
        self.local_worker().stop()
        for w in self.remote_workers():
            w.stop.remote()
            w.__ray_terminate__.remote()

    @DeveloperAPI
    def foreach_worker(self, func: Callable[[RolloutWorker], T]) -> List[T]:

After Change

        Stop all rollout workers.
        try:
            self.local_worker().stop()
            tids = [w.stop.remote() for w in self.remote_workers()]
            ray.get(tids)
        except Exception:
            logger.exception("Failed to stop workers")

Instances