Phil Whitby
11/22/2022, 5:44 PMfreshness_policies_by_key={
asset_key: FreshnessPolicy(maximum_lag_minutes=45) for asset_key, (input_name, _) in (asset_ins | asset_outs).items()
}
sandy
11/22/2022, 5:48 PMowen
11/22/2022, 5:56 PMmy_dbt_assets = with_freshness_policies(
load_assets_from_dbt...(...),
freshness_policy=FreshnessPolicy(maximum_lag_minutes=45),
# or...
freshness_policies_by_key={AssetKey("a"): FreshnessPolicy(...), ...}
)
additionally, it'd be neat for there to be some config you could add to the dbt project / dbt models themselves that we could parse to figure out a freshness policy.
so I think in the short term, having your own override to the default behavior of dbt_nodes_to_assets
is a reasonable solution, and we'll prioritize getting a general-purpose solution for adding freshness policies to assets for the near futurePhil Whitby
11/22/2022, 6:00 PM