diff --git a/dbt_project/models/ANALYTICS/orders_augmented.sql b/dbt_project/models/ANALYTICS/orders_augmented.sql index cf37759..90369de 100644 --- a/dbt_project/models/ANALYTICS/orders_augmented.sql +++ b/dbt_project/models/ANALYTICS/orders_augmented.sql @@ -8,7 +8,7 @@ from {{ ref("orders_cleaned") }} o left join {{ ref("users_cleaned") }} u on o.user_id = u.user_id - left join {{ ref("location_cleaned") }} l + left join {{ ref("locations_cleaned") }} l on o.user_id = l.user_id {% if is_incremental() %} diff --git a/dbt_project/models/CLEANED/location_cleaned.sql b/dbt_project/models/CLEANED/locations_cleaned.sql similarity index 100% rename from dbt_project/models/CLEANED/location_cleaned.sql rename to dbt_project/models/CLEANED/locations_cleaned.sql diff --git a/hooli_data_eng/assets/dbt_assets.py b/hooli_data_eng/assets/dbt_assets.py index b4af6b3..20b4d6a 100644 --- a/hooli_data_eng/assets/dbt_assets.py +++ b/hooli_data_eng/assets/dbt_assets.py @@ -153,6 +153,6 @@ def weekly_dbt_assets(context: OpExecutionContext, dbt2: DbtCliResource): dbt_views = load_assets_from_dbt_project( DBT_PROJECT_DIR, DBT_PROFILES_DIR, - select="company_perf sku_stats company_stats", + select="company_perf sku_stats company_stats locations_cleaned", dagster_dbt_translator=CustomDagsterDbtTranslatorForViews() )