-
Notifications
You must be signed in to change notification settings - Fork 5.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[NewComm]No.7 compatiable upgrade for global_gather_op. #57305
Conversation
你的PR提交成功,感谢你对开源项目的贡献! |
auto send_buf = x->data<T>(); | ||
auto recv_buf = out->mutable_data<T>(out_dims, place); | ||
|
||
out->mutable_data<T>(out_dims, place); | ||
|
||
for (auto i = 0; i < n_expert; ++i) { | ||
PADDLE_ENFORCE_GPU_SUCCESS(platform::dynload::ncclGroupStart()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
参考PR:#56088 的alltoall_op.cu.cc修改一下
j, | ||
comm->comm(), | ||
stream)); | ||
} | ||
} | ||
} | ||
PADDLE_ENFORCE_GPU_SUCCESS(platform::dynload::ncclGroupEnd()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
同上。需要修改一下。
@@ -38,6 +38,15 @@ def test_global_gather_nccl_dygraph_eager(self): | |||
eager_mode=True, | |||
) | |||
|
|||
def test_global_gather_nccl_new_comm(self): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
还需要修改collective_global_gather.py。可以参考#57161
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
PR types
Others
PR changes
Others
Description