fix: parallel state initialization error in Megatron to HF model conversion (#1120)

Signed-off-by: Stan Kirdey <stan@inflection.ai>
Signed-off-by: NeMo Bot <nemo-bot@nvidia.com>

Author: skirdey-inflection

nemo_rl/models/megatron/community_import.py

@@ -104,9 +104,24 @@ def export_model_from_megatron(
             f"HF checkpoint already exists at {output_path}. Delete it to run or set overwrite=True."
         )
 
+    try:
+        from megatron.bridge.training.model_load_save import (
+            temporary_distributed_context,
+        )
+    except ImportError:
+        raise ImportError("megatron.bridge.training is not available.")
+
     bridge = AutoBridge.from_hf_pretrained(hf_model_name, trust_remote_code=True)
-    megatron_model = bridge.load_megatron_model(input_path)
-    bridge.save_hf_pretrained(megatron_model, output_path)
+
+    # Export performs on CPU with proper distributed context
+    with temporary_distributed_context(backend="gloo"):
+        # Load the Megatron model
+        megatron_model = bridge.load_megatron_model(
+            input_path, skip_temp_dist_context=True
+        )
+
+        # Save in HuggingFace format
+        bridge.save_hf_pretrained(megatron_model, output_path)
 
     # resetting mcore state
     import megatron.core.rerun_state_machine