Use SourceFreshnessRuntimeError

core/dbt/artifacts/schemas/freshness/v3/freshness.py

@@ -18,7 +18,7 @@
     BaseArtifactMetadata,
 )
 from dbt_common.dataclass_schema import dbtClassMixin, StrEnum
-from dbt_common.exceptions import DbtInternalError, DbtRuntimeError
+from dbt_common.exceptions import DbtInternalError
 
 from dbt.contracts.graph.nodes import SourceDefinition
 
@@ -94,7 +94,7 @@ class FreshnessErrorEnum(StrEnum):
 
 @dataclass
 class SourceFreshnessRuntimeError(dbtClassMixin):
-    unique_id: str
+    unique_id: Optional[str]
     error: Optional[Union[str, int]]
     status: FreshnessErrorEnum
 
@@ -114,11 +114,6 @@ class FreshnessExecutionResultArtifact(
 
     @classmethod
     def from_result(cls, base: FreshnessResult):
-        # Raise an error if a hook failed
-        for r in base.results:
-            if isinstance(r, BaseResult) and r.status == RunStatus.Error:
-                raise DbtRuntimeError(r.message)
-
         processed = [process_freshness_result(r) for r in base.results]
         return cls(
             metadata=base.metadata,
@@ -128,7 +123,15 @@ def from_result(cls, base: FreshnessResult):
 
 
 def process_freshness_result(result: FreshnessNodeResult) -> FreshnessNodeOutput:
+    if isinstance(result, BaseResult) and result.status == RunStatus.Error:
+        return SourceFreshnessRuntimeError(
+            unique_id=None,
+            error=result.message + "foobar",
+            status=FreshnessErrorEnum.runtime_error,
+        )
+
     unique_id = result.node.unique_id
+
     if result.status == FreshnessStatus.RuntimeErr:
         return SourceFreshnessRuntimeError(
             unique_id=unique_id,