import prefect
from prefect.states import Failed


@prefect.flow
def foo():
    bar()


@prefect.task
def bar():
    return Failed(message="Oh no!")


foo()