From 66a7cfc700e97f533c100691280e210a28ed698e Mon Sep 17 00:00:00 2001 From: mattromano Date: Tue, 20 Jan 2026 10:47:32 -0800 Subject: [PATCH] add hourly tags to nado api models --- .../protocols/nado/silver/silver__nado_market_depth.sql | 2 +- .../protocols/nado/silver/silver__nado_market_stats.sql | 2 +- .../protocols/nado/silver/silver__nado_money_markets.sql | 5 ++--- 3 files changed, 4 insertions(+), 5 deletions(-) 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