Fixes for incremental runs

opensource-observer · Mar 26, 2024 · ac8a99a · ac8a99a
1 parent cb2842d
commit ac8a99a
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 10 deletions.
diff --git a/warehouse/dbt/models/staging/ethereum/stg_ethereum__deployers.sql b/warehouse/dbt/models/staging/ethereum/stg_ethereum__deployers.sql
@@ -25,10 +25,9 @@ WHERE
   AND receipt_status = 1
   AND receipt_contract_address IS NOT NULL
 {% if is_incremental() %}
-  WHERE 
-    TIMESTAMP_TRUNC(block_timestamp, DAY) >= (
-      SELECT TIMESTAMP_TRUNC(MAX(block_timestamp), DAY)
-      FROM {{ this }}
-    )
-    AND TIMESTAMP_TRUNC(block_timestamp, DAY) < CURRENT_TIMESTAMP()
-  {% endif %}
+  AND TIMESTAMP_TRUNC(block_timestamp, DAY) >= (
+    SELECT TIMESTAMP_TRUNC(MAX(block_timestamp), DAY)
+    FROM {{ this }}
+  )
+  AND TIMESTAMP_TRUNC(block_timestamp, DAY) < CURRENT_TIMESTAMP()
+{% endif %}
diff --git a/warehouse/dbt/models/staging/optimism/stg_optimism__deployers.sql b/warehouse/dbt/models/staging/optimism/stg_optimism__deployers.sql
@@ -41,9 +41,9 @@ INNER JOIN logs AS l
   ON t.transaction_hash = l.transaction_hash
 WHERE
   t.to_address IS null
-{% if is_incremental() %}
-  AND TIMESTAMP_TRUNC(block_timestamp, DAY) >= (
+  {% if is_incremental() %}
+  AND TIMESTAMP_TRUNC(t.block_timestamp, DAY) >= (
     SELECT * FROM max_block_timestamp
   )
-  AND TIMESTAMP_TRUNC(block_timestamp, DAY) < CURRENT_TIMESTAMP()
+  AND TIMESTAMP_TRUNC(t.block_timestamp, DAY) < CURRENT_TIMESTAMP()
   {% endif %}