Safe cast field to INT to avoid failure on casting error (#217)

brooklyn-data · Oct 8, 2022 · 34b5936 · 34b5936
1 parent 781a8f8
commit 34b5936
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/macros/upload_model_executions.sql b/macros/upload_model_executions.sql
@@ -187,7 +187,7 @@
                 {% endif %}
 
                 {{ model.execution_time }}, {# total_node_runtime #}
-                '{{ model.adapter_response.rows_affected }}', {# rows_affected #}
+                try_cast('{{ model.adapter_response.rows_affected }}' as int), {# rows_affected #}
                 '{{ model.node.config.materialized }}', {# materialization #}
                 '{{ model.node.schema }}', {# schema #}
                 '{{ model.node.name }}' {# name #}

diff --git a/macros/upload_seed_executions.sql b/macros/upload_seed_executions.sql
@@ -186,7 +186,7 @@
                 {% endif %}
 
                 {{ model.execution_time }}, {# total_node_runtime #}
-                '{{ model.adapter_response.rows_affected }}', {# rows_affected #}
+                try_cast('{{ model.adapter_response.rows_affected }}' as int), {# rows_affected #}
                 '{{ model.node.config.materialized }}', {# materialization #}
                 '{{ model.node.schema }}', {# schema #}
                 '{{ model.node.name }}' {# name #}

diff --git a/macros/upload_snapshot_executions.sql b/macros/upload_snapshot_executions.sql
@@ -186,7 +186,7 @@
                 {% endif %}
 
                 {{ model.execution_time }}, {# total_node_runtime #}
-                '{{ model.adapter_response.rows_affected }}', {# rows_affected #}
+                try_cast('{{ model.adapter_response.rows_affected }}' as int), {# rows_affected #}
                 '{{ model.node.config.materialized }}', {# materialization #}
                 '{{ model.node.schema }}', {# schema #}
                 '{{ model.node.name }}' {# name #}