Merge pull request #17 from MetricsDAO/hotfix

models/core/txs.sql

@@ -9,17 +9,13 @@
 -- WIP -- below serves as example
 
 with base_txs as (
-    select * from {{ deduped_txs("near_txs") }}
+    select * from {{ ref("stg_txs") }}
+    where {{ incremental_load_filter("block_timestamp") }}
 ),
 final as (  
     select
-        block_timestamp,
-        tx:nonce::string as nonce,
-        tx_id as tx_hash,
-        -- Build out more columns here from `txs`
-        -- ...    
+        *    
     from base_txs
-where {{ incremental_load_filter("block_timestamp") }}
 )
 
 select * from final

models/staging/stg_blocks.sql

@@ -1,7 +1,7 @@
 {{
     config(
         materialized='incremental',
-        unique_key='tx_id',
+        unique_key='block_id',
         incremental_strategy = 'delete+insert',
         tags=['core'],
         cluster_by=['block_timestamp']