Tibs
Zanie
import prefect from prefect.states import Failed @prefect.flow def foo(): bar() @prefect.task def bar(): return Failed(message="Oh no!") foo()