Skip to content

Commit

Permalink
Revert "Update mosaic_fsdp_utils.py (mosaicml#3185)" (mosaicml#3187)
Browse files Browse the repository at this point in the history
This reverts commit 2a262b4.
  • Loading branch information
vchiley committed Apr 12, 2024
1 parent 52776a7 commit 05e568b
Showing 1 changed file with 8 additions and 3 deletions.
11 changes: 8 additions & 3 deletions composer/trainer/mosaic_fsdp_utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -177,11 +177,16 @@ def _get_process_group(pg, process_group_cache=None):
return process_group_cache[ranks]

log.info(f'Instantiating custom process groups with {ranks=} on rank={dist.get_global_rank()}.')
process_group = distributed.new_group(ranks)

ranks_per_subgroup_list = list(set(dist.all_gather_object(ranks)))
(
current_group,
_subgroups,
) = distributed.distributed_c10d.new_subgroups_by_enumeration(ranks_per_subgroup_list)

if process_group_cache is not None:
process_group_cache[ranks] = process_group
return process_group
process_group_cache[ranks] = current_group
return current_group


def _set_custom_fsdp_module_kwargs(module_kwargs: Dict, process_group_cache: Dict[Tuple[int], Any]) -> Dict:
Expand Down

0 comments on commit 05e568b

Please sign in to comment.