From da63eed12557763af3453f376ab10c61cf6967fd Mon Sep 17 00:00:00 2001 From: Stijnvandenbroek Date: Wed, 4 Mar 2026 13:49:44 +0000 Subject: [PATCH] fix: dbt model metadata and source lineage --- dbt/models/staging/schema.yml | 6 ++++++ dbt/models/staging/sources.yml | 9 +++++++++ 2 files changed, 15 insertions(+) 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.