19913d85-f662-4518-a9a1-7adc1793dfd4.png){kind=small}
Channels
#dagster-support
Title
# dagster-support
r
Riccardo Tesselli
12/05/2022, 3:33 PMI can’t find a way to attach an hook to an asset materialisation. I’ve created the job for the asset with
define_asset_jobScheduleDefinitiono
owen
12/05/2022, 6:04 PMhi @Riccardo Tesselli! do you mind sharing a bit more about what you'd like the hook to do? we do have a concept of an
@asset_sensorr
Riccardo Tesselli
12/05/2022, 6:56 PMI would like to have a failure hook which is triggered when the asset materialisation fails
o
owen
12/06/2022, 11:29 PMright now, there's not built-in support for asset failure hooks, there is a concept of op failure hooks: https://docs.dagster.io/concepts/ops-jobs-graphs/op-hooks#op-hooks.
so if you had a hook defined, you could do something like this:
Copy code
@op
def do_asset_computation(input):
...
my_asset = AssetsDefinition.from_op(
do_asset_computation.with_hooks({some_hook_def}),
keys_by_input_name={"input": AssetKey("input")},
keys_by_output_name={"result": AssetKey("some_asset")},
)an alternative solution might just be to do something like
Copy code
@asset
def my_asset():
result = None
try:
# ... do stuff
result = "something"
finally:
# things went as expected
if result is not None:
return result
else:
# ... do some error-related stuffalso, if you will only ever execute the asset via the specific job you've defined, you could just set up a run_status_sensor to alert if that job fails
r
Riccardo Tesselli
12/07/2022, 4:13 PM@owen thanks!!!
2 Views