Skip to content

Commit

Permalink
update owners to new asset owners (#67)
Browse files Browse the repository at this point in the history
  • Loading branch information
slopp authored Mar 15, 2024
1 parent 88c4300 commit b2c66d0
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 9 deletions.
7 changes: 2 additions & 5 deletions hooli_data_eng/assets/dbt_assets.py
Original file line number Diff line number Diff line change
Expand Up @@ -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":"[email protected]"}
metadata = {"partition_expr": "dt"}

if dbt_resource_props["name"] == "users_cleaned":
metadata = {"partition_expr": "created_at", "owner":"[email protected]"}

if dbt_resource_props["name"] in ["company_perf", "sku_stats", "company_stats"]:
metadata = {"owner":"[email protected]"}
metadata = {"partition_expr": "created_at"}

default_metadata = default_metadata_from_dbt_resource_props(dbt_resource_props)

Expand Down
6 changes: 2 additions & 4 deletions hooli_data_eng/assets/marketing/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand All @@ -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": "[email protected]"
},
owners=["team:programmers"],
ins={"company_perf": AssetIn(key_prefix=["ANALYTICS"])}
)
def min_order(context, company_perf: pd.DataFrame) -> pd.DataFrame:
Expand Down

0 comments on commit b2c66d0

Please sign in to comment.