-
Notifications
You must be signed in to change notification settings - Fork 5.6k
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
[PIR] Adapt distributed API broadcast
#64190
[PIR] Adapt distributed API broadcast
#64190
Conversation
你的PR提交成功,感谢你对开源项目的贡献! |
broadcast
@@ -59,6 +61,11 @@ def _broadcast_in_static_mode( | |||
helper = framework.LayerHelper(op_type, **locals()) | |||
ring_id = 0 if group is None else group.id | |||
|
|||
if in_pir_mode(): | |||
op_type = _to_inplace_op(op_type) | |||
getattr(_C_ops, op_type)(tensor, src_rank_in_group, sync_op, ring_id) |
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.
这里的参数顺序有点问题,请参考paddle/fluid/pir/dialect/operator/ir/ops.yaml中c_broadcast的args顺序~
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.
已修改~
… pir/adapt-dist-op-broadcast
Sorry to inform you that 4b48e0c's CIs have passed for more than 7 days. To prevent PR conflicts, you need to re-run all CIs manually. |
… pir/adapt-dist-op-broadcast
… pir/adapt-dist-op-broadcast
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 Category
Others
PR Types
Others
Description
适配分布式 API broadcast,为 inplace 操作