merlin
11/01/2022, 9:04 PM@task
def fail_task():
return Failed()
@flow
def fail_flow_i_hope():
fail_task()
fail_flow_i_hope()
11:42:32.292 | DEBUG | Task run 'always_fail_task-d83fd752-0' - Beginning execution...
11:42:32.302 | INFO | Task run 'always_fail_task-d83fd752-0' - Finished in state Completed()
...
11:42:32.313 | INFO | Flow run 'ludicrous-lemur' - Finished in state Completed('All states completed.')
I'd like a task to fail, and then do retries (or not) but end the steps in the flow, with the flow also failed.Mason Menges
11/01/2022, 9:06 PM@task
def fail_task():
# you could really raise any exception here
raise ValueError
@flow
def fail_flow_i_hope():
fail_task()
fail_flow_i_hope()
merlin
11/01/2022, 9:13 PM