Turn inliner into a pass and use it in rewriter & optimizer (microsoft#2149)

Use passes in optimizer and rewriter.

1. By opting into using the pass infra early, we get the benefit of
getting the additional features in pass infra w/o having to pay higher
refactoring cost in the future. We will be able to add more
sophisticated debug utilities/snapshot capabilities etc. to the passes.
2. Since we are offering the pass infra to users, we can start
validating it internally by using it here. If order altering becomes a
valid use case we can expect users may need that and we can create
appropriate facilities to support the usage.

Author: justinchuby

onnxscript/optimizer/_inliner.py

@@ -47,7 +47,7 @@ class _CopyReplace:
 
     def __init__(
         self,
-        inliner: _Inliner,
+        inliner: InlinePass,
         attr_map: dict[str, ir.Attr | ir.RefAttr],
         value_map: dict[ir.Value, ir.Value | None],
         metadata_props: dict[str, str],
@@ -188,15 +188,29 @@ def id_abbreviation(id: ir.OperatorIdentifier) -> str:
     return {id: id_abbreviation(id) for id in function_ids}
 
 
-class _Inliner:
-    def __init__(self, model: ir.Model) -> None:
-        self._functions = model.functions
-        self._function_id_abbreviations = _abbreviate(self._functions.keys())
-        self._opset_imports = model.opset_imports
+class InlinePass(ir.passes.InPlacePass):
+    def __init__(self) -> None:
+        self._functions: dict[ir.OperatorIdentifier, ir.Function] = {}
+        self._function_id_abbreviations: dict[ir.OperatorIdentifier, str] = {}
+        self._opset_imports: dict[str, int] = {}
         self.used_value_names: set[str] = set()
         self.used_node_names: set[str] = set()
         self.node_context: dict[ir.Node, CallStack] = {}
 
+    def _reset(self, model: ir.Model) -> None:
+        self._functions = model.functions
+        self._function_id_abbreviations = _abbreviate(self._functions.keys())
+        self._opset_imports = model.opset_imports
+        self.used_value_names = set()
+        self.used_node_names = set()
+        self.node_context = {}
+
+    def call(self, model: ir.Model) -> ir.passes.PassResult:
+        self._reset(model)
+        modified = self.inline_calls_in(model.graph)
+        model.functions.clear()
+        return ir.passes.PassResult(model, modified)
+
     def _instantiate_call(self, node: ir.Node, call_site_id: CallSiteId) -> NodeReplacement:
         id = node.op_identifier()
         function = self._functions[id]
@@ -249,7 +263,7 @@ def _instantiate_call(self, node: ir.Node, call_site_id: CallSiteId) -> NodeRepl
         output_values = [value_map[output] for output in function.outputs]
         return nodes, output_values  # type: ignore
 
-    def inline_calls_in(self, graph: ir.Graph) -> None:
+    def inline_calls_in(self, graph: ir.Graph) -> bool:
         for input in graph.inputs:
             if input.name is not None:
                 self.used_value_names.add(input.name)
@@ -302,11 +316,10 @@ def inline_calls_in(self, graph: ir.Graph) -> None:
                     elif attr.type == ir.AttributeType.GRAPHS:
                         for graph in attr.as_graphs():
                             self.inline_calls_in(graph)
+        return bool(id_count)
 
 
 def inline(model: ir.Model) -> None:
     """Inline all function calls (recursively) in the model."""
     if model.functions:
-        inliner = _Inliner(model)
-        inliner.inline_calls_in(model.graph)
-        model.functions.clear()
+        InlinePass()(model)

onnxscript/optimizer/_optimizer.py

@@ -4,6 +4,7 @@
 
 import logging
 
+import onnxscript.ir.passes.common.unused_removal
 import onnxscript.optimizer
 from onnxscript import ir, rewriter
 from onnxscript.optimizer import _constant_folding, _inliner
@@ -50,15 +51,26 @@ def optimize_ir(
         stop_if_no_change: Not supported currently (has no effect). Meant to stop the
             outer optimization loop if no change is detected in one iteration.
     """
-    del stop_if_no_change  # Looks like rewriter doesn't support this yet.
-    # TODO(justinchuby): Update this to use a pass manager
-    _inliner.inline(model)
-    for _ in range(num_iterations):
-        _constant_folding.fold_constants(
-            model,
-            onnx_shape_inference=onnx_shape_inference,
-            input_size_limit=input_size_limit,
-            output_size_limit=output_size_limit,
-        )
-        rewriter.rewrite(model, pattern_rewrite_rules=_DEFAULT_REWRITE_RULES)
-    onnxscript.optimizer.remove_unused_nodes(model)
+    optimizer_pass = ir.passes.Sequential(
+        _inliner.InlinePass(),
+        ir.passes.PassManager(
+            [
+                _constant_folding.FoldConstantsPass(
+                    external_data_folder="",
+                    shape_inference=onnx_shape_inference,
+                    input_size_limit=input_size_limit,
+                    output_size_limit=output_size_limit,
+                ),
+                rewriter.RewritePass(_DEFAULT_REWRITE_RULES),
+                onnxscript.ir.passes.common.unused_removal.RemoveUnusedNodesPass(),
+                onnxscript.ir.passes.common.unused_removal.RemoveUnusedFunctionsPass(),
+                onnxscript.ir.passes.common.unused_removal.RemoveUnusedOpsetsPass(),
+            ],
+            steps=num_iterations,
+            early_stop=stop_if_no_change,
+        ),
+        onnxscript.ir.passes.common.unused_removal.RemoveUnusedNodesPass(),
+    )
+    assert optimizer_pass.in_place
+    result = optimizer_pass(model)
+    assert result.model is model

onnxscript/rewriter/__init__.py

@@ -18,13 +18,31 @@
 from onnxscript.optimizer import _remove_unused, _remove_unused_function
 from onnxscript.rewriter import function_rule, pattern
 
-RewriteRuleSet = pattern.RewriteRuleSet
 PatternRewriteRule = pattern.RewriteRule
 FunctionRewriteRule = function_rule.FunctionRewriteRule
 
 ModelProtoOrIr = TypeVar("ModelProtoOrIr", onnx.ModelProto, ir.Model)
 
 
+class RewritePass(ir.passes.InPlacePass):
+    def __init__(
+        self,
+        pattern_rewrite_rules: Sequence[PatternRewriteRule] | pattern.RewriteRuleSet = (),
+    ) -> None:
+        if pattern_rewrite_rules:
+            if not isinstance(pattern_rewrite_rules, pattern.RewriteRuleSet):
+                # Create a pattern rule-set using provided rules
+                pattern_rewrite_rules = pattern.RewriteRuleSet(pattern_rewrite_rules)
+        assert isinstance(pattern_rewrite_rules, pattern.RewriteRuleSet)
+        self.pattern_rewrite_rules: pattern.RewriteRuleSet = pattern_rewrite_rules
+
+    def call(self, model: ir.Model) -> ir.passes.PassResult:
+        count = self.pattern_rewrite_rules.apply_to_model(model)
+        if count:
+            print(f"Applied {count} of general pattern rewrite rules.")
+        return ir.passes.PassResult(model, bool(count))
+
+
 def rewrite(
     model: ModelProtoOrIr,
     function_rewrite_rules: Sequence[type[FunctionRewriteRule]] = (),
@@ -50,12 +68,13 @@ def rewrite(
             print(f"Applied {count} of general pattern rewrite rules.")
     unused_remover = ir.passes.PassManager(
         (
+            RewritePass(pattern_rewrite_rules),
             unused_removal.RemoveUnusedNodesPass(),
             unused_removal.RemoveUnusedFunctionsPass(),
             unused_removal.RemoveUnusedOpsetsPass(),
         )
     )
-    model_ir = unused_remover(model_ir).model
+    model_ir = rewrite_pass(model_ir).model
     if proto:
         return ir.serde.serialize_model(model_ir)
     return model_ir  # type: ignore[return-value]