Taqi
08/05/2022, 6:53 AM@failure_hook(required_resource_keys={'slack'})
def slack_message_on_failure(context):
message = 'op {} failed'.format(context.op.name)
context.resources.slack.send_message(message)
@failure_hook
def do_something_on_failure(context):
do_something()
owen
08/05/2022, 8:50 PM@job(..., hooks={do_something_on_failure})
def my_job():
...
see: https://docs.dagster.io/concepts/ops-jobs-graphs/op-hooks#applying-a-hook-on-every-op-in-a-jobdagster-daemon
to be running, but can catch more types of errors (such as if the job fails to start).Taqi
08/06/2022, 3:16 PM