Hello.
My DAG is as follow :
D
/ \
A -- B -- C F -- G
\ /
E
I have a case where the C BranchPythonOperator fails so that it is not able
to tell Airflow which child task must be executed. The result is : D & E
are in UP_FOR_RETRY state and F & G are in SKIPPED state.
The issue is, because of the last SKIPPED state, Airflow considers the
whole DAG to have succeeded whereras it has not.
The FAILED state is not propagated to downstream tasks. Is it intended
behaviour ?
Regards.
At moment, I want my privacy to be protected.
https://mytemp.email/
