airflow.example_dags.example_nested_branch_dag

Example DAG demonstrating a workflow with nested branching. The join tasks are created with none_failed_min_one_success trigger rule such that they are skipped whenever their corresponding branching tasks are skipped.

Module Contents

Functions

branch(task_id_to_return)

airflow.example_dags.example_nested_branch_dag.branch(task_id_to_return)[source]

Was this entry helpful?