From 504a683e852c5c56f43e0f14d4767fcd2aa97740 Mon Sep 17 00:00:00 2001 From: Leopoldo Araujo <68853890+poloaraujo@users.noreply.github.com> Date: Mon, 2 Oct 2023 13:59:00 -0400 Subject: [PATCH] Formatted sources Formatted sources and corrected snapshot_executions --- models/fct_dbt__snapshot_executions.sql | 51 ++++++++++--------- models/sources/exposures.sql | 37 +++++++------- models/sources/invocations.sql | 47 +++++++++-------- models/sources/model_executions.sql | 43 ++++++++-------- models/sources/models.sql | 39 +++++++------- models/sources/seed_executions.sql | 41 ++++++++------- models/sources/seeds.sql | 33 ++++++------ models/sources/snapshot_executions.sql | 41 ++++++++------- models/sources/snapshots.sql | 36 ++++++------- models/sources/sources.sql | 33 ++++++------ models/sources/test_executions.sql | 34 +++++++------ models/sources/tests.sql | 27 +++++----- .../staging/stg_dbt__snapshot_executions.sql | 2 +- 13 files changed, 247 insertions(+), 217 deletions(-) diff --git a/models/fct_dbt__snapshot_executions.sql b/models/fct_dbt__snapshot_executions.sql index bd0957a8..91613db0 100644 --- a/models/fct_dbt__snapshot_executions.sql +++ b/models/fct_dbt__snapshot_executions.sql @@ -1,31 +1,32 @@ -with base as ( +with + base as ( - select * - from {{ ref('stg_dbt__snapshot_executions') }} + select * + from {{ ref('stg_dbt__snapshot_executions') }} -), + ) -snapshot_executions as ( + , snapshot_executions as ( - select - snapshot_execution_id, - command_invocation_id, - node_id, - run_started_at, - was_full_refresh, - thread_id, - status, - compile_started_at, - query_completed_at, - total_node_runtime, - rows_affected, - materialization, - schema, - name, - alias, - message - from base + select + snapshot_execution_id + , command_invocation_id + , node_id + , run_started_at + , was_full_refresh + , thread_id + , status + , compile_started_at + , query_completed_at + , total_node_runtime + , rows_affected + , materialization + , schema + , name + , alias + , message + from base -) + ) -select * from snapshot_executions \ No newline at end of file +select * from snapshot_executions diff --git a/models/sources/exposures.sql b/models/sources/exposures.sql index 9b6e48b3..6d593bcf 100644 --- a/models/sources/exposures.sql +++ b/models/sources/exposures.sql @@ -1,22 +1,25 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_string() }}) as type, - cast(null as {{ type_json() }}) as owner, - cast(null as {{ type_string() }}) as maturity, - cast(null as {{ type_string() }}) as path, - cast(null as {{ type_string() }}) as description, - cast(null as {{ type_string() }}) as url, - cast(null as {{ type_string() }}) as package_name, - cast(null as {{ type_array() }}) as depends_on_nodes, - cast(null as {{ type_array() }}) as tags, - cast(null as {{ type_json() }}) as all_results + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_string() }}) as type + , cast(null as {{ type_json() }}) as owner + , cast(null as {{ type_string() }}) as maturity + , cast(null as {{ type_string() }}) as path + , cast(null as {{ type_string() }}) as description + , cast(null as {{ type_string() }}) as url + , cast(null as {{ type_string() }}) as package_name + , cast(null as {{ type_array() }}) as depends_on_nodes + , cast(null as {{ type_array() }}) as tags + , cast(null as {{ type_json() }}) as all_results from dummy_cte where 1 = 0 diff --git a/models/sources/invocations.sql b/models/sources/invocations.sql index 7cdabf94..d92c8bfb 100644 --- a/models/sources/invocations.sql +++ b/models/sources/invocations.sql @@ -1,27 +1,30 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as dbt_version, - cast(null as {{ type_string() }}) as project_name, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_string() }}) as dbt_command, - cast(null as {{ type_boolean() }}) as full_refresh_flag, - cast(null as {{ type_string() }}) as target_profile_name, - cast(null as {{ type_string() }}) as target_name, - cast(null as {{ type_string() }}) as target_schema, - cast(null as {{ type_int() }}) as target_threads, - cast(null as {{ type_string() }}) as dbt_cloud_project_id, - cast(null as {{ type_string() }}) as dbt_cloud_job_id, - cast(null as {{ type_string() }}) as dbt_cloud_run_id, - cast(null as {{ type_string() }}) as dbt_cloud_run_reason_category, - cast(null as {{ type_string() }}) as dbt_cloud_run_reason, - cast(null as {{ type_json() }}) as env_vars, - cast(null as {{ type_json() }}) as dbt_vars, - cast(null as {{ type_json() }}) as invocation_args, - cast(null as {{ type_json() }}) as dbt_custom_envs + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as dbt_version + , cast(null as {{ type_string() }}) as project_name + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_string() }}) as dbt_command + , cast(null as {{ type_boolean() }}) as full_refresh_flag + , cast(null as {{ type_string() }}) as target_profile_name + , cast(null as {{ type_string() }}) as target_name + , cast(null as {{ type_string() }}) as target_schema + , cast(null as {{ type_int() }}) as target_threads + , cast(null as {{ type_string() }}) as dbt_cloud_project_id + , cast(null as {{ type_string() }}) as dbt_cloud_job_id + , cast(null as {{ type_string() }}) as dbt_cloud_run_id + , cast(null as {{ type_string() }}) as dbt_cloud_run_reason_category + , cast(null as {{ type_string() }}) as dbt_cloud_run_reason + , cast(null as {{ type_json() }}) as env_vars + , cast(null as {{ type_json() }}) as dbt_vars + , cast(null as {{ type_json() }}) as invocation_args + , cast(null as {{ type_json() }}) as dbt_custom_envs from dummy_cte where 1 = 0 diff --git a/models/sources/model_executions.sql b/models/sources/model_executions.sql index 09bec105..14d6c6b2 100644 --- a/models/sources/model_executions.sql +++ b/models/sources/model_executions.sql @@ -1,27 +1,30 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_boolean() }}) as was_full_refresh, - cast(null as {{ type_string() }}) as thread_id, - cast(null as {{ type_string() }}) as status, - 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_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_boolean() }}) as was_full_refresh + , cast(null as {{ type_string() }}) as thread_id + , cast(null as {{ type_string() }}) as status + , 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 {% if target.type == 'bigquery' %} - cast(null as {{ type_int() }}) as bytes_processed, + , cast(null as {{ type_int() }}) as bytes_processed {% endif %} - cast(null as {{ type_string() }}) as materialization, - cast(null as {{ type_string() }}) as schema, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_string() }}) as alias, - cast(null as {{ type_string() }}) as message, - cast(null as {{ type_json() }}) as adapter_response + , cast(null as {{ type_string() }}) as materialization + , cast(null as {{ type_string() }}) as schema + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_string() }}) as alias + , cast(null as {{ type_string() }}) as message + , cast(null as {{ type_json() }}) as adapter_response from dummy_cte where 1 = 0 diff --git a/models/sources/models.sql b/models/sources/models.sql index f4ec8f01..debeaf05 100644 --- a/models/sources/models.sql +++ b/models/sources/models.sql @@ -1,23 +1,26 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_string() }}) as database, - cast(null as {{ type_string() }}) as schema, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_array() }}) as depends_on_nodes, - cast(null as {{ type_string() }}) as package_name, - cast(null as {{ type_string() }}) as path, - cast(null as {{ type_string() }}) as checksum, - cast(null as {{ type_string() }}) as materialization, - cast(null as {{ type_array() }}) as tags, - cast(null as {{ type_json() }}) as meta, - cast(null as {{ type_string() }}) as alias, - cast(null as {{ type_json() }}) as all_results + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_string() }}) as database + , cast(null as {{ type_string() }}) as schema + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_array() }}) as depends_on_nodes + , cast(null as {{ type_string() }}) as package_name + , cast(null as {{ type_string() }}) as path + , cast(null as {{ type_string() }}) as checksum + , cast(null as {{ type_string() }}) as materialization + , cast(null as {{ type_array() }}) as tags + , cast(null as {{ type_json() }}) as meta + , cast(null as {{ type_string() }}) as alias + , cast(null as {{ type_json() }}) as all_results from dummy_cte where 1 = 0 diff --git a/models/sources/seed_executions.sql b/models/sources/seed_executions.sql index dbb93977..6d9aee35 100644 --- a/models/sources/seed_executions.sql +++ b/models/sources/seed_executions.sql @@ -1,24 +1,27 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_boolean() }}) as was_full_refresh, - cast(null as {{ type_string() }}) as thread_id, - cast(null as {{ type_string() }}) as status, - 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_string() }}) as materialization, - cast(null as {{ type_string() }}) as schema, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_string() }}) as alias, - cast(null as {{ type_string() }}) as message, - cast(null as {{ type_json() }}) as adapter_response + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_boolean() }}) as was_full_refresh + , cast(null as {{ type_string() }}) as thread_id + , cast(null as {{ type_string() }}) as status + , 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_string() }}) as materialization + , cast(null as {{ type_string() }}) as schema + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_string() }}) as alias + , cast(null as {{ type_string() }}) as message + , cast(null as {{ type_json() }}) as adapter_responss from dummy_cte where 1 = 0 diff --git a/models/sources/seeds.sql b/models/sources/seeds.sql index 7c52ecf7..3c99ef01 100644 --- a/models/sources/seeds.sql +++ b/models/sources/seeds.sql @@ -1,20 +1,23 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_string() }}) as database, - cast(null as {{ type_string() }}) as schema, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_string() }}) as package_name, - cast(null as {{ type_string() }}) as path, - cast(null as {{ type_string() }}) as checksum, - cast(null as {{ type_json() }}) as meta, - cast(null as {{ type_string() }}) as alias, - cast(null as {{ type_json() }}) as all_results + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_string() }}) as database + , cast(null as {{ type_string() }}) as schema + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_string() }}) as package_name + , cast(null as {{ type_string() }}) as path + , cast(null as {{ type_string() }}) as checksum + , cast(null as {{ type_json() }}) as meta + , cast(null as {{ type_string() }}) as alias + , cast(null as {{ type_json() }}) as all_results from dummy_cte where 1 = 0 diff --git a/models/sources/snapshot_executions.sql b/models/sources/snapshot_executions.sql index dbb93977..c3e9465d 100644 --- a/models/sources/snapshot_executions.sql +++ b/models/sources/snapshot_executions.sql @@ -1,24 +1,27 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_boolean() }}) as was_full_refresh, - cast(null as {{ type_string() }}) as thread_id, - cast(null as {{ type_string() }}) as status, - 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_string() }}) as materialization, - cast(null as {{ type_string() }}) as schema, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_string() }}) as alias, - cast(null as {{ type_string() }}) as message, - cast(null as {{ type_json() }}) as adapter_response + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_boolean() }}) as was_full_refresh + , cast(null as {{ type_string() }}) as thread_id + , cast(null as {{ type_string() }}) as status + , 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_string() }}) as materialization + , cast(null as {{ type_string() }}) as schema + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_string() }}) as alias + , cast(null as {{ type_string() }}) as message + , cast(null as {{ type_json() }}) as adapter_response from dummy_cte where 1 = 0 diff --git a/models/sources/snapshots.sql b/models/sources/snapshots.sql index e7832de6..c47ef812 100644 --- a/models/sources/snapshots.sql +++ b/models/sources/snapshots.sql @@ -1,22 +1,24 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_string() }}) as database, - cast(null as {{ type_string() }}) as schema, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_array() }}) as depends_on_nodes, - cast(null as {{ type_string() }}) as package_name, - cast(null as {{ type_string() }}) as path, - cast(null as {{ type_string() }}) as checksum, - cast(null as {{ type_string() }}) as strategy, - cast(null as {{ type_json() }}) as meta, - cast(null as {{ type_string() }}) as alias, - cast(null as {{ type_json() }}) as all_results + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_string() }}) as database + , cast(null as {{ type_string() }}) as schema + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_array() }}) as depends_on_nodes + , cast(null as {{ type_string() }}) as package_name + , cast(null as {{ type_string() }}) as path + , cast(null as {{ type_string() }}) as checksum + , cast(null as {{ type_string() }}) as strategy + , cast(null as {{ type_json() }}) as meta + , cast(null as {{ type_string() }}) as alias + , cast(null as {{ type_json() }}) as all_results from dummy_cte where 1 = 0 diff --git a/models/sources/sources.sql b/models/sources/sources.sql index ad08f0d7..d152ad22 100644 --- a/models/sources/sources.sql +++ b/models/sources/sources.sql @@ -1,24 +1,25 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + select 1 as foo + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_string() }}) as database, - cast(null as {{ type_string() }}) as schema, - cast(null as {{ type_string() }}) as source_name, - cast(null as {{ type_string() }}) as loader, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_string() }}) as identifier, - cast(null as {{ type_string() }}) as loaded_at_field, + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_string() }}) as database + , cast(null as {{ type_string() }}) as schema + , cast(null as {{ type_string() }}) as source_name + , cast(null as {{ type_string() }}) as loader + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_string() }}) as identifier + , cast(null as {{ type_string() }}) as loaded_at_field {% if target.type == 'snowflake' %} - cast(null as {{ type_array() }}) as freshness, + , cast(null as {{ type_array() }}) as freshness {% else %} - cast(null as {{ type_json() }}) as freshness, + , cast(null as {{ type_json() }}) as freshness {% endif %} - cast(null as {{ type_json() }}) as all_results + , cast(null as {{ type_json() }}) as all_results from dummy_cte where 1 = 0 diff --git a/models/sources/test_executions.sql b/models/sources/test_executions.sql index 50d37980..c7d59121 100644 --- a/models/sources/test_executions.sql +++ b/models/sources/test_executions.sql @@ -1,21 +1,23 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_boolean() }}) as was_full_refresh, - cast(null as {{ type_string() }}) as thread_id, - cast(null as {{ type_string() }}) as status, - 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 + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_boolean() }}) as was_full_refresh + , cast(null as {{ type_string() }}) as thread_id + , cast(null as {{ type_string() }}) as status + , 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 from dummy_cte where 1 = 0 diff --git a/models/sources/tests.sql b/models/sources/tests.sql index 1a4b5d9d..d46ed1dc 100644 --- a/models/sources/tests.sql +++ b/models/sources/tests.sql @@ -1,17 +1,20 @@ /* Bigquery won't let us `where` without `from` so we use this workaround */ -with dummy_cte as ( - select 1 as foo -) +with + dummy_cte as ( + + select 1 as foo + + ) select - cast(null as {{ type_string() }}) as command_invocation_id, - cast(null as {{ type_string() }}) as node_id, - cast(null as {{ type_timestamp() }}) as run_started_at, - cast(null as {{ type_string() }}) as name, - cast(null as {{ type_array() }}) as depends_on_nodes, - cast(null as {{ type_string() }}) as package_name, - cast(null as {{ type_string() }}) as test_path, - cast(null as {{ type_array() }}) as tags, - cast(null as {{ type_json() }}) as all_results + cast(null as {{ type_string() }}) as command_invocation_id + , cast(null as {{ type_string() }}) as node_id + , cast(null as {{ type_timestamp() }}) as run_started_at + , cast(null as {{ type_string() }}) as name + , cast(null as {{ type_array() }}) as depends_on_nodes + , cast(null as {{ type_string() }}) as package_name + , cast(null as {{ type_string() }}) as test_path + , cast(null as {{ type_array() }}) as tags + , cast(null as {{ type_json() }}) as all_results from dummy_cte where 1 = 0 diff --git a/models/staging/stg_dbt__snapshot_executions.sql b/models/staging/stg_dbt__snapshot_executions.sql index 207e7691..5818133d 100644 --- a/models/staging/stg_dbt__snapshot_executions.sql +++ b/models/staging/stg_dbt__snapshot_executions.sql @@ -9,7 +9,7 @@ with , enhanced as ( select - , {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as snapshot_execution_id + {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as snapshot_execution_id , command_invocation_id , node_id , run_started_at