joe v2 tables incremental

macros/trader_joe_v_2/trader_joe_v_2_1_swaps.sql

@@ -34,6 +34,9 @@ WITH lbpairs AS (        -- Step 1: Extract all Pools addresses that were create
             SELECT lbpair_address FROM lbpairs
         )
     AND event_name = 'Swap' 
+    {% if is_incremental() %}
+        AND block_timestamp > (SELECT MAX(block_timestamp) FROM {{this}})
+    {% endif %}
 )
 SELECT
     s.block_timestamp,

macros/trader_joe_v_2/trader_joe_v_2_2_swaps.sql

@@ -38,6 +38,9 @@ WHERE
             lbpairs
     )
     AND topics[0] = '0xad7d6f97abf51ce18e17a38f4d70e975be9c0708474987bb3e26ad21bd93ca70'
+    {% if is_incremental() %}
+        AND block_timestamp > (SELECT MAX(block_timestamp) FROM {{this}})
+    {% endif %}
 )
 SELECT
     s.block_timestamp,

models/staging/trader_joe/fact_trader_joe_arbitrum_v2_1_dex_swaps.sql

@@ -1,6 +1,6 @@
 {{
     config(
-        materialized="table",
+        materialized="incremental",
         snowflake_warehouse="TRADER_JOE",
     )
 }}

models/staging/trader_joe/fact_trader_joe_arbitrum_v2_2_dex_swaps.sql

@@ -1,6 +1,6 @@
 {{
     config(
-        materialized="table",
+        materialized="incremental",
         snowflake_warehouse="TRADER_JOE",
     )
 }}

models/staging/trader_joe/fact_trader_joe_avalanche_v2_1_dex_swaps.sql

@@ -1,6 +1,6 @@
 {{
     config(
-        materialized="table",
+        materialized="incremental",
         snowflake_warehouse="TRADER_JOE",
     )
 }}

models/staging/trader_joe/fact_trader_joe_avalanche_v2_2_dex_swaps.sql

@@ -1,6 +1,6 @@
 {{
     config(
-        materialized="table",
+        materialized="incremental",
         snowflake_warehouse="TRADER_JOE",
     )
 }}