Allow override of process_run_result

dbt-labs · Oct 31, 2024 · b27655c · b27655c
1 parent aaab488
commit b27655c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/dbt/artifacts/schemas/run/v5/run.py b/core/dbt/artifacts/schemas/run/v5/run.py
@@ -132,7 +132,7 @@ def from_execution_results(
         args: Dict,
     ):
         processed_results = [
-            process_run_result(result) for result in results if isinstance(result, RunResult)
+            cls._process_run_result(result) for result in results if isinstance(result, RunResult)
         ]
         meta = RunResultsMetadata(
             dbt_schema_version=str(cls.dbt_schema_version),
@@ -182,5 +182,9 @@ def upgrade_schema_version(cls, data):
                 result["relation_name"] = ""
         return cls.from_dict(data)
 
+    @classmethod
+    def _process_run_result(cls, result: RunResult) -> RunResultOutput:
+        return process_run_result(result)
+
     def write(self, path: str):
         write_json(path, self.to_dict(omit_none=False))