run sdr agg in parallel to agg_awc

saiprakash-v · Mar 5, 2020 · 22fd6dd · 22fd6dd
1 parent 723b1f2
commit 22fd6dd
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/dags/dashboard_subdags.py b/dags/dashboard_subdags.py
@@ -191,10 +191,11 @@ def generate_uuid():
     agg_child_health_temp >> agg_awc_table
     child_health_monthly >> agg_awc_table
     agg_ccs_record >> agg_awc_table
+    agg_child_health_temp >> update_service_delivery_report
+    child_health_monthly >> update_service_delivery_report
+    agg_ccs_record >> update_service_delivery_report
     agg_awc_table >> ls_tasks
-    agg_awc_table >> update_service_delivery_report
     ls_tasks >> agg_ls_table
-    update_service_delivery_report >> agg_ls_table
 
     if interval == 0:
         aggregate_awc_daily = BashOperator(