From 41dd67440bc4d74f977688f1401eefc652eeb1ee Mon Sep 17 00:00:00 2001
From: liangwr <liangwr@chinatelecom.cn>
Date: Mon, 15 Sep 2025 11:06:55 +0800
Subject: [PATCH] fix(postgres): populate rows_affected for all models in
 fct_dbt__model_executions

Resolves persistent NULL values in rows_affected column across all model execution records on Postgres.
---
 .../upload_individual_datasets/upload_model_executions.sql  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/macros/upload_individual_datasets/upload_model_executions.sql b/macros/upload_individual_datasets/upload_model_executions.sql
index 231f036e..928c8392 100644
--- a/macros/upload_individual_datasets/upload_model_executions.sql
+++ b/macros/upload_individual_datasets/upload_model_executions.sql
@@ -184,7 +184,11 @@
                 {% if query_completed_at %}'{{ query_completed_at }}'{% else %}null{% endif %}, {# query_completed_at #}
 
                 {{ model.execution_time }}, {# total_node_runtime #}
-                null, {# rows_affected #}
+                {% if model.adapter_response.rows_affected is none or model.adapter_response.rows_affected is not defined %}  
+                    null,
+                {% else %}  
+                    {{ model.adapter_response.rows_affected }},
+                {% endif %} {# rows_affected #}
                 '{{ model.node.config.materialized }}', {# materialization #}
                 '{{ model.node.schema }}', {# schema #}
                 '{{ model.node.name }}', {# name #}