Latest balances EVM models

dbt_subprojects/tokens/macros/balances/balances_latest.sql

@@ -0,0 +1,29 @@
+{%- macro balances_latest(balances) %}
+
+select
+    {{dbt_utils.generate_surrogate_key(['address', 'token_address', 'token_standard', "token_id"])}} as unique_key,
+    blockchain,
+    address,
+    token_address,
+    token_standard,
+    token_symbol,
+    token_id,
+    collection_name,
+    max(block_number) as block_number_latest,
+    max(block_time) as block_time_latest,
+    max_by(balance_raw, block_number) as balance_raw_latest,
+    max_by(balance, block_number) as balance_latest
+from {{balances}}
+where
+    {{ incremental_predicate('block_time') }}
+-- for testing
+    and block_time > timestamp '2025-01-27 00:00:00.000 +0000'
+group by
+    blockchain,
+    address,
+    token_address,
+    token_standard,
+    token_symbol,
+    token_id,
+    collection_name
+{% endmacro %}

dbt_subprojects/tokens/models/transfers_and_balances/ethereum/_schema.yml

@@ -190,3 +190,25 @@ models:
       - name: symbol
       - name: decimals
       - name: collection_name
+
+  - name: tokens_ethereum_balances_latest
+    meta:
+      blockchain: ethereum
+      sector: tokens
+      contributors: et-dynamic
+    config:
+      tags: ['tokens','balances', 'ethereum']
+    description: "Most recent token balances enriched"
+    columns:
+      - name: unique_key
+      - name: blockchain
+      - name: address
+      - name: token_address
+      - name: token_standard
+      - name: token_symbol
+      - name: token_id
+      - name: collection_name
+      - name: block_number_latest
+      - name: block_time_latest
+      - name: balance_raw_latest
+      - name: balance_latest

dbt_subprojects/tokens/models/transfers_and_balances/ethereum/tokens_ethereum_balances_latest.sql

@@ -0,0 +1,20 @@
+{{config(
+    schema = 'tokens_ethereum',
+    alias = 'balances_latest',
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    unique_key = ['unique_key'],
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
+    post_hook='{{ expose_spells(\'["ethereum"]\',
+                                "sector",
+                                "balances_latest",
+                                \'["et-dynamic"]\') }}'
+)
+}}
+
+{{
+    balances_latest(
+        balances = ref('tokens_ethereum_balances'),
+    )
+}}