Add FP8 MHA quantization support for HuggingFace ViT

Enables TensorRT attention-v2 fusion for HuggingFace ViT (and similar
transformer vision models) when exported to ONNX with FP8 Q/DQ.

- fp8_exporter: rewrite attention-scaling Mul and K Transpose to the
  Q-side so DQ feeds MatMul directly, pre-transpose weight constants,
  insert FP8 Q/DQ on Softmax outputs for MHA-v2 fusion. Scale dtype
  now matches the graph's float dtype to keep strongly-typed builds
  consistent.
- onnx/utils: fold Cast(FP16<->FP32) nodes that convert_float_to_float16
  inserts around Q/DQ by rewriting scale initializers to FP16, so TRT
  fuses DQ into the downstream GEMM/MatMul kernel.
- torch/quantization/export_onnx: keep FP8 Q/DQ scale in the native
  input dtype so no Cast is injected between graph and Q/DQ.
- torch/quantization/nn: register nn.LayerNorm in QuantModuleRegistry
  so LayerNorm output quantizers are honored.
- torch/quantization/plugins/huggingface: skip attention wrappers whose
  children are also "*Attention" to avoid double-patching
  eager_attention_forward (e.g. ViTAttention vs ViTSelfAttention).

Example: examples/torch_onnx/vit_mha_quantization.py shows a ViT-FP8
config (extends FP8_DEFAULT_CFG with LayerNorm output quantizer,
disabled input quantizers on LayerNorm-followed layers, and
*_bmm_quantizer entries) plus accuracy + TRT-latency comparison
against an FP16 baseline.

Measured on ViT-base-patch16-224 (RTX 6000 Ada, batch=1):
- Top-1 / top-5 on 5k ImageNet-val: 81.16% / 95.50% (FP16) vs
  80.96% / 95.44% (torch FP8) — -0.20% / -0.06%
- TRT latency: 0.721 ms (FP16) vs 0.646 ms (torch FP8) — 1.12x speedup

Signed-off-by: ajrasane <131806219+ajrasane@users.noreply.github.com>

Author: ajrasane

examples/torch_onnx/vit_mha_quantization.py

@@ -62,6 +62,8 @@ def compress_weights(onnx_model: onnx.ModelProto) -> onnx.ModelProto:
         # Fold constants is required since the scale is not constant yet.
         graph.cleanup().toposort().fold_constants().cleanup()
 
+        n_t_folded = 0
+
         for node in graph.nodes:
             if node.op == "TRT_FP8QuantizeLinear":
                 # Should not remove input QDQ (only process weight quantization)
@@ -78,6 +80,33 @@ def compress_weights(onnx_model: onnx.ModelProto) -> onnx.ModelProto:
                     f"QDQ does not occur in pairs. You reached {dq_op.op}"
                 )
 
+                # Pre-transpose constant weights if DQ feeds ``Transpose → MatMul`` (or
+                # ``Cast → Transpose → MatMul`` after fp16 conversion) so TRT sees DQ→MatMul.
+                transpose_to_remove = None
+                cast_to_remove = None
+                for candidate in list(dq_op.outputs[0].outputs):
+                    if candidate.op == "Cast":
+                        cast_to_remove = candidate
+                        candidate = next(
+                            (c for c in candidate.outputs[0].outputs if c.op == "Transpose"),
+                            None,
+                        )
+                        if candidate is None:
+                            cast_to_remove = None
+                            continue
+                    if candidate.op != "Transpose":
+                        cast_to_remove = None
+                        continue
+                    if any(c.op == "MatMul" for c in candidate.outputs[0].outputs):
+                        perm = candidate.attrs.get("perm", None)
+                        torch_weights = (
+                            torch_weights.permute(*perm).contiguous()
+                            if perm is not None
+                            else torch_weights.T.contiguous()
+                        )
+                        transpose_to_remove = candidate
+                    break
+
                 # Replace it with Dequantize with FP8 weights. This is a WAR because numpy does not support fp8.
                 numpy_weights = (
                     (torch_weights / torch_scale).to(torch.float8_e4m3fn).view(torch.uint8).numpy()
@@ -94,20 +123,232 @@ def compress_weights(onnx_model: onnx.ModelProto) -> onnx.ModelProto:
                 dq_op.inputs[0] = onnx_weights_fp8
                 dq_op.op = "DequantizeLinear"
                 dq_op.outputs[0].dtype = dq_op.inputs[1].dtype
+                dq_op.outputs[0].shape = list(numpy_weights.shape)
+
+                if transpose_to_remove is not None:
+                    t_out = transpose_to_remove.outputs[0]
+                    for consumer in list(t_out.outputs):
+                        for i, inp in enumerate(consumer.inputs):
+                            if inp is t_out:
+                                consumer.inputs[i] = dq_op.outputs[0]
+                    transpose_to_remove.outputs.clear()
+                    if cast_to_remove is not None:
+                        cast_to_remove.outputs.clear()
+                    n_t_folded += 1
 
         graph.cleanup().toposort()
         end_time = time.time()
+        if n_t_folded > 0:
+            logger.info(f"Folded {n_t_folded} weight Transpose nodes during weight compression")
         print(f"fp8 qdq replaced with only dq completed in {end_time - start_time}s.")
 
         return gs.export_onnx(graph)
 
+    @staticmethod
+    def _move_mul_before_qdq(graph: gs.Graph) -> int:
+        """Move attention-scaling Mul(const) from after DQ to before Q for TRT MatMul fusion.
+
+        Handles both ``DQ → Mul → MatMul`` and ``DQ → Transpose → Mul → MatMul`` (K path).
+        """
+        count = 0
+        for mul_node in list(graph.nodes):
+            if mul_node.op != "Mul":
+                continue
+
+            const_input = next(
+                (i for i in mul_node.inputs if isinstance(i, gs.Constant) and i.values.size == 1),
+                None,
+            )
+            tensor_input = next(
+                (i for i in mul_node.inputs if not isinstance(i, gs.Constant)), None
+            )
+            if const_input is None or tensor_input is None:
+                continue
+            if not (isinstance(tensor_input, gs.Variable) and len(tensor_input.inputs) == 1):
+                continue
+
+            producer = tensor_input.inputs[0]
+            transpose_node = producer if producer.op == "Transpose" else None
+            dq_node = producer if producer.op == "DequantizeLinear" else None
+            if transpose_node is not None:
+                t_input = transpose_node.inputs[0]
+                if (
+                    isinstance(t_input, gs.Variable)
+                    and len(t_input.inputs) == 1
+                    and t_input.inputs[0].op == "DequantizeLinear"
+                ):
+                    dq_node = t_input.inputs[0]
+            if dq_node is None:
+                continue
+
+            q_output = dq_node.inputs[0]
+            if (
+                not isinstance(q_output, gs.Variable)
+                or len(q_output.inputs) != 1
+                or q_output.inputs[0].op != "QuantizeLinear"
+            ):
+                continue
+            q_node = q_output.inputs[0]
+            q_input = q_node.inputs[0]
+            if not isinstance(q_input, gs.Variable):
+                continue
+
+            mul_output = mul_node.outputs[0]
+            if not any(c.op == "MatMul" for c in mul_output.outputs):
+                continue
+
+            new_mul_output = gs.Variable(
+                q_input.name + "_scaled", dtype=q_input.dtype, shape=q_input.shape
+            )
+            graph.nodes.append(
+                gs.Node(
+                    op="Mul",
+                    name=mul_node.name + "_moved",
+                    inputs=[q_input, const_input],
+                    outputs=[new_mul_output],
+                )
+            )
+            q_node.inputs[0] = new_mul_output
+
+            replacement = (
+                transpose_node.outputs[0] if transpose_node is not None else dq_node.outputs[0]
+            )
+            for consumer in list(mul_output.outputs):
+                for i, inp in enumerate(consumer.inputs):
+                    if inp is mul_output:
+                        consumer.inputs[i] = replacement
+            mul_node.outputs.clear()
+            count += 1
+
+        graph.cleanup().toposort()
+        return count
+
+    @staticmethod
+    def _move_transpose_before_qdq(graph: gs.Graph) -> int:
+        """Move Transpose from ``DQ → Transpose → MatMul`` to ``Transpose → Q → DQ → MatMul`` (K path)."""
+        count = 0
+        for transpose_node in list(graph.nodes):
+            if transpose_node.op != "Transpose":
+                continue
+
+            t_input = transpose_node.inputs[0]
+            if (
+                not isinstance(t_input, gs.Variable)
+                or len(t_input.inputs) != 1
+                or t_input.inputs[0].op != "DequantizeLinear"
+            ):
+                continue
+            dq_node = t_input.inputs[0]
+
+            dq_input = dq_node.inputs[0]
+            if (
+                not isinstance(dq_input, gs.Variable)
+                or len(dq_input.inputs) != 1
+                or dq_input.inputs[0].op != "QuantizeLinear"
+            ):
+                continue
+            q_node = dq_input.inputs[0]
+            q_input = q_node.inputs[0]
+            if not isinstance(q_input, gs.Variable):
+                continue
+
+            t_output = transpose_node.outputs[0]
+            if not any(c.op == "MatMul" for c in t_output.outputs):
+                continue
+
+            new_t_output = gs.Variable(q_input.name + "_transposed", dtype=q_input.dtype)
+            graph.nodes.append(
+                gs.Node(
+                    op="Transpose",
+                    name=transpose_node.name + "_moved",
+                    inputs=[q_input],
+                    outputs=[new_t_output],
+                    attrs=transpose_node.attrs,
+                )
+            )
+            q_node.inputs[0] = new_t_output
+
+            for consumer in list(t_output.outputs):
+                for i, inp in enumerate(consumer.inputs):
+                    if inp is t_output:
+                        consumer.inputs[i] = dq_node.outputs[0]
+            transpose_node.outputs.clear()
+            count += 1
+
+        graph.cleanup().toposort()
+        return count
+
+    @staticmethod
+    def _insert_qdq_after_softmax(graph: gs.Graph) -> int:
+        """Insert FP8 Q→DQ on Softmax outputs feeding MatMul (required by TRT MHA fusion).
+
+        Torch export does not quantize softmax output; scale=1/448 saturates exactly at 1.0
+        (softmax range is [0, 1]) while covering the full FP8 E4M3 representable range.
+        """
+        import numpy as np
+
+        count = 0
+        for softmax_node in list(graph.nodes):
+            if softmax_node.op != "Softmax":
+                continue
+            softmax_output = softmax_node.outputs[0]
+            if not any(c.op == "MatMul" for c in softmax_output.outputs):
+                continue
+            if any(c.op == "QuantizeLinear" for c in softmax_output.outputs):
+                continue
+
+            # Match scale dtype to the graph's current float dtype so TRT stronglyTyped
+            # sees consistent Q/DQ types with the surrounding compute.
+            scale_dtype = softmax_output.dtype if softmax_output.dtype is not None else np.float32
+            scale_val = np.array(1.0 / 448.0, dtype=scale_dtype)
+            scale_constant = gs.Constant(softmax_node.name + "/softmax_q_scale", scale_val)
+            dq_scale_constant = gs.Constant(
+                softmax_node.name + "/softmax_dq_scale", scale_val.copy()
+            )
+
+            zp_tensor = onnx.TensorProto()
+            zp_tensor.data_type = onnx.TensorProto.FLOAT8E4M3FN
+            zp_tensor.dims.extend([1])
+            zp_tensor.raw_data = b"\x00"
+            zp_constant = gs.Constant(
+                softmax_node.name + "/softmax_q_zero_point", LazyValues(zp_tensor)
+            )
+
+            q_output = gs.Variable(softmax_node.name + "/q_output")
+            dq_output = gs.Variable(softmax_node.name + "/dq_output", dtype=softmax_output.dtype)
+            q_node = gs.Node(
+                op="QuantizeLinear",
+                name=softmax_node.name + "/QuantizeLinear",
+                inputs=[softmax_output, scale_constant, zp_constant],
+                outputs=[q_output],
+                attrs={"saturate": 1},
+            )
+            dq_node = gs.Node(
+                op="DequantizeLinear",
+                name=softmax_node.name + "/DequantizeLinear",
+                inputs=[q_output, dq_scale_constant],
+                outputs=[dq_output],
+            )
+            graph.nodes.extend([q_node, dq_node])
+
+            for consumer in list(softmax_output.outputs):
+                if consumer is q_node:
+                    continue
+                for i, inp in enumerate(consumer.inputs):
+                    if inp is softmax_output:
+                        consumer.inputs[i] = dq_output
+            count += 1
+
+        graph.cleanup().toposort()
+        return count
+
     @staticmethod
     def post_process(onnx_model: onnx.ModelProto) -> onnx.ModelProto:
         """Post-processes the ONNX model for FP8 quantization.
 
-        Converts TRT_FP8 QDQ ops to native ONNX QuantizeLinear/DequantizeLinear:
-        - TRT_FP8QuantizeLinear -> QuantizeLinear with FP8E4M3FN zero_point and saturate=1
-        - TRT_FP8DequantizeLinear -> DequantizeLinear
+        Converts TRT_FP8 QDQ ops to native ONNX QuantizeLinear/DequantizeLinear and
+        rewrites attention scaling / K-transpose / softmax-output patterns so TRT
+        can fuse DQ into the attention MatMul kernels.
 
         Args:
             onnx_model: The ONNX model containing TRT_FP8 quantization nodes.
@@ -144,5 +385,15 @@ def post_process(onnx_model: onnx.ModelProto) -> onnx.ModelProto:
                     f"Converted {node.name} from TRT_FP8DequantizeLinear to DequantizeLinear"
                 )
 
+        # Attention-aware rewrites so TRT can fuse DQ into the attention MatMuls.
+        n_mul = FP8QuantExporter._move_mul_before_qdq(graph)
+        n_t = FP8QuantExporter._move_transpose_before_qdq(graph)
+        n_sm = FP8QuantExporter._insert_qdq_after_softmax(graph)
+        if n_mul or n_t or n_sm:
+            logger.info(
+                f"Attention QDQ rewrites: moved {n_mul} Mul, {n_t} Transpose; "
+                f"inserted QDQ on {n_sm} Softmax outputs"
+            )
+
         graph.cleanup().toposort()
         return gs.export_onnx(graph)

modelopt/onnx/export/fp8_exporter.py

@@ -1415,6 +1415,96 @@ def _bypass_cast_node(model: onnx.ModelProto, node: onnx.NodeProto) -> None:
                     consumer.input[i] = input_tensor
 
 
+_DQ_OPS = {"DequantizeLinear", "TRT_FP8DequantizeLinear"}
+_Q_OPS = {"QuantizeLinear", "TRT_FP8QuantizeLinear"}
+
+
+def _scale_fp32_to_fp16(scale_init: onnx.TensorProto) -> None:
+    """Convert a scalar Q/DQ scale initializer in-place from FP32 to FP16."""
+    import numpy as np
+
+    if scale_init.data_type != onnx.TensorProto.FLOAT:
+        return
+    scale_data = np.frombuffer(scale_init.raw_data, dtype=np.float32)
+    if not scale_data.size:
+        scale_data = np.array(scale_init.float_data, dtype=np.float32)
+    scale_init.data_type = onnx.TensorProto.FLOAT16
+    scale_init.raw_data = scale_data.astype(np.float16).tobytes()
+    del scale_init.float_data[:]
+
+
+def fold_dq_fp32_to_fp16_casts(onnx_model: onnx.ModelProto) -> onnx.ModelProto:
+    """Remove ``DQ → Cast(FP32→FP16)`` patterns inserted by ``convert_float_to_float16``.
+
+    The DQ scale is rewritten to FP16 so DQ natively produces FP16 output, enabling
+    TRT to fuse DQ directly into the downstream compute op.
+    """
+    producer_map = {out: node for node in onnx_model.graph.node for out in node.output}
+    initializers = {init.name: init for init in onnx_model.graph.initializer}
+
+    to_remove = []
+    for node in onnx_model.graph.node:
+        if node.op_type != "Cast":
+            continue
+        cast_to = next((a.i for a in node.attribute if a.name == "to"), None)
+        if cast_to != onnx.TensorProto.FLOAT16:
+            continue
+        producer = producer_map.get(node.input[0])
+        if producer is None or producer.op_type not in _DQ_OPS:
+            continue
+
+        if len(producer.input) >= 2 and producer.input[1] in initializers:
+            _scale_fp32_to_fp16(initializers[producer.input[1]])
+
+        _bypass_cast_node(onnx_model, node)
+        to_remove.append(node)
+
+        for vi in onnx_model.graph.value_info:
+            if vi.name == producer.output[0]:
+                vi.type.tensor_type.elem_type = onnx.TensorProto.FLOAT16
+                break
+
+    logger.debug(f"Folded {len(to_remove)} DQ -> Cast(FP32->FP16) patterns")
+    for node in to_remove:
+        onnx_model.graph.node.remove(node)
+    return onnx_model
+
+
+def fold_q_fp16_to_fp32_casts(onnx_model: onnx.ModelProto) -> onnx.ModelProto:
+    """Remove ``Cast(FP16→FP32) → Q`` patterns inserted by ``convert_float_to_float16``.
+
+    The Q scale is rewritten to FP16 so Q consumes the FP16 graph directly.
+    """
+    consumer_map: dict[str, list[onnx.NodeProto]] = {}
+    for node in onnx_model.graph.node:
+        for inp in node.input:
+            consumer_map.setdefault(inp, []).append(node)
+    initializers = {init.name: init for init in onnx_model.graph.initializer}
+
+    to_remove = []
+    for node in onnx_model.graph.node:
+        if node.op_type != "Cast":
+            continue
+        cast_to = next((a.i for a in node.attribute if a.name == "to"), None)
+        if cast_to != onnx.TensorProto.FLOAT:
+            continue
+        consumers = consumer_map.get(node.output[0], [])
+        if not consumers or not all(c.op_type in _Q_OPS for c in consumers):
+            continue
+
+        for q_node in consumers:
+            if len(q_node.input) >= 2 and q_node.input[1] in initializers:
+                _scale_fp32_to_fp16(initializers[q_node.input[1]])
+
+        _bypass_cast_node(onnx_model, node)
+        to_remove.append(node)
+
+    logger.debug(f"Folded {len(to_remove)} Cast(FP16->FP32) -> Q patterns")
+    for node in to_remove:
+        onnx_model.graph.node.remove(node)
+    return onnx_model
+
+
 def _is_foldable_constant_cast_pattern(model: onnx.ModelProto, node: onnx.NodeProto) -> bool:
     """Check if a Constant -> Cast pattern can be folded."""
     assert node.op_type == "Cast"