staging_area_example_USAGE.py

from airflow import DAG
from lib.operators.trigger_and_wait_for_completion import trigger_dag

with DAG(dag_id='business_logic',
         default_args=None,  # None only for demonstration purposes - this shouldn't be None
         schedule_interval=None) as dag:
    staging_area = trigger_dag(task_id='staging_area',
                               trigger_dag_id='staging_area',
                               wait_for_task='finish')
    bus_logic_child_dag, wait_for_bus_logic = trigger_dag(task_id='business_logic_layer',
                                                          trigger_dag_id='business_logic_layer',
                                                          wait_for_task='finish')
    data_mart = trigger_dag(task_id='data_mart',
                            trigger_dag_id='data_mart',
                            wait_for_task='finish')

    staging_area >> bus_logic_child_dag >> wait_for_bus_logic >> data_mart