incremenatal filters

duneanalytics · Nov 15, 2024 · 632f327 · 632f327
1 parent e15d6d1
commit 632f327
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/dbt_subprojects/dex/macros/models/_project/zeroex/zeroex_v2.sql b/dbt_subprojects/dex/macros/models/_project/zeroex/zeroex_v2.sql
@@ -220,9 +220,9 @@ fills as (
         and event_name in ('TokenExchange', 'OtcOrderFilled', 'SellBaseToken', 'Swap', 'BuyGem', 'DODOSwap', 'SellGem', 'Submitted')
         WHERE 
         {% if is_incremental() %}
-            and  {{ incremental_predicate('l.block_time') }}
+            {{ incremental_predicate('l.block_time') }}
         {% else %}
-            and  l.block_time >= DATE '{{start_date}}'
+            l.block_time >= DATE '{{start_date}}'
         {% endif %}
 
         )
@@ -233,9 +233,9 @@ fills as (
         join  tbl_trades tt on tt.tx_hash = l.tx_hash and l.block_time = tt.block_time and l.block_number = tt.block_number 
         WHERE 
         {% if is_incremental() %}
-            and  {{ incremental_predicate('l.block_time') }}
+            {{ incremental_predicate('l.block_time') }}
         {% else %}
-            and  l.block_time >= DATE '{{start_date}}'
+            l.block_time >= DATE '{{start_date}}'
         {% endif %}
 
         group by 1,2,3