Add tags to models

models/intermediate/trades/int_trade_agg_day.sql

@@ -1,5 +1,6 @@
 {{ config(
-    cluster_by =["asset_a", "asset_b"]
+    tags = ["trade_agg"]
+    , cluster_by =["asset_a", "asset_b"]
     )
 }}
 

models/intermediate/trades/int_trade_agg_month.sql

@@ -1,5 +1,6 @@
 {{ config(
-    cluster_by =["asset_a", "asset_b"]
+    tags = ["trade_agg"]
+    , cluster_by =["asset_a", "asset_b"]
     )
 }}
 

models/intermediate/trades/int_trade_agg_week.sql

@@ -1,5 +1,6 @@
 {{ config(
-    cluster_by =["asset_a", "asset_b"]
+    tags = ["trade_agg"]
+    , cluster_by =["asset_a", "asset_b"]
     )
 }}
 

models/intermediate/trades/int_trade_agg_year.sql

@@ -1,5 +1,6 @@
 {{ config(
-    cluster_by =["asset_a", "asset_b"]
+    tags = ["trade_agg"]
+    , cluster_by =["asset_a", "asset_b"]
     )
 }}
 

models/marts/enriched_history_operations.sql

@@ -1,5 +1,5 @@
 {{ config(
-    tags = ["partnership_assets", "asset_stats"],
+    tags = ["enriched_history_operations"],
     materialized='incremental',
     unique_key=["op_id"],
     partition_by={

models/marts/enriched_history_operations.yml

@@ -13,17 +13,6 @@ models:
           meta:
             description:
               "Monitors the freshness of your table over time, as the expected time between data updates."
-      - elementary.dimension_anomalies:
-          timestamp_column: closed_at
-          backfill_days: 90
-          dimensions:
-            - "type"
-          time_bucket:
-            period: day
-            count: 1
-          meta:
-            description:
-              "Monitors the frequency of values in the type column over time."
     columns:
       - name: op_id
         description: '{{ doc("operation_id") }}'

models/marts/fee_stats_agg.sql

@@ -1,4 +1,5 @@
 {{ config(
+    tags=["fee_stats_agg"],
     materialized='incremental',
     unique_key=["day_agg"],
     partition_by={
@@ -164,4 +165,4 @@ with
     )
 
 select distinct *
-from renaming
+from renaming

models/marts/history_assets.sql

@@ -1,5 +1,6 @@
 {{ config(
-    materialized='incremental'
+    tags = ["history_assets", "trade_agg"]
+    , materialized='incremental'
     , unique_key=["asset_id"]
     , cluster_by= ["asset_id"]
     )
@@ -81,4 +82,4 @@
 {% endif %}
 
 select *
-from add_assets
+from add_assets

models/marts/trade_agg.sql

@@ -1,6 +1,7 @@
 {{ config(
-    materialized='incremental',
-    partition_by={
+    tags = ["trade_agg"],
+    materialized = 'incremental',
+    partition_by = {
         "field": "day_agg"
         , "data_type": "date"
         , "granularity": "month"}
@@ -117,4 +118,4 @@ with
     )
 
 select *
-from join_trades
+from join_trades

models/sources/src_accounts_signers.yml

@@ -16,15 +16,6 @@ sources:
               meta:
                 description:
                   "Monitors the freshness of your table over time, as the expected time between data updates."
-          - elementary.volume_anomalies:
-              timestamp_column: batch_run_date
-              backfill_days: 90
-              time_bucket:
-                period: day
-                count: 1
-              meta:
-                description:
-                  "Monitors the row count of your table over time."
           - dbt_utils.unique_combination_of_columns:
               combination_of_columns:
                 - account_id
@@ -88,4 +79,4 @@ sources:
             tests:
               - not_null:
                   config:
-                    where: batch_run_date > current_datetime - interval 2 day 
+                    where: batch_run_date > current_datetime - interval 2 day 

models/staging/stg_account_signers.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["current_state"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_accounts.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["current_state"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_claimable_balances.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["claimable_balances"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_history_assets.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["history_assets", "trade_agg"]
+    )
+}}
+
 /* This query prepares the assets of each load for deduplication,
 in order to guarantee a new asset won't be loaded twice */
 with

models/staging/stg_history_effects.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["history_effects"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_history_ledgers.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["enriched_history_operations"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_history_operations.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["enriched_history_operations"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_history_trades.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["trade_agg"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_history_transactions.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["enriched_history_operations"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_liquidity_pools.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["current_state"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_offers.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["current_state"]
+    )
+}}
+
 with
     raw_table as (
         select *

models/staging/stg_trust_lines.sql

@@ -1,3 +1,8 @@
+{{ config(
+    tags = ["current_state"]
+    )
+}}
+
 with
     raw_table as (
         select *