Update to latest surrogate key macro

macros/generate_surrogate_key.sql

@@ -0,0 +1,41 @@
+{#
+    Since folks commonly install dbt_artifacts alongside a myriad of other packages,
+    we copy the dbt_utils implementation of the surrogate_key macro so we don't have
+    any dependencies to make conflicts worse!
+
+    This version is:
+    URL: https://github.com/dbt-labs/dbt-utils/blob/main/macros/sql/generate_surrogate_key.sql
+    Commit SHA: eaa0e41b033bdf252eff0ae014ec11888f37ebff
+    Date: 2023-04-28
+#}
+
+{%- macro generate_surrogate_key(field_list) -%}
+    {# Note - update the reference to `dbt_utils` to `dbt_artifacts` here #}
+    {{ return(adapter.dispatch('generate_surrogate_key', 'dbt_artifacts')(field_list)) }}
+{% endmacro %}
+
+{%- macro default__generate_surrogate_key(field_list) -%}
+
+{%- if var('surrogate_key_treat_nulls_as_empty_strings', False) -%}
+    {%- set default_null_value = "" -%}
+{%- else -%}
+    {%- set default_null_value = '_dbt_utils_surrogate_key_null_' -%}
+{%- endif -%}
+
+{%- set fields = [] -%}
+
+{%- for field in field_list -%}
+
+    {%- do fields.append(
+        "coalesce(cast(" ~ field ~ " as " ~ dbt.type_string() ~ "), '" ~ default_null_value  ~"')"
+    ) -%}
+
+    {%- if not loop.last %}
+        {%- do fields.append("'-'") -%}
+    {%- endif -%}
+
+{%- endfor -%}
+
+{{ dbt.hash(dbt.concat(fields)) }}
+
+{%- endmacro -%}

models/staging/stg_dbt__exposures.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.surrogate_key(['command_invocation_id', 'node_id']) }} as exposure_execution_id,
+        {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as exposure_execution_id,
         command_invocation_id,
         node_id,
         run_started_at,

models/staging/stg_dbt__model_executions.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.surrogate_key(['command_invocation_id', 'node_id']) }} as model_execution_id,
+        {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as model_execution_id,
         command_invocation_id,
         node_id,
         run_started_at,

models/staging/stg_dbt__models.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.surrogate_key(['command_invocation_id', 'node_id']) }} as model_execution_id,
+        {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as model_execution_id,
         command_invocation_id,
         node_id,
         run_started_at,

models/staging/stg_dbt__seed_executions.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.surrogate_key(['command_invocation_id', 'node_id']) }} as seed_execution_id,
+        {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as seed_execution_id,
         command_invocation_id,
         node_id,
         run_started_at,

models/staging/stg_dbt__seeds.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.surrogate_key(['command_invocation_id', 'node_id']) }} as seed_execution_id,
+        {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as seed_execution_id,
         command_invocation_id,
         node_id,
         run_started_at,

models/staging/stg_dbt__snapshot_executions.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.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,

models/staging/stg_dbt__snapshots.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.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,

models/staging/stg_dbt__sources.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.surrogate_key(['command_invocation_id', 'node_id']) }} as source_execution_id,
+        {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as source_execution_id,
         command_invocation_id,
         node_id,
         run_started_at,

models/staging/stg_dbt__test_executions.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.surrogate_key(['command_invocation_id', 'node_id']) }} as test_execution_id,
+        {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as test_execution_id,
         command_invocation_id,
         node_id,
         run_started_at,

models/staging/stg_dbt__tests.sql

@@ -8,7 +8,7 @@ with base as (
 enhanced as (
 
     select
-        {{ dbt_artifacts.surrogate_key(['command_invocation_id', 'node_id']) }} as test_execution_id,
+        {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as test_execution_id,
         command_invocation_id,
         node_id,
         run_started_at,