https://dagster.io/ logo
#ask-community
Title
# ask-community
e

Eugenio Contreras

05/02/2023, 12:25 PM
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 😅)
Copy code
[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:
Copy code
op1 >> op5
op2 >> op5
op3 >> op5
...
Thanks!
y

yuhan

05/04/2023, 5:06 PM
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
.
2 Views