dex_solana.trades: simplify block slot cutoff (#9058)

jeff-dude · web-flow · commit 7ebd6c636278 · 2025-11-21T12:44:34.000-05:00
* simplify block slot cutoff * force short run time * add filter for performance * Revert "force short run time" This reverts commit 388b53c.
diff --git a/dbt_subprojects/solana/models/_sector/dex/dex_solana_stg_max_block_slot.sql b/dbt_subprojects/solana/models/_sector/dex/dex_solana_stg_max_block_slot.sql
@@ -0,0 +1,18 @@
+{{
+    config(
+        schema = 'dex_solana'
+        , alias = 'stg_max_block_slot'
+        , materialized = 'table'
+    )
+}}
+-- depends_on: {{ ref('dex_solana_base_trades') }}
+
+select
+    max(block_date) as block_date_filter
+    , max(block_time) as block_time_filter
+    , max(block_slot) as block_slot_filter
+from
+    {{ source('tokens_solana', 'transfers') }}
+where
+    -- to prevent full scan, give short timeframe filter with some buffer
+    block_date >= now() - interval '3' day
diff --git a/dbt_subprojects/solana/models/_sector/dex/dex_solana_stg_min_max_block_slot.sql b/dbt_subprojects/solana/models/_sector/dex/dex_solana_stg_min_max_block_slot.sql
diff --git a/dbt_subprojects/solana/models/_sector/dex/dex_solana_trades.sql b/dbt_subprojects/solana/models/_sector/dex/dex_solana_trades.sql
@@ -29,7 +29,7 @@ with base_trades as (
         , block_time_filter
         , block_slot_filter
     FROM
-        {{ ref('dex_solana_stg_min_max_block_slot') }}
+        {{ ref('dex_solana_stg_max_block_slot') }}
 )
 SELECT bt.blockchain
       , bt.project

Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,7 @@ with base_trades as (`
`29`	`29`	`, block_time_filter`
`30`	`30`	`, block_slot_filter`
`31`	`31`	`FROM`
`32`		`- {{ ref('dex_solana_stg_min_max_block_slot') }}`
	`32`	`+ {{ ref('dex_solana_stg_max_block_slot') }}`
`33`	`33`	`)`
`34`	`34`	`SELECT bt.blockchain`
`35`	`35`	`, bt.project`