Merge pull request #42 from FlipsideCrypto/an-4888

AN-4888 one more commit for clock skew
FlipsideCrypto · Jul 26, 2024 · 9063af0 · 9063af0
2 parents b62848d + f95a65f
commit 9063af0
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/models/silver/silver__block_rewards.sql b/models/silver/silver__block_rewards.sql
@@ -2,7 +2,7 @@
   materialized = 'incremental',
   unique_key = 'day',
   incremental_strategy = 'merge',
-  cluster_by = ['block_timestamp::DATE']
+  cluster_by = ['day']
 ) }}
 
 WITH all_block_id AS (

diff --git a/models/silver/silver__daily_earnings.sql b/models/silver/silver__daily_earnings.sql
@@ -23,7 +23,7 @@ WHERE
   block_timestamp :: DATE >= (
     SELECT
       MAX(
-        DAY
+        DAY - INTERVAL '2 DAYS' --counteract clock skew
       )
     FROM
       {{ this }}
@@ -48,7 +48,7 @@ WHERE
   block_timestamp :: DATE >= (
     SELECT
       MAX(
-        DAY
+        DAY - INTERVAL '2 DAYS' --counteract clock skew
       )
     FROM
       {{ this }}

diff --git a/models/silver/silver__daily_pool_stats.sql b/models/silver/silver__daily_pool_stats.sql
@@ -2,7 +2,7 @@
   materialized = 'incremental',
   unique_key = "_unique_key",
   incremental_strategy = 'merge',
-  cluster_by = ['block_timestamp::DATE'],
+  cluster_by = ['day'],
   incremental_predicates = ['DBT_INTERNAL_DEST.day >= (select min(day) from ' ~ generate_tmp_view_name(this) ~ ')']
 ) }}
 

diff --git a/models/silver/silver__prices.sql b/models/silver/silver__prices.sql
@@ -23,7 +23,7 @@ WITH blocks AS (
 
 {% if is_incremental() %}
 WHERE
- b.block_timestamp :: DATE >= (
+ b.block_timestamp >= (
     SELECT
       MAX(
         block_timestamp - INTERVAL '1 HOUR'
@@ -46,7 +46,7 @@ price AS (
 
 {% if is_incremental() %}
 WHERE
-  b.block_timestamp :: DATE >= (
+  b.block_timestamp >= (
     SELECT
       MAX(
         block_timestamp - INTERVAL '1 HOUR'

diff --git a/models/silver/silver__total_block_rewards.sql b/models/silver/silver__total_block_rewards.sql
@@ -95,7 +95,7 @@ FROM
 {% if is_incremental() %}
 WHERE
   (
-    b.block_timestamp :: DATE >= (
+    b.block_timestamp >= (
       SELECT
         MAX(
           block_timestamp - INTERVAL '1 HOUR'