@@ -267,6 +267,7 @@ modify_liquidity_events as (
267267 from
268268 {{ PoolManager_call_ModifyLiquidity }}
269269 where call_success
270+ and call_block_time <= date ' 2025-03-05'
270271 {%- if is_incremental() %}
271272 and {{ incremental_predicate(' call_block_time' ) }}
272273 {%- endif %}
@@ -323,8 +324,9 @@ modify_liquidity_events as (
323324 ROW_NUMBER() OVER (PARTITION BY evt_tx_hash ORDER BY evt_index) AS evt_rn
324325 from
325326 {{ PoolManager_evt_ModifyLiquidity }}
327+ where evt_block_time <= date ' 2025-03-05'
326328 {%- if is_incremental() %}
327- where {{ incremental_predicate(' evt_block_time' ) }}
329+ and {{ incremental_predicate(' evt_block_time' ) }}
328330 {%- endif %}
329331 )
330332
@@ -396,8 +398,9 @@ swap_events as (
396398 , cast(null as varbinary) as salt
397399 from
398400 {{ PoolManager_evt_Swap }}
401+ where evt_block_time <= date ' 2025-03-05'
399402 {%- if is_incremental() %}
400- where {{ incremental_predicate(' evt_block_time' ) }}
403+ and {{ incremental_predicate(' evt_block_time' ) }}
401404 {%- endif %}
402405),
403406
@@ -418,8 +421,9 @@ swap_fees_paid as (
418421 , cast(null as varbinary) as salt
419422 from
420423 {{ PoolManager_evt_Swap }}
424+ where evt_block_time <= date ' 2025-03-05'
421425 {%- if is_incremental() %}
422- where {{ incremental_predicate(' evt_block_time' ) }}
426+ and {{ incremental_predicate(' evt_block_time' ) }}
423427 {%- endif %}
424428),
425429
0 commit comments