Romain
05/05/2022, 1:53 PMprha
05/05/2022, 2:50 PMfrom dagster import asset, build_assets_job, run_failure_sensor
@asset
def asset1():
return 1
@asset
def asset2():
return 2
my_asset_job = build_assets_job("my_assets_job", assets=[asset1, asset2])
@run_failure_sensor(job_selection=[my_asset_job])
def perform_on_asset_job_failure(context):
...
Romain
05/05/2022, 2:52 PMprha
05/06/2022, 5:30 PMDagster Bot
05/06/2022, 5:30 PM