Revert "Remove unused rows_affected column in test_executions #195"

This reverts commit 9182fdc.

macros/upload_individual_datasets/upload_test_executions.sql

@@ -17,7 +17,8 @@
             {{ adapter.dispatch('column_identifier', 'dbt_artifacts')(9) }},
             {{ adapter.dispatch('column_identifier', 'dbt_artifacts')(10) }},
             {{ adapter.dispatch('column_identifier', 'dbt_artifacts')(11) }},
-            {{ adapter.dispatch('parse_json', 'dbt_artifacts')(adapter.dispatch('column_identifier', 'dbt_artifacts')(12)) }}
+            {{ adapter.dispatch('column_identifier', 'dbt_artifacts')(12) }},
+            {{ adapter.dispatch('parse_json', 'dbt_artifacts')(adapter.dispatch('column_identifier', 'dbt_artifacts')(13)) }}
         from values
         {% for test in tests -%}
             (
@@ -56,6 +57,7 @@
                 {% endif %}
 
                 {{ test.execution_time }}, {# total_node_runtime #}
+                null, {# rows_affected not available in Databricks #}
                 {{ 'null' if test.failures is none else test.failures }}, {# failures #}
                 '{{ test.message | replace("\\", "\\\\") | replace("'", "\\'") | replace('"', '\\"') }}', {# message #}
                 '{{ tojson(test.adapter_response) | replace("\\", "\\\\") | replace("'", "\\'") | replace('"', '\\"') }}' {# adapter_response #}
@@ -109,6 +111,7 @@
                 {% endif %}
 
                 {{ test.execution_time }}, {# total_node_runtime #}
+                null, {# rows_affected not available in Databricks #}
                 {{ 'null' if test.failures is none else test.failures }}, {# failures #}
                 '{{ test.message | replace("\\", "\\\\") | replace("'", "\\'") | replace('"', '\\"') | replace("\n", "\\n") }}', {# message #}
                 {{ adapter.dispatch('parse_json', 'dbt_artifacts')(tojson(test.adapter_response) | replace("\\", "\\\\") | replace("'", "\\'") | replace('"', '\\"')) }} {# adapter_response #}

macros/upload_results/get_column_name_lists.sql

@@ -211,6 +211,7 @@
             compile_started_at,
             query_completed_at,
             total_node_runtime,
+            rows_affected,
             failures,
             message,
             adapter_response

models/fct_dbt__test_executions.sql

@@ -18,6 +18,7 @@ test_executions as (
         compile_started_at,
         query_completed_at,
         total_node_runtime,
+        rows_affected,
         failures,
         message
     from base

models/fct_dbt__test_executions.yml

@@ -14,6 +14,8 @@ models:
         description: '{{ doc("node_id") }}'
       - name: query_completed_at
         description: '{{ doc("query_completed_at") }}'
+      - name: rows_affected
+        description: '{{ doc("rows_affected") }}'
       - name: status
         description: '{{ doc("status") }}'
       - name: test_execution_id

models/sources/test_executions.sql

@@ -13,6 +13,7 @@ select
     cast(null as {{ type_timestamp() }}) as compile_started_at,
     cast(null as {{ type_timestamp() }}) as query_completed_at,
     cast(null as {{ type_float() }}) as total_node_runtime,
+    cast(null as {{ type_int() }}) as rows_affected,
     cast(null as {{ type_int() }}) as failures,
     cast(null as {{ type_string() }}) as message,
     cast(null as {{ type_json() }}) as adapter_response

models/sources/test_executions.yml

@@ -22,6 +22,8 @@ models:
         description: '{{ doc("query_completed_at") }}'
       - name: total_node_runtime
         description: '{{ doc("total_node_runtime") }}'
+      - name: rows_affected
+        description: '{{ doc("rows_affected") }}'
       - name: failures
         description: '{{ doc("failures") }}'
       - name: message

models/staging/stg_dbt__test_executions.sql

@@ -18,6 +18,7 @@ enhanced as (
         compile_started_at,
         query_completed_at,
         total_node_runtime,
+        rows_affected,
         failures,
         message
     from base

models/staging/stg_dbt__test_executions.yml

@@ -14,6 +14,8 @@ models:
         description: '{{ doc("node_id") }}'
       - name: query_completed_at
         description: '{{ doc("query_completed_at") }}'
+      - name: rows_affected
+        description: '{{ doc("rows_affected") }}'
       - name: run_started_at
         description: '{{ doc("run_started_at") }}'
       - name: status