未验证 提交 e7f205ec 编写于 作者: K kuizhiqing 提交者: GitHub

[launch] fix typos (#41190)

上级 00d23897
...@@ -142,4 +142,4 @@ class Device(object): ...@@ -142,4 +142,4 @@ class Device(object):
if __name__ == '__main__': if __name__ == '__main__':
d = Device.parse_device() d = Device.parse_device()
print(d.get_selected_flag()) print(d.get_selected_devices())
...@@ -93,7 +93,7 @@ class CollectiveController(Controller): ...@@ -93,7 +93,7 @@ class CollectiveController(Controller):
"PADDLE_RANK_IN_NODE": str(i), "PADDLE_RANK_IN_NODE": str(i),
} }
if self.pod.replicas == 1: if self.pod.replicas == 1:
e.update({selected_dev_key: selected_dev_list}) e.update({selected_dev_key: ",".join(selected_dev_list)})
else: else:
e.update({selected_dev_key: selected_dev_list[i]}) e.update({selected_dev_key: selected_dev_list[i]})
self.add_container(envs=e, log_tag=i) self.add_container(envs=e, log_tag=i)
...@@ -134,7 +134,7 @@ class CollectiveElasticController(CollectiveController): ...@@ -134,7 +134,7 @@ class CollectiveElasticController(CollectiveController):
if ok: if ok:
self.job.replicas = replicas self.job.replicas = replicas
else: else:
self.ctx.logger.warnning("peer not ready {}".format(self.job)) self.ctx.logger.warning("peer not ready {}".format(self.job))
break break
self.ctx.logger.debug("Run {}".format(self.job)) self.ctx.logger.debug("Run {}".format(self.job))
......
...@@ -162,7 +162,7 @@ class Container(object): ...@@ -162,7 +162,7 @@ class Container(object):
if idx > lines: if idx > lines:
break break
finally: finally:
return self._log_handler.tell() return
def tail(self, length=3000): def tail(self, length=3000):
if not self._log_handler: if not self._log_handler:
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册