[hotfix] fix fp16 optimzier bug (#2273)

2 years ago · f027ef7913
1 changed files with 2 additions and 2 deletions
--- a/colossalai/amp/naive_amp/_fp16_optimizer.py
+++ b/colossalai/amp/naive_amp/_fp16_optimizer.py
@ -70,8 +70,8 @@ class FP16Optimizer(Optimizer):

        # get process group
        def _get_process_group(parallel_mode):
-            if gpc.is_initialized(ParallelMode.DATA) and gpc.get_world_size(ParallelMode.DATA):
-                return gpc.get_group(ParallelMode.DATA)
+            if gpc.is_initialized(parallel_mode) and gpc.get_world_size(parallel_mode):
+                return gpc.get_group(parallel_mode)
            else:
                return None