Added gov dashboard aggregation step to airflow

saiprakash-v · Jan 16, 2020 · 124961e · 124961e
1 parent 57863f5
commit 124961e
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/dags/dashboard_subdags.py b/dags/dashboard_subdags.py
@@ -201,8 +201,16 @@ def generate_uuid():
             params={'query': 'create_mbt_for_month'},
             dag=monthly_dag
         )
+        governance_dashboard = BashOperator(
+            task_id='update_governance_dashboard',
+            bash_command=run_query_template,
+            params={'query': 'update_governance_dashboard'},
+            dag=monthly_dag
+        )
         aggregate_awc_daily >> create_mbt
         update_child_health_monthly_table >> create_mbt
         agg_ls_table >> create_mbt
 
+        create_mbt >> governance_dashboard
+
     return monthly_dag