Refactor EdFiResourceDAG.chain_task_groups_into_dag() to add a final …

edanalytics / edu_edfi_airflow

Manages extract-load of Ed-Fi data in Airflow

Other

4 stars 0 forks source link

Refactor EdFiResourceDAG.chain_task_groups_into_dag() to add a final … #20

Closed jayckaiser closed 1 year ago

jayckaiser commented 1 year ago

…state sentinel that outputs the state of the DAG, depending on the success of all upstream tasks; unchain cv_update_operator and dbt_increment_var_operator.