Add block_time and block_slot to solana_utils balances (duneanalytics…

…#6539) * Add block_time and block_slot to solana_utils balances * test: hardcode small time window * fix incremental * Revert "fix incremental" This reverts commit 1a2ed02. * Revert "test: hardcode small time window" This reverts commit 7ccb104. --------- Co-authored-by: jeff-dude <jeff@dune.xyz>
bancorprotocol · Aug 13, 2024 · 4a6999c · 4a6999c
1 parent f3cfd20
commit 4a6999c
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/dbt_subprojects/solana/models/solana_utils/solana_utils_daily_balances.sql b/dbt_subprojects/solana/models/solana_utils/solana_utils_daily_balances.sql
@@ -45,6 +45,8 @@ SELECT
       , token_mint_address
       , token_balance
       , token_balance_owner
+      , block_time
+      , block_slot
       , {{ dbt_utils.generate_surrogate_key(['address', 'token_mint_address', 'day']) }} as unique_address_key
       , now() as updated_at
 FROM updated_balances

diff --git a/dbt_subprojects/solana/models/solana_utils/solana_utils_latest_balances.sql b/dbt_subprojects/solana/models/solana_utils/solana_utils_latest_balances.sql
@@ -21,6 +21,8 @@ WITH
                   , token_mint_address
                   , token_balance
                   , token_balance_owner
+                  , block_time
+                  , block_slot
                   , row_number() OVER (partition by address order by day desc) as latest_balance
             FROM {{ ref('solana_utils_daily_balances') }}
             {% if is_incremental() %}
@@ -31,6 +33,8 @@ WITH
 
 SELECT
       ub.address
+      , ub.block_time
+      , ub.block_slot
       , ub.sol_balance
       , ub.token_balance
       , coalesce(ub.token_mint_address, tk.token_mint_address) as token_mint_address