def flow_fail(task, old_state, new_state):
    if new_state.is_failed():
        return_state = Failed()
        raise signals.SKIP(
                message="Skip this task and any downstream tasks.",
                result=[])
    else:
        return_state = new_state
    return return_state

 state = nodes_flow.run(state_handlers=[flow_fail])