diff --git a/hooli_data_eng/assets/dbt_assets.py b/hooli_data_eng/assets/dbt_assets.py index d465e3f4..bae145bb 100644 --- a/hooli_data_eng/assets/dbt_assets.py +++ b/hooli_data_eng/assets/dbt_assets.py @@ -93,13 +93,10 @@ def get_metadata(self, dbt_resource_props: Mapping[str, Any]) -> Mapping[str, An metadata = {"partition_expr": "order_date"} if dbt_resource_props["name"] == "orders_cleaned": - metadata = {"partition_expr": "dt", "owner":"data@hooli.org"} + metadata = {"partition_expr": "dt"} if dbt_resource_props["name"] == "users_cleaned": - metadata = {"partition_expr": "created_at", "owner":"data@hooli.org"} - - if dbt_resource_props["name"] in ["company_perf", "sku_stats", "company_stats"]: - metadata = {"owner":"bi@hooli.org"} + metadata = {"partition_expr": "created_at"} default_metadata = default_metadata_from_dbt_resource_props(dbt_resource_props) diff --git a/hooli_data_eng/assets/marketing/__init__.py b/hooli_data_eng/assets/marketing/__init__.py index 88111b9f..c3d96458 100644 --- a/hooli_data_eng/assets/marketing/__init__.py +++ b/hooli_data_eng/assets/marketing/__init__.py @@ -22,7 +22,7 @@ freshness_policy=FreshnessPolicy(maximum_lag_minutes=24*60), auto_materialize_policy=allow_outdated_parents_policy, compute_kind="pandas", - op_tags={"owner": "bi@hooli.com"}, + owners=["team:programmers", "lopp@dagsterlabs.com"], ins={"company_perf": AssetIn(key_prefix=["ANALYTICS"])} ) def avg_orders(context: AssetExecutionContext, company_perf: pd.DataFrame) -> pd.DataFrame: @@ -47,9 +47,7 @@ def check_avg_orders(context, avg_orders: pd.DataFrame): key_prefix="MARKETING", freshness_policy=FreshnessPolicy(maximum_lag_minutes=24*60), compute_kind="snowflake", - metadata={ - "owner": "bi@hooli.com" - }, + owners=["team:programmers"], ins={"company_perf": AssetIn(key_prefix=["ANALYTICS"])} ) def min_order(context, company_perf: pd.DataFrame) -> pd.DataFrame: