diff --git a/models/gold/core/core__dim_assets.sql b/models/gold/core/core__dim_assets.sql index 4b3dae2..fa90615 100644 --- a/models/gold/core/core__dim_assets.sql +++ b/models/gold/core/core__dim_assets.sql @@ -1,7 +1,7 @@ -- depends_on: {{ ref('silver__assets') }} {{ config( materialized = 'incremental', - unique_key = ['asset_id'], + unique_key = ["asset_issuer","asset_code"], incremental_strategy = 'merge', merge_exclude_columns = ['inserted_timestamp'], post_hook = "ALTER TABLE {{ this }} ADD SEARCH OPTIMIZATION ON EQUALITY(asset_code,asset_issuer,asset_id);", diff --git a/models/silver/core/silver__assets.sql b/models/silver/core/silver__assets.sql index 4006d4e..702b743 100644 --- a/models/silver/core/silver__assets.sql +++ b/models/silver/core/silver__assets.sql @@ -1,7 +1,7 @@ -- depends_on: {{ ref('bronze__assets') }} {{ config( materialized = 'incremental', - unique_key = "asset_id", + unique_key = ["asset_issuer","asset_code"], incremental_predicates = ["dynamic_range_predicate", "partition_id::date"], merge_exclude_columns = ["inserted_timestamp"], cluster_by = ['partition_id','modified_timestamp::DATE'], @@ -60,7 +60,8 @@ WHERE {% endif %} qualify ROW_NUMBER() over ( - PARTITION BY asset_id + PARTITION BY asset_issuer, + asset_code ORDER BY batch_insert_ts DESC, _inserted_timestamp DESC