Skip to content

Commit dceb953

Browse files
committed
Fix merge bug
1 parent 8e0e35e commit dceb953

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/paddle/distributed/auto_parallel/static/reshard_funcs/same_status_reshard_func.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ def reshard(self, src_dist_attr, dst_dist_attr, src_value, dst_type):
100100
paddle._C_ops.p_send(
101101
src_value,
102102
comm_group.id,
103-
dst_local_rank,
103+
comm_group.ranks.index(dst),
104104
False,
105105
)
106106
point = paddle.base.libpaddle.pir.get_current_insertion_point()
@@ -128,7 +128,7 @@ def reshard(self, src_dist_attr, dst_dist_attr, src_value, dst_type):
128128
comm_group = new_process_group([src, dst], group_type="p2p")
129129
recv_value = paddle._C_ops.p_recv(
130130
comm_group.id,
131-
src_local_rank,
131+
comm_group.ranks.index(src),
132132
dst_type.dtype,
133133
False,
134134
)

0 commit comments

Comments
 (0)