Make latest balances incremental (duneanalytics#6337)

raho1 · Jul 9, 2024 · cb3b91f · cb3b91f
1 parent 4ceb30d
commit cb3b91f
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/solana/models/solana_utils/solana_utils_latest_balances.sql b/solana/models/solana_utils/solana_utils_latest_balances.sql
@@ -2,8 +2,10 @@
   config(
         schema = 'solana_utils',
         alias = 'latest_balances',
-        materialized='table',
-
+        materialized='incremental',
+        file_format = 'delta',
+        incremental_strategy = 'merge',
+        unique_key = ['address'],
         post_hook='{{ expose_spells(\'["solana"]\',
                                     "sector",
                                     "solana_utils",
@@ -21,6 +23,10 @@ WITH
                   , token_balance_owner
                   , row_number() OVER (partition by address order by day desc) as latest_balance
             FROM {{ ref('solana_utils_daily_balances') }}
+            {% if is_incremental() %}
+            WHERE {{incremental_predicate('day')}}
+            {% endif %}
+
       )
 
 SELECT
@@ -32,4 +38,4 @@ SELECT
       , now() as updated_at
 FROM updated_balances ub
 LEFT JOIN {{ ref('solana_utils_token_accounts')}} tk ON tk.address = ub.address
-WHERE latest_balance = 1
+WHERE latest_balance = 1