diff --git a/dbt/models/staging/schema.yml b/dbt/models/staging/schema.yml index 54eca7a..a3c5875 100644 --- a/dbt/models/staging/schema.yml +++ b/dbt/models/staging/schema.yml @@ -4,6 +4,9 @@ models: - name: stg_funda_listings description: > Cleaned Funda listing details – one row per property. + meta: + dagster: + group: funda columns: - name: global_id description: Funda internal listing ID. @@ -18,6 +21,9 @@ models: - name: stg_funda_price_history description: > Historical price events per listing (asking prices, WOZ assessments, sales). + meta: + dagster: + group: funda columns: - name: global_id description: Funda internal listing ID. diff --git a/dbt/models/staging/sources.yml b/dbt/models/staging/sources.yml index 0a31a37..3f77f16 100644 --- a/dbt/models/staging/sources.yml +++ b/dbt/models/staging/sources.yml @@ -8,6 +8,9 @@ sources: tables: - name: search_results description: Funda search results (broad overview of matching listings). + meta: + dagster: + asset_key: ["funda_search_results"] columns: - name: global_id description: Funda internal listing ID. @@ -23,6 +26,9 @@ sources: - name: listing_details description: > Full listing details fetched per search result (50+ fields). + meta: + dagster: + asset_key: ["funda_listing_details"] columns: - name: global_id description: Funda internal listing ID. @@ -38,6 +44,9 @@ sources: - name: price_history description: > Historical price data per listing (asking prices, WOZ, sales). + meta: + dagster: + asset_key: ["funda_price_history"] columns: - name: global_id description: Funda internal listing ID.