https://prefect.io logo
Title
e

Ed Burroughes

03/28/2023, 2:46 PM
Hello, I'm trying to implement allow_failure as a substitute for
all_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