(self, worker: ray.actor.ActorHandle)
| 203 | self._bind_worker_method(self.ray_cls_with_init.cls, func_generator) |
| 204 | |
| 205 | def _is_worker_alive(self, worker: ray.actor.ActorHandle): |
| 206 | worker_state_dict = get_actor(worker._actor_id.hex()) |
| 207 | return worker_state_dict.get("state", "undefined") == "ALIVE" if worker_state_dict is not None else False |
| 208 | |
| 209 | def _init_with_detached_workers(self, worker_names): |
| 210 | workers = [ray.get_actor(name=name) for name in worker_names] |