Skip to content

Commit

Permalink
fix: Typo in the rank zero code (#240)
Browse files Browse the repository at this point in the history
The original Ray controller method `execute_rank_zero_sync()` is not
functional. Fixed.
  • Loading branch information
ExtremeViscent authored Feb 11, 2025
1 parent bf9be15 commit 95560d7
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion verl/single_controller/ray/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -317,7 +317,7 @@ def _rebind_actor_methods(worker_group, actor_name):
return new_worker_group_dict

def execute_rank_zero_sync(self, method_name: str, *args, **kwargs):
return ray.get(self.execute_all_async(method_name, **args, **kwargs))
return ray.get(self.execute_rank_zero_async(method_name, *args, **kwargs))

def execute_rank_zero_async(self, method_name: str, *args, **kwargs):
remote_call = getattr(self._workers[0], method_name)
Expand Down

0 comments on commit 95560d7

Please sign in to comment.