I want a task to run and then, if it fails, I don't want the final state of my flow to be failed (i.e. I want to silence that failed task). I've tried:
Copy code
@flow
def foo():
future = some_task(**some_kwargs).submit() # should **some_kwargs be used in submit?
future.result(raise_on_failure=False)
When
some_task
fails, it ends up failing the flow; what am I doing wrong?
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.