From deae4ab453014c4111de210b02096a91acb148d2 Mon Sep 17 00:00:00 2001 From: Sean Lopp Date: Wed, 13 Mar 2024 10:52:02 -0600 Subject: [PATCH] update owners to new asset owners --- hooli_data_eng/assets/dbt_assets.py | 7 ++----- hooli_data_eng/assets/marketing/__init__.py | 6 ++---- 2 files changed, 4 insertions(+), 9 deletions(-) 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: