Put back report_node_data in fresshness.py

dbt-labs · Dec 3, 2021 · 791564a · 791564a
1 parent e2a2753
commit 791564a
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/core/dbt/task/freshness.py b/core/dbt/task/freshness.py
@@ -59,7 +59,8 @@ def after_execute(self, result):
                     table_name=table_name,
                     index=self.node_index,
                     total=self.num_nodes,
-                    execution_time=result.execution_time
+                    execution_time=result.execution_time,
+                    report_node_data=self.node
                 )
             )
         elif result.status == FreshnessStatus.Error:
@@ -69,7 +70,8 @@ def after_execute(self, result):
                     table_name=table_name,
                     index=self.node_index,
                     total=self.num_nodes,
-                    execution_time=result.execution_time
+                    execution_time=result.execution_time,
+                    report_node_data=self.node
                 )
             )
         elif result.status == FreshnessStatus.Warn:
@@ -79,7 +81,8 @@ def after_execute(self, result):
                     table_name=table_name,
                     index=self.node_index,
                     total=self.num_nodes,
-                    execution_time=result.execution_time
+                    execution_time=result.execution_time,
+                    report_node_data=self.node
                 )
             )
         else:
@@ -89,7 +92,8 @@ def after_execute(self, result):
                     table_name=table_name,
                     index=self.node_index,
                     total=self.num_nodes,
-                    execution_time=result.execution_time
+                    execution_time=result.execution_time,
+                    report_node_data=self.node
                 )
             )