未验证 提交 55b87742 编写于 作者: Y Yuang Liu 提交者: GitHub

[fleet_executor] bug fix for fleet_executor, test=allcase (#37934)

上级 567e6bbc
......@@ -1954,7 +1954,7 @@ class Executor(object):
trainer_endpoints_str = os.getenv("PADDLE_TRAINER_ENDPOINTS", "")
trainer_endpoints = trainer_endpoints_str.split(',')
fleet_exe_desc = fleet_executor_desc_pb2.FleetExecutorDesc()
fleet_exe_desc.cur_rank = os.getenv("PADDLE_TRAINER_ID", 0)
fleet_exe_desc.cur_rank = int(os.getenv("PADDLE_TRAINER_ID", 0))
nrank = len(trainer_endpoints)
for rank, endpoint in enumerate(trainer_endpoints):
rank_info = fleet_executor_desc_pb2.RankInfo()
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册