again

duneanalytics · Jan 24, 2025 · 20d2bad · 20d2bad
1 parent eef1695
commit 20d2bad
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 6 deletions.
diff --git a/dbt_macros/shared/balancer/balancer_bpt_prices_macro.sql b/dbt_macros/shared/balancer/balancer_bpt_prices_macro.sql
@@ -403,7 +403,7 @@ WITH pool_labels AS (
             decimals,
             APPROX_PERCENTILE(median_price, 0.5) AS price,
             DATE_TRUNC ('day', next_change) AS next_change,
-            ROW_NUMBER() OVER(PARTITION BY wrapped_token ORDER BY next_change) AS rn
+            ROW_NUMBER() OVER(PARTITION BY wrapped_token ORDER BY DATE_TRUNC ('day', next_change)) AS rn
         FROM {{ source('balancer_v3' , 'erc4626_token_prices') }}
         WHERE blockchain = '{{blockchain}}'
         AND DATE_TRUNC ('day', next_change) != date_trunc('day', minute)

diff --git a/dbt_macros/shared/balancer/balancer_liquidity_macro.sql b/dbt_macros/shared/balancer/balancer_liquidity_macro.sql
@@ -383,17 +383,20 @@ WITH pool_labels AS (
         GROUP BY 1
     ),
 
-    erc4626_prices AS(
+    erc4626_prices AS (
+    SELECT * FROM (
         SELECT
             date_trunc('day', minute) AS day,
             wrapped_token AS token,
             decimals,
             APPROX_PERCENTILE(median_price, 0.5) AS price,
-            DATE_TRUNC ('day', next_change) AS next_change
+            DATE_TRUNC ('day', next_change) AS next_change,
+            ROW_NUMBER() OVER(PARTITION BY wrapped_token ORDER BY DATE_TRUNC ('day', next_change)) AS rn
         FROM {{ source('balancer_v3' , 'erc4626_token_prices') }}
         WHERE blockchain = '{{blockchain}}'
         AND DATE_TRUNC ('day', next_change) != date_trunc('day', minute)
-        GROUP BY 1, 2, 3, 5
+        GROUP BY 1, 2, 3, 5)
+    WHERE rn = 1
     ),
 
     swaps_changes AS (

diff --git a/dbt_macros/shared/balancer/balancer_protocol_fee_macro.sql b/dbt_macros/shared/balancer/balancer_protocol_fee_macro.sql
@@ -276,7 +276,7 @@ WITH pool_labels AS (
             decimals,
             APPROX_PERCENTILE(median_price, 0.5) AS price,
             DATE_TRUNC ('day', next_change) AS next_change,
-            ROW_NUMBER() OVER(PARTITION BY wrapped_token ORDER BY next_change) AS rn
+            ROW_NUMBER() OVER(PARTITION BY wrapped_token ORDER BY DATE_TRUNC ('day', next_change)) AS rn
         FROM {{ source('balancer_v3' , 'erc4626_token_prices') }}
         WHERE blockchain = '{{blockchain}}'
         AND DATE_TRUNC ('day', next_change) != date_trunc('day', minute)

diff --git a/dbt_macros/shared/balancer/balancer_token_balance_changes_daily_agg_macro.sql b/dbt_macros/shared/balancer/balancer_token_balance_changes_daily_agg_macro.sql
@@ -276,7 +276,7 @@ WITH
             decimals,
             APPROX_PERCENTILE(median_price, 0.5) AS price,
             DATE_TRUNC ('day', next_change) AS next_change,
-            ROW_NUMBER() OVER(PARTITION BY wrapped_token ORDER BY next_change) AS rn
+            ROW_NUMBER() OVER(PARTITION BY wrapped_token ORDER BY DATE_TRUNC ('day', next_change)) AS rn
         FROM {{ source('balancer_v3' , 'erc4626_token_prices') }}
         WHERE blockchain = '{{blockchain}}'
         AND DATE_TRUNC ('day', next_change) != date_trunc('day', minute)