diff --git a/macros/edr/tests/on_run_end/handle_tests_results.sql b/macros/edr/tests/on_run_end/handle_tests_results.sql index 002d40d39..b41114080 100644 --- a/macros/edr/tests/on_run_end/handle_tests_results.sql +++ b/macros/edr/tests/on_run_end/handle_tests_results.sql @@ -220,7 +220,7 @@ {%- do elementary.edr_create_table_as( true, temp_relation, test_tables_union_query ) %} - {% do elementary.run_query(insert_query) %} + {% do elementary.execute_no_fetch(insert_query) %} {# DuckDB: commit so insert survives dbt's post-on-run-end ROLLBACK #} {% if target.type == "duckdb" %} {% do adapter.commit() %} {% endif %} @@ -280,7 +280,7 @@ {%- do elementary.edr_create_table_as( true, temp_relation, test_tables_union_query ) %} - {% do elementary.run_query(insert_query) %} + {% do elementary.execute_no_fetch(insert_query) %} {# DuckDB: commit so insert survives dbt's post-on-run-end ROLLBACK #} {% if target.type == "duckdb" %} {% do adapter.commit() %} {% endif %} diff --git a/macros/utils/run_queries/run_query.sql b/macros/utils/run_queries/run_query.sql index 500e453a2..1bf356b11 100644 --- a/macros/utils/run_queries/run_query.sql +++ b/macros/utils/run_queries/run_query.sql @@ -11,6 +11,12 @@ {% do return(query_result) %} {% endmacro %} +{# Execute without fetching a result set. Use this for DML/DDL whose callers + discard the result; dbt.run_query always fetches. #} +{% macro execute_no_fetch(query) %} + {% do adapter.execute(elementary.format_query_with_metadata(query), fetch=false) %} +{% endmacro %} + {% macro format_query_with_metadata(query) %} {% do return( adapter.dispatch("format_query_with_metadata", "elementary")(query) diff --git a/macros/utils/table_operations/insert_rows.sql b/macros/utils/table_operations/insert_rows.sql index 43c6999a2..035fa7056 100644 --- a/macros/utils/table_operations/insert_rows.sql +++ b/macros/utils/table_operations/insert_rows.sql @@ -69,7 +69,7 @@ "[{}/{}] Running insert query.".format(loop.index, queries_len) ) %} {% do elementary.begin_duration_measure_context("run_insert_rows_query") %} - {% do elementary.run_query(insert_query) %} + {% do elementary.execute_no_fetch(insert_query) %} {% do elementary.end_duration_measure_context("run_insert_rows_query") %} {% endfor %}