diff --git a/macros/commands/dump_table.sql b/macros/commands/dump_table.sql index 77bbbaee9..fcd1eee9e 100644 --- a/macros/commands/dump_table.sql +++ b/macros/commands/dump_table.sql @@ -17,7 +17,7 @@ {% set column_names = column_names | reject("in", deprecated_column_names) | list %} {% endif %} - {% set dedup_by_column = node.meta.id_column or "unique_id" %} + {% set dedup_by_column = node.meta.dedup_by_column or "unique_id" %} {% set order_by_dedup_column = "generated_at" %} {% set query %} {% if dedup and (dedup_by_column in column_names) and (order_by_dedup_column in column_names) %} diff --git a/models/edr/dbt_artifacts/dbt_run_results.sql b/models/edr/dbt_artifacts/dbt_run_results.sql index cdf7d7da6..f84e8267c 100644 --- a/models/edr/dbt_artifacts/dbt_run_results.sql +++ b/models/edr/dbt_artifacts/dbt_run_results.sql @@ -6,7 +6,7 @@ on_schema_change = 'append_new_columns', full_refresh=elementary.get_config_var('elementary_full_refresh'), meta={ - "id_column": "model_execution_id", + "dedup_by_column": "model_execution_id", "timestamp_column": "created_at", "prev_timestamp_column": "generated_at", }