From 59f72a11d13df9d6953a79c744831b095da2874a Mon Sep 17 00:00:00 2001 From: Eric Laurello Date: Mon, 25 Sep 2023 08:54:55 -0400 Subject: [PATCH] qualify fix --- models/gold/price/price__ez_prices.sql | 47 +++++++++++++------------- 1 file changed, 24 insertions(+), 23 deletions(-) diff --git a/models/gold/price/price__ez_prices.sql b/models/gold/price/price__ez_prices.sql index 3b6701c..383f27d 100644 --- a/models/gold/price/price__ez_prices.sql +++ b/models/gold/price/price__ez_prices.sql @@ -24,26 +24,27 @@ WITH p_base AS ( ELSE 4 END AS pro_rank FROM - {{ ref('core__dim_prices') }} A qualify(ROW_NUMBER() over(PARTITION BY recorded_hour, UPPER(symbol) - ORDER BY - pro_rank) = 1)) - SELECT - A.recorded_hour, - A.symbol, - COALESCE( - A.currency, - b_1.address, - b_2.address - ) AS currency, - A.price - FROM - p_base A - LEFT JOIN {{ ref('silver__asset_metadata') }} - b_1 - ON A.currency = b_1.address - LEFT JOIN {{ ref('silver__asset_metadata') }} - b_2 - ON A.symbol = UPPER ( - b_2.project_name - ) - AND A.currency IS NULL + {{ ref('price__dim_prices') }} A +) +SELECT + A.recorded_hour, + A.symbol, + COALESCE( + A.currency, + b_1.address, + b_2.address + ) AS currency, + A.price +FROM + p_base A + LEFT JOIN {{ ref('silver__asset_metadata') }} + b_1 + ON A.currency = b_1.address + LEFT JOIN {{ ref('silver__asset_metadata') }} + b_2 + ON A.symbol = UPPER ( + b_2.project_name + ) + AND A.currency IS NULL qualify(ROW_NUMBER() over(PARTITION BY recorded_hour, COALESCE(A.currency, b_1.address, b_2.address) +ORDER BY + pro_rank) = 1)