Adding run failure sensors to software-defined asset jobs

[dagsir[bot]]

The question was originally asked in Dagster Slack. Reposting it here for posterity and discoverability.

Original question:

Is there a way to attach a hook to a job built from a software-defined asset?

[prha]

If you are looking for a way to fire an alert or perform some action based on a run failure of an asset job, you can set up a run status sensor. You can point it at a specific job, including an asset job. For example:

from 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):
    ...