Unverified Commit 8eb22b50 by BearBiscuit Committed by GitHub

[docs] modify the comments (#363)

parent d36422be
......@@ -333,8 +333,8 @@ class RayWorkerGroup(WorkerGroup):
return ray.get(self.execute_all_async(method_name, *args, **kwargs))
def execute_all_async(self, method_name: str, *args, **kwargs):
# 这里我们假设,如果 args 和 kwargs 里面所有的参数都是 list,且所有的 list 长度都与 len(self._workers) 一致的话,我们会把
# list 中的每一个分别发到对应的 worker 上去
# Here, we assume that if all arguments in args and kwargs are lists, and their lengths match len(self._workers),
# we'll distribute each element in these lists to the corresponding worker
# print(f"execute_all_async: method {method_name}({args}, {kwargs})")
length = len(self._workers)
if all(isinstance(arg, list) for arg in args) and all(isinstance(kwarg, list) for kwarg in kwargs.values()):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment