diff --git a/models/silver/parser/silver__decoded_logs.sql b/models/silver/parser/silver__decoded_logs.sql index a8dc37171..b81c58d12 100644 --- a/models/silver/parser/silver__decoded_logs.sql +++ b/models/silver/parser/silver__decoded_logs.sql @@ -50,7 +50,7 @@ USING(block_id) {% if is_incremental() %} WHERE - A._inserted_timestamp >= dateadd('minute', -5, '{{ max_inserted_timestamp }}') + A._inserted_timestamp >= '{{ max_inserted_timestamp }}' AND A._partition_by_created_date_hour >= dateadd('hour', -2, date_trunc('hour','{{ max_inserted_timestamp }}'::timestamp_ntz)) {% endif %} {% endset %}