Skip to content

Commit 447297a

Browse files
fix gid (#4054)
Co-authored-by: Divano <[email protected]>
1 parent 63d24b2 commit 447297a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

fastdeploy/config.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -348,12 +348,14 @@ def set_tp_group(self):
348348
(self.data_parallel_rank + 1) * self.tensor_parallel_size,
349349
)
350350
)
351+
dist.collective._set_custom_gid(None)
351352
# same ep group id
352353
dist.collective._set_custom_gid(self.data_parallel_size + tp_gid_offset)
353354
self.ep_group = dist.new_group(range(self.expert_parallel_size))
354355
logger.info(
355356
f"data_parallel_size: {self.data_parallel_size}, tensor_parallel_size: {self.tensor_parallel_size}, expert_parallel_size: {self.expert_parallel_size}, data_parallel_rank: {self.data_parallel_rank}, tensor_parallel_rank: {self.tensor_parallel_rank}, expert_parallel_rank: {self.expert_parallel_rank}, tp_group: {self.tp_group}."
356357
)
358+
dist.collective._set_custom_gid(None)
357359

358360
def print(self):
359361
"""

0 commit comments

Comments
 (0)