Fix PatchedMoeMatmul and Get num_experts from Module (#202)

Fix `PatchedMoeMatmul` and Get `num_experts` from Module

---------

Signed-off-by: Yi Liu <[email protected]>
Co-authored-by: Yi Liu <[email protected]>

Author: 2 people

neural_compressor/torch/algorithms/fp8_quant/_core/measure.py

@@ -146,6 +146,10 @@ def register_patched_measure_modules(model, mod_list, observer_class, d_shapes=N
                 patched_types.add(type(mod))
 
                 set_hqt_config(mod, top_level_config)  # set config in the module, as it consumed by the patched module
+                if mod_type == "dynamic_moe" and hasattr(mod, "num_experts"):
+                    # override default number of outputs for dynamic moe
+                    mod_types[mod_type].num_outputs = mod.num_experts+1
+                    logger.warning(f"Dynamic moe num_outputs set to {mod.num_experts+1}")
                 mod_extra_config = (
                     init_measure_object(
                         mod,

neural_compressor/torch/algorithms/fp8_quant/_core/patching_common.py

@@ -51,8 +51,6 @@ def create_mod_info_recursion(parent):
 
     create_mod_info_recursion(model)
 
-    
-INC_DYNAMIC_MOE_EXPERTS = int(os.environ.get("INC_DYNAMIC_MOE_EXPERTS", "8"))
 
 _mod_types = {
     "linear": ModuleType(1, ["weight"], 1, False),
@@ -61,7 +59,7 @@ def create_mod_info_recursion(parent):
     "kv_cache": ModuleType(1, [], 1, False),
     "softmax": ModuleType(1, [], 1, True),
     "fused_sdpa": ModuleType(3, [], 2, True),
-    "dynamic_moe": ModuleType(1, [], 1 + INC_DYNAMIC_MOE_EXPERTS, True),
+    "dynamic_moe": ModuleType(1, [], 1 + 8, True),
 }
 
 

neural_compressor/torch/algorithms/fp8_quant/_quant_common/helper_modules.py

@@ -705,7 +705,7 @@ def __init__(self, mod, parent, mod_extra_config, *args, **kwargs):
         if (self.quantization_mode == QuantMode.MEASURE) or (self.quantization_mode == QuantMode.SHAPE):
             measure_input((torch.tensor(0),), observer=self._mod_extra_config.inputs)
         else:
-            self.weight = self.weight.squeeze()
+            self.weight = torch.nn.Parameter(self.weight.squeeze(), requires_grad=False)
 
     def forward_qdq(self, input, *args, **kwargs):
         qinput = self.quant_input(input)