Robert Kolb
05/23/2023, 3:59 PMaggregation_pipline_job = define_asset_job(
"aggregation_pipline",
[*accumulator_assets.values(), *groupby_assets, groups_asset],
)
i'm not able to pass in hooks in the same way that you are to when using the job decorator like this
@job(resource_defs={"slack": slack_resource}, hooks={slack_message_on_success})
can you provide a recommendation on the best way to accomplish this?owen
05/23/2023, 6:18 PMBala Samynathan
06/01/2023, 6:18 PM