Bojan
11/07/2022, 1:39 PMyuhan
11/11/2022, 2:11 AMSam Werbalowsky
01/13/2023, 8:26 PM@asset(required_resource_keys={"dbt"}, name='force_dbt_run_job',
ins={"upstream": AssetIn(key="dim_products")},
non_argument_deps={"force_update_dim_products"})
def force_updated_job(upstream):
return upstream
I am trying to return the “dim_products” asset and re-materialize it (I need to do some manual manipulation of the data) but I don’t know of a graceful way to do that….this code doesn’t work because it looked in local storage for the asset, rather than wherever dbt is storing it.Benedikt Buchert
01/26/2023, 2:52 PMBojan
01/26/2023, 7:52 PM