Merge pull request #434 from FlipsideCrypto/tag-supply

Tag supply model with scheduled_core

models/gold/atlas/atlas__ez_supply.sql

@@ -8,7 +8,7 @@
             }
         }
     },
-    tags = ['atlas']
+    tags = ['atlas', 'scheduled_core']
 ) }}
 
 WITH supply AS (

models/silver/atlas/supply/silver__atlas_supply.sql

@@ -2,7 +2,7 @@
     materialized = "table",
     cluster_by = ["utc_date"],
     unique_key = "atlas_supply_id",
-    tags = ['atlas']
+    tags = ['atlas', 'scheduled_core']
 ) }}
 
 WITH daily_lockup_locked_balances AS (

models/silver/atlas/supply/silver__atlas_supply_daily_lockup_locked_balances.sql

@@ -2,7 +2,7 @@
     materialized = "table",
     cluster_by = ["utc_date"],
     unique_key = "atlas_daily_lockup_locked_balances_id",
-    tags = ['atlas', 'atlas_supply']
+    tags = ['atlas', 'scheduled_core']
 ) }}
 
 WITH lockup_receipts AS (

models/silver/atlas/supply/silver__atlas_supply_daily_lockup_staking_balances.sql

@@ -2,7 +2,7 @@
     materialized = "table",
     cluster_by = ["utc_date"],
     unique_key = "atlas_daily_lockup_staking_balances_id",
-    tags = ['atlas', 'atlas_supply']
+    tags = ['atlas', 'scheduled_core']
 ) }}
 
 WITH lockup_receipts AS (

models/silver/atlas/supply/silver__atlas_supply_daily_staked_supply.sql

@@ -3,7 +3,7 @@
     cluster_by = ["utc_date"],
     unique_key = "atlas_daily_staked_supply_id",
     merge_exclude_columns = ["inserted_timestamp"],
-    tags = ['atlas', 'atlas_supply'],
+    tags = ['atlas', 'scheduled_core'],
     enabled = False
 ) }}
 

models/silver/atlas/supply/silver__atlas_supply_epochs.sql

@@ -2,7 +2,7 @@
     materialized = "table",
     cluster_by = ["epoch_id"],
     unique_key = "atlas_epochs_id",
-    tags = ['atlas']
+    tags = ['atlas', 'scheduled_core']
 ) }}
 
 WITH blocks AS (
@@ -16,15 +16,9 @@ WITH blocks AS (
         _partition_by_block_number
     FROM
         {{ ref('silver__blocks_final') }}
+
         {% if var("MANUAL_FIX") %}
             WHERE {{ partition_load_manual('no_buffer') }}
-        {% else %}
-            WHERE modified_timestamp >= (
-                SELECT
-                    MAX(modified_timestamp)
-                FROM
-                    {{ this }}
-            )
         {% endif %}
 ),
 epochs AS (

models/silver/atlas/supply/silver__atlas_supply_lockup_receipts.sql

@@ -5,7 +5,7 @@
     merge_exclude_columns = ["inserted_timestamp"],
     incremental_strategy = "merge",
     incremental_predicates = ["dynamic_range_predicate_custom","block_timestamp::date"],
-    tags = ['atlas']
+    tags = ['atlas', 'scheduled_core']
 ) }}
 
 WITH receipts AS (