Ed Burroughes
03/28/2023, 2:46 PMall_finished
but I am getting some unexpected behaviour. For example, if I have multiple upstream tasks like so:
@flow
def flow():
_do_something = do_something()
_do_something2 = do_something2()
_do_something3 = do_something3()
_always_run = always_run(
wait_for=[
allow_failure(_do_something),
allow_failure(_do_something2),
allow_failure(_do_something3)
]
)
return _always_run
Say if any do_something
functions fail, I would like always_run
to always implement. Currently, when I force any upstream task to fail the always_run task doesn't run. Any idea why this is and if there are any work around thanks