File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
megatron/core/distributed/fsdp/src/megatron_fsdp Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1691,9 +1691,6 @@ def __init__(
16911691 if self .dist_index .get_fsdp_group (is_expert_parallel = True ) is not None :
16921692 # Expert-DP group when using EP
16931693 self .ubr_groups .append (self .dist_index .get_fsdp_group (is_expert_parallel = True ))
1694- if self .dist_index .get_outer_fsdp_group () is not None :
1695- # Outer/Inter-FSDP group when using hybrid FSDP
1696- self .ubr_groups .append (self .dist_index .get_outer_fsdp_group ())
16971694 if (
16981695 self .dist_index .get_fsdp_group (
16991696 is_expert_parallel = False , independent_all_gather = True
@@ -1716,6 +1713,9 @@ def __init__(
17161713 is_expert_parallel = True , independent_all_gather = True
17171714 )
17181715 )
1716+ if self .dist_index .get_outer_fsdp_group () is not None :
1717+ # Outer/Inter-FSDP group when using hybrid FSDP (IB domain, registered last).
1718+ self .ubr_groups .append (self .dist_index .get_outer_fsdp_group ())
17191719
17201720 log_single_rank (
17211721 logger ,
You can’t perform that action at this time.
0 commit comments