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 00a141a5..ec6ab80e 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 @@ -10,7 +10,7 @@ full_refresh = false, unique_key = ['product_id','hour','price','orderbook_side'], cluster_by = ['hour::DATE'], - tags = ['silver','curated','nado'] + tags = ['silver','curated','nado','hourly_nado'] ) }} WITH market_depth AS ({% for item in range(55) %} diff --git a/models/curated_package/protocols/nado/silver/silver__nado_market_stats.sql b/models/curated_package/protocols/nado/silver/silver__nado_market_stats.sql index 60fc928d..fd49ec31 100644 --- a/models/curated_package/protocols/nado/silver/silver__nado_market_stats.sql +++ b/models/curated_package/protocols/nado/silver/silver__nado_market_stats.sql @@ -9,7 +9,7 @@ incremental_strategy = 'merge', unique_key = ['ticker_id','hour'], cluster_by = ['HOUR::DATE'], - tags = ['silver','curated','nado'] + tags = ['silver','curated','nado','hourly_nado'] ) }} diff --git a/models/curated_package/protocols/nado/silver/silver__nado_money_markets.sql b/models/curated_package/protocols/nado/silver/silver__nado_money_markets.sql index ff1aa644..a370c58d 100644 --- a/models/curated_package/protocols/nado/silver/silver__nado_money_markets.sql +++ b/models/curated_package/protocols/nado/silver/silver__nado_money_markets.sql @@ -9,7 +9,7 @@ incremental_strategy = 'merge', unique_key = ['ticker_id','hour'], cluster_by = ['HOUR::DATE'], - tags = ['silver','curated','nado'] + tags = ['silver','curated','nado','hourly_nado'] ) }} @@ -54,7 +54,6 @@ SELECT ) }} AS nado_money_markets_id, '{{ invocation_id }}' AS _invocation_id FROM - flattened -WHERE product_id not in ('121','125') qualify(ROW_NUMBER() over(PARTITION BY ticker_id, HOUR + flattened qualify(ROW_NUMBER() over(PARTITION BY ticker_id, HOUR ORDER BY inserted_timestamp DESC )) = 1 \ No newline at end of file