diff --git a/models/curated_package/protocols/nado/silver/silver__nado_market_depth.sql b/models/curated_package/protocols/nado/silver/silver__nado_market_depth.sql index e6085ef6..00a141a5 100644 --- a/models/curated_package/protocols/nado/silver/silver__nado_market_depth.sql +++ b/models/curated_package/protocols/nado/silver/silver__nado_market_depth.sql @@ -8,7 +8,7 @@ materialized = 'incremental', incremental_strategy = 'merge', full_refresh = false, - unique_key = ['product_id','hour','price'], + unique_key = ['product_id','hour','price','orderbook_side'], cluster_by = ['hour::DATE'], tags = ['silver','curated','nado'] ) }} @@ -102,7 +102,7 @@ WITH market_depth AS ({% for item in range(55) %} SELECT *, {{ dbt_utils.generate_surrogate_key( - ['product_id','hour','price'] + ['product_id','hour','price','orderbook_side'] ) }} AS nado_market_depth_id, SYSDATE() AS inserted_timestamp, '{{ invocation_id }}' AS _invocation_id