diff --git a/models/silver/streamline/silver__streamline_blocks.sql b/models/silver/streamline/silver__streamline_blocks.sql index 35e70ff..ca2105d 100644 --- a/models/silver/streamline/silver__streamline_blocks.sql +++ b/models/silver/streamline/silver__streamline_blocks.sql @@ -73,6 +73,9 @@ blocks AS ( LEFT JOIN meta m USING ( _filename ) + + {% if not var('MANUAL_FIX') %} + {% if is_incremental() %} WHERE _inserted_timestamp >= ( @@ -82,6 +85,7 @@ blocks AS ( {{ this }} ) {% endif %} + {% endif %} ) SELECT diff --git a/models/silver/streamline/silver__streamline_shards.sql b/models/silver/streamline/silver__streamline_shards.sql index eac4a37..60f96fb 100644 --- a/models/silver/streamline/silver__streamline_shards.sql +++ b/models/silver/streamline/silver__streamline_shards.sql @@ -67,6 +67,7 @@ shards AS ( external_shards e LEFT JOIN meta m USING (_filename) + {% if not var('MANUAL_FIX') %} {% if is_incremental() %} WHERE _inserted_timestamp >= ( @@ -76,6 +77,7 @@ shards AS ( {{ this }} ) {% endif %} + {% endif %} ) SELECT *,