From d43de1f8dae5a5f697df2f1ff66b79507e6cc00b Mon Sep 17 00:00:00 2001 From: Eric Laurello Date: Mon, 5 May 2025 10:05:09 -0400 Subject: [PATCH] fix --- .../silver/prices/silver__pool_token_prices_usd.sql | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/models/silver/prices/silver__pool_token_prices_usd.sql b/models/silver/prices/silver__pool_token_prices_usd.sql index dbc66af..f532394 100644 --- a/models/silver/prices/silver__pool_token_prices_usd.sql +++ b/models/silver/prices/silver__pool_token_prices_usd.sql @@ -59,6 +59,10 @@ AND A._inserted_timestamp >= ( {{ this }} ) {% endif %} + +qualify(ROW_NUMBER() over(PARTITION BY A.block_id, A.token_address +ORDER BY + A.pool_total DESC) = 1) ), non_osomo_price AS ( SELECT @@ -102,7 +106,7 @@ AND A._inserted_timestamp >= ( ) {% endif %} -qualify(ROW_NUMBER() over(PARTITION BY A.token_address +qualify(ROW_NUMBER() over(PARTITION BY A.block_id, A.token_address ORDER BY A.pool_total DESC) = 1) ), @@ -329,4 +333,9 @@ SELECT SYSDATE() AS modified_timestamp, '{{ invocation_id }}' AS _invocation_id FROM - fin + fin qualify ROW_NUMBER() over( + PARTITION BY block_id, + token_address + ORDER BY + pool_id DESC + ) = 1