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