1

I have following workflow, except the branching tasks all the other tasks are implemented using dummy operators.

But without completing descending tasks workflow is move to complete state. Graph view of the workflow

Tree view of the workflow

Is there any particular reason(s) for not executing (skipping) descending tasks?

Hasitha
  • 558
  • 1
  • 12
  • 26

1 Answers1

0

Found the reason and the solution in the airflow documentation using the triggering rules option. According to the documentation

In the case of this DAG, join is downstream of follow_branch_a and branch_false. The join task will show up as skipped because its trigger_rule is set to all_success by default and skipped tasks will cascade through all_success.

So I have added trigger_rule='none_failed' to dss4_dummy, branch3 and end_routine tasks. Which gave me expected results as follows.

enter image description here

Hasitha
  • 558
  • 1
  • 12
  • 26