add incremental conditions

duneanalytics · Jan 29, 2025 · a406a68 · a406a68
1 parent f0fe2c4
commit a406a68
Show file tree

Hide file tree

Showing 6 changed files with 19 additions and 0 deletions.
diff --git a/dbt_subprojects/dex/macros/models/_decoding/uniswap_v2/uniswap_v2_factory_event_decoding.sql b/dbt_subprojects/dex/macros/models/_decoding/uniswap_v2/uniswap_v2_factory_event_decoding.sql
@@ -35,4 +35,8 @@
 {% set topic0 = '0x0d3648bd0f6ba80134a33ba9275ac585d9d315f0ad8355cddefde31afa28d0e9' %}
 
 {{ evm_event_decoding_base(logs, abi, topic0) }}
+{% if is_incremental() %}
+WHERE {{ incremental_predicate('block_time') }}
+{% endif %}
+
 {% endmacro %}
diff --git a/dbt_subprojects/dex/macros/models/_decoding/uniswap_v2/uniswap_v2_pool_event_decoding.sql b/dbt_subprojects/dex/macros/models/_decoding/uniswap_v2/uniswap_v2_pool_event_decoding.sql
@@ -47,4 +47,7 @@
 {% set topic0 = '0xd78ad95fa46c994b6551d0da85fc275fe613ce37657fb8d5e3d130840159d822' %}
 
 {{ evm_event_decoding_base(logs, abi, topic0) }}
+{% if is_incremental() %}
+WHERE {{ incremental_predicate('block_time') }}
+{% endif %}
 {% endmacro %}
diff --git a/dbt_subprojects/dex/macros/models/_decoding/uniswap_v2/uniswap_v2_trades.sql b/dbt_subprojects/dex/macros/models/_decoding/uniswap_v2/uniswap_v2_trades.sql
@@ -81,5 +81,8 @@ SELECT
     , tx_to
     , tx_index
 FROM dexs
+{% if is_incremental() %}
+WHERE {{ incremental_predicate('block_time') }}
+{% endif %}
 
 {% endmacro %}
diff --git a/dbt_subprojects/dex/macros/models/_decoding/uniswap_v3/uniswap_v3_factory_event_decoding.sql b/dbt_subprojects/dex/macros/models/_decoding/uniswap_v3/uniswap_v3_factory_event_decoding.sql
@@ -7,5 +7,8 @@
 {% set topic0 = '0x783cca1c0412dd0d695e784568c96da2e9c22ff989357a2e8b1d9b2b4e6b7118' %}
 
 {{ evm_event_decoding_base(logs, abi, topic0) }}
+{% if is_incremental() %}
+WHERE {{ incremental_predicate('block_time') }}
+{% endif %}
 {% endmacro %}
 
diff --git a/dbt_subprojects/dex/macros/models/_decoding/uniswap_v3/uniswap_v3_pool_event_decoding.sql b/dbt_subprojects/dex/macros/models/_decoding/uniswap_v3/uniswap_v3_pool_event_decoding.sql
@@ -7,5 +7,8 @@
 {% set topic0 = '0xc42079f94a6350d7e6235f29174924f928cc2ac818eb64fed8004e115fbcca67' %}
 
 {{ evm_event_decoding_base(logs, abi, topic0) }}
+{% if is_incremental() %}
+WHERE {{ incremental_predicate('block_time') }}
+{% endif %}
 {% endmacro %}
 
diff --git a/dbt_subprojects/dex/macros/models/_decoding/uniswap_v3/uniswap_v3_trades.sql b/dbt_subprojects/dex/macros/models/_decoding/uniswap_v3/uniswap_v3_trades.sql
@@ -89,4 +89,7 @@ SELECT
     , tx_to
     , tx_index
 FROM dexs
+{% if is_incremental() %}
+WHERE {{ incremental_predicate('block_time') }}
+{% endif %}
 {% endmacro %}