Hey all. I have a question regarding downstream ops behavior. I have a bunch of ops that are pointing to one downstream op, like this (following an Airflow concept 😅)

[op1, op2, op3, op4] >> op5

Is there a way to execute op5 even though one of the previous ops failed? The code in op5 is able to handle the failures, so that's not a problem. I want to avoid as much as I can the following pattern:

op1 >> op5
op2 >> op5
op3 >> op5
...

Thanks!

there are two options: • conditional branching: you can configure an op to have optional output and catch the error to not yield anything, then the downstream can skip that upstream • fan in: you can also set it so

op5

takes one single input which is

[op1, op2, op3, op4]

, and

op1

can have an optional output, then when it’s

[op2, op3, op4]

, it would still go through to

op5

.