Hey ypwdr,
I got a pull request that will fix this problem. It works for me but I need
to fix the failing branch. Be my guest to try it out and see if it resolves
your problem.
On Wed, Jan 4, 2017 at 4:14 PM wrote:
> Hello
>
> I just became aware that failure inside a branch (BranchPythonOpera
Hello
I just became aware that failure inside a branch (BranchPythonOperator) set
the DAG state to success despites the task failure.
Indeed Airflow set all downstream tasks to the skipped state because of the
trigger_rule needed for the branching mecanism and as a consequence Airflow
wrongly
