Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-04-03T21:00:00+00:00 PythonOperator 2021-04-03T22:00:08.349493+00:00 2021-04-03T22:00:11.106201+00:00 0:00:02.756708 13258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T22:00:05.621360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T20:00:00+00:00 TriggerDagRunOperator 2021-04-03T21:20:18.290719+00:00 2021-04-03T21:20:18.806878+00:00 0:00:00.516159 13250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:20:15.735328+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T20:00:00+00:00 TriggerDagRunOperator 2021-04-03T21:20:17.903870+00:00 2021-04-03T21:20:18.306565+00:00 0:00:00.402695 13249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:20:15.735363+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T20:00:00+00:00 EmrJobFlowSensor 2021-04-03T21:01:00.290843+00:00 2021-04-03T21:20:04.403914+00:00 0:19:04.113071 13245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:00:57.810605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:00:38.016905+00:00 2021-04-03T21:00:39.700219+00:00 0:00:01.683314 13244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T21:00:35.788474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T20:00:00+00:00 PythonOperator 2021-04-03T21:00:16.348911+00:00 2021-04-03T21:00:19.233348+00:00 0:00:02.884437 13243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T21:00:13.765567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T19:00:00+00:00 TriggerDagRunOperator 2021-04-03T20:10:13.217521+00:00 2021-04-03T20:10:13.735485+00:00 0:00:00.517964 13235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:10:10.793946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T19:00:00+00:00 TriggerDagRunOperator 2021-04-03T20:10:13.001688+00:00 2021-04-03T20:10:13.403277+00:00 0:00:00.401589 13234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:10:10.793982+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:00:56.548535+00:00 2021-04-03T20:09:59.295034+00:00 0:09:02.746499 13230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:00:53.871178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:00:34.482917+00:00 2021-04-03T20:00:36.281035+00:00 0:00:01.798118 13229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T20:00:31.791323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:00:14.251404+00:00 2021-04-03T20:00:17.010797+00:00 0:00:02.759393 13228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T20:00:11.753961+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T18:00:00+00:00 TriggerDagRunOperator 2021-04-03T19:13:23.396584+00:00 2021-04-03T19:13:24.261793+00:00 0:00:00.865209 13219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:13:21.008463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T18:00:00+00:00 TriggerDagRunOperator 2021-04-03T19:13:23.312018+00:00 2021-04-03T19:13:23.905107+00:00 0:00:00.593089 13218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T19:13:21.008435+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T18:00:00+00:00 EmrJobFlowSensor 2021-04-03T19:00:57.996930+00:00 2021-04-03T19:13:01.035803+00:00 0:12:03.038873 13214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T19:00:55.797484+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T19:00:38.051052+00:00 2021-04-03T19:00:39.769397+00:00 0:00:01.718345 13213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T19:00:35.748432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T18:00:00+00:00 PythonOperator 2021-04-03T19:00:16.159958+00:00 2021-04-03T19:00:18.937735+00:00 0:00:02.777777 13212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T19:00:13.725417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T17:00:00+00:00 TriggerDagRunOperator 2021-04-03T18:09:25.459407+00:00 2021-04-03T18:09:25.989532+00:00 0:00:00.530125 13204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:09:22.965669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T17:00:00+00:00 TriggerDagRunOperator 2021-04-03T18:09:25.378641+00:00 2021-04-03T18:09:25.847213+00:00 0:00:00.468572 13203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T18:09:22.965716+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T17:00:00+00:00 EmrJobFlowSensor 2021-04-03T18:01:06.215726+00:00 2021-04-03T18:09:08.851714+00:00 0:08:02.635988 13199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T18:01:03.913983+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T18:00:42.126831+00:00 2021-04-03T18:00:43.830751+00:00 0:00:01.703920 13198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T18:00:39.891818+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T17:00:00+00:00 PythonOperator 2021-04-03T18:00:22.347269+00:00 2021-04-03T18:00:25.265077+00:00 0:00:02.917808 13197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T18:00:19.874896+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T16:00:00+00:00 TriggerDagRunOperator 2021-04-03T17:10:18.221407+00:00 2021-04-03T17:10:18.738570+00:00 0:00:00.517163 13189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:10:15.751338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T16:00:00+00:00 TriggerDagRunOperator 2021-04-03T17:10:17.997355+00:00 2021-04-03T17:10:18.434058+00:00 0:00:00.436703 13188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T17:10:15.751375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T16:00:00+00:00 EmrJobFlowSensor 2021-04-03T17:01:05.171200+00:00 2021-04-03T17:10:07.877598+00:00 0:09:02.706398 13184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T17:01:02.882951+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T17:00:43.083559+00:00 2021-04-03T17:00:44.753500+00:00 0:00:01.669941 13183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T17:00:40.791856+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T16:00:00+00:00 PythonOperator 2021-04-03T17:00:22.899522+00:00 2021-04-03T17:00:25.610925+00:00 0:00:02.711403 13182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T17:00:20.739248+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T15:00:00+00:00 TriggerDagRunOperator 2021-04-03T16:25:06.628031+00:00 2021-04-03T16:25:07.503383+00:00 0:00:00.875352 13173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:00.759501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T15:00:00+00:00 TriggerDagRunOperator 2021-04-03T16:25:06.571088+00:00 2021-04-03T16:25:07.164569+00:00 0:00:00.593481 13172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T16:25:00.759514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T15:00:00+00:00 EmrJobFlowSensor 2021-04-03T16:01:00.111370+00:00 2021-04-03T16:11:03.157186+00:00 0:10:03.045816 13169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T16:00:57.427199+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T16:00:37.903110+00:00 2021-04-03T16:00:39.763757+00:00 0:00:01.860647 13168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T16:00:35.401809+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T15:00:00+00:00 PythonOperator 2021-04-03T16:00:17.654904+00:00 2021-04-03T16:00:20.385393+00:00 0:00:02.730489 13167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T16:00:15.380283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T14:00:00+00:00 TriggerDagRunOperator 2021-04-03T15:10:14.290774+00:00 2021-04-03T15:10:14.844282+00:00 0:00:00.553508 13160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:10:11.872904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T14:00:00+00:00 TriggerDagRunOperator 2021-04-03T15:10:14.254982+00:00 2021-04-03T15:10:14.671178+00:00 0:00:00.416196 13159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T15:10:11.872934+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T14:00:00+00:00 EmrJobFlowSensor 2021-04-03T15:01:04.723472+00:00 2021-04-03T15:10:07.413354+00:00 0:09:02.689882 13154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T15:01:02.408559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T15:00:40.626950+00:00 2021-04-03T15:00:42.298926+00:00 0:00:01.671976 13153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T15:00:38.378078+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T14:00:00+00:00 PythonOperator 2021-04-03T15:00:20.847166+00:00 2021-04-03T15:00:23.750643+00:00 0:00:02.903477 13152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T15:00:18.368824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T13:00:00+00:00 TriggerDagRunOperator 2021-04-03T14:12:30.175513+00:00 2021-04-03T14:12:30.756845+00:00 0:00:00.581332 13145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:12:27.403826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T13:00:00+00:00 TriggerDagRunOperator 2021-04-03T14:12:29.843628+00:00 2021-04-03T14:12:30.262540+00:00 0:00:00.418912 13144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T14:12:27.403780+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T13:00:00+00:00 EmrJobFlowSensor 2021-04-03T14:03:14.919232+00:00 2021-04-03T14:12:17.649367+00:00 0:09:02.730135 13140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T14:03:12.527184+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T14:02:50.803336+00:00 2021-04-03T14:02:52.589801+00:00 0:00:01.786465 13139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T14:02:48.496286+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T13:00:00+00:00 PythonOperator 2021-04-03T14:00:18.348853+00:00 2021-04-03T14:00:21.086420+00:00 0:00:02.737567 13137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T14:00:16.146924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T12:00:00+00:00 TriggerDagRunOperator 2021-04-03T13:10:43.763979+00:00 2021-04-03T13:10:44.286634+00:00 0:00:00.522655 13130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:10:41.251131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T12:00:00+00:00 TriggerDagRunOperator 2021-04-03T13:10:43.668133+00:00 2021-04-03T13:10:44.230560+00:00 0:00:00.562427 13129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:10:41.251099+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T12:00:00+00:00 EmrJobFlowSensor 2021-04-03T13:01:34.660847+00:00 2021-04-03T13:10:37.291892+00:00 0:09:02.631045 13125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:01:32.436201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:01:12.731903+00:00 2021-04-03T13:01:14.420882+00:00 0:00:01.688979 13124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T13:01:10.381219+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T12:00:00+00:00 PythonOperator 2021-04-03T13:00:52.771125+00:00 2021-04-03T13:00:55.630198+00:00 0:00:02.859073 13123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T13:00:50.355010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T11:00:00+00:00 TriggerDagRunOperator 2021-04-03T12:10:18.179760+00:00 2021-04-03T12:10:18.737215+00:00 0:00:00.557455 13115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:10:15.807247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T11:00:00+00:00 TriggerDagRunOperator 2021-04-03T12:10:18.020949+00:00 2021-04-03T12:10:18.423106+00:00 0:00:00.402157 13114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:10:15.807213+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T11:00:00+00:00 EmrJobFlowSensor 2021-04-03T12:00:55.459721+00:00 2021-04-03T12:09:58.293362+00:00 0:09:02.833641 13110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:00:52.940884+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:00:33.231197+00:00 2021-04-03T12:00:34.968728+00:00 0:00:01.737531 13109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T12:00:30.866166+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T11:00:00+00:00 PythonOperator 2021-04-03T12:00:13.098756+00:00 2021-04-03T12:00:15.801771+00:00 0:00:02.703015 13108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T12:00:10.798905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T10:00:00+00:00 TriggerDagRunOperator 2021-04-03T11:11:18.058639+00:00 2021-04-03T11:11:18.650358+00:00 0:00:00.591719 13100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:11:15.654997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T10:00:00+00:00 TriggerDagRunOperator 2021-04-03T11:11:17.912331+00:00 2021-04-03T11:11:18.559014+00:00 0:00:00.646683 13099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:11:15.654963+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T10:00:00+00:00 EmrJobFlowSensor 2021-04-03T11:01:05.031970+00:00 2021-04-03T11:11:07.833000+00:00 0:10:02.801030 13095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:01:02.814752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:00:43.101160+00:00 2021-04-03T11:00:44.766341+00:00 0:00:01.665181 13094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T11:00:40.795181+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T10:00:00+00:00 PythonOperator 2021-04-03T11:00:21.629893+00:00 2021-04-03T11:00:24.555713+00:00 0:00:02.925820 13093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T11:00:18.772559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T09:00:00+00:00 TriggerDagRunOperator 2021-04-03T10:09:18.662292+00:00 2021-04-03T10:09:19.335310+00:00 0:00:00.673018 13085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:09:16.048637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T09:00:00+00:00 TriggerDagRunOperator 2021-04-03T10:09:18.296803+00:00 2021-04-03T10:09:18.729698+00:00 0:00:00.432895 13084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:09:16.048674+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:01:05.714149+00:00 2021-04-03T10:09:08.387605+00:00 0:08:02.673456 13080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:01:03.342512+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:00:45.543173+00:00 2021-04-03T10:00:47.271738+00:00 0:00:01.728565 13079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T10:00:43.251617+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T09:00:00+00:00 PythonOperator 2021-04-03T10:00:23.807227+00:00 2021-04-03T10:00:26.594550+00:00 0:00:02.787323 13078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T10:00:21.234836+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T08:00:00+00:00 TriggerDagRunOperator 2021-04-03T09:09:28.942804+00:00 2021-04-03T09:09:29.503759+00:00 0:00:00.560955 13070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:09:26.285917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T08:00:00+00:00 TriggerDagRunOperator 2021-04-03T09:09:28.752335+00:00 2021-04-03T09:09:29.150075+00:00 0:00:00.397740 13069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:09:26.285866+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T08:00:00+00:00 EmrJobFlowSensor 2021-04-03T09:01:05.789275+00:00 2021-04-03T09:09:08.422139+00:00 0:08:02.632864 13065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:01:03.444342+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:00:43.589904+00:00 2021-04-03T09:00:45.352163+00:00 0:00:01.762259 13064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T09:00:41.245367+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T08:00:00+00:00 PythonOperator 2021-04-03T09:00:23.640196+00:00 2021-04-03T09:00:26.510034+00:00 0:00:02.869838 13063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T09:00:21.186755+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T07:00:00+00:00 TriggerDagRunOperator 2021-04-03T08:11:00.313349+00:00 2021-04-03T08:11:00.874915+00:00 0:00:00.561566 13055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:10:57.879188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T07:00:00+00:00 TriggerDagRunOperator 2021-04-03T08:11:00.294180+00:00 2021-04-03T08:11:00.762353+00:00 0:00:00.468173 13054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:10:57.879152+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T07:00:00+00:00 EmrJobFlowSensor 2021-04-03T08:00:52.890634+00:00 2021-04-03T08:10:55.691278+00:00 0:10:02.800644 13050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:00:50.689622+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:00:32.927547+00:00 2021-04-03T08:00:34.776432+00:00 0:00:01.848885 13049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T08:00:30.658984+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T07:00:00+00:00 PythonOperator 2021-04-03T08:00:10.923863+00:00 2021-04-03T08:00:13.853681+00:00 0:00:02.929818 13048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T08:00:08.591893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T06:00:00+00:00 TriggerDagRunOperator 2021-04-03T07:10:16.109604+00:00 2021-04-03T07:10:16.657131+00:00 0:00:00.547527 13040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:10:13.809417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T06:00:00+00:00 TriggerDagRunOperator 2021-04-03T07:10:16.043664+00:00 2021-04-03T07:10:16.435073+00:00 0:00:00.391409 13039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:10:13.809453+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T06:00:00+00:00 EmrJobFlowSensor 2021-04-03T07:00:52.923857+00:00 2021-04-03T07:09:55.620092+00:00 0:09:02.696235 13035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:00:50.622715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:00:30.938049+00:00 2021-04-03T07:00:32.811865+00:00 0:00:01.873816 13034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T07:00:28.607397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T06:00:00+00:00 PythonOperator 2021-04-03T07:00:09.319524+00:00 2021-04-03T07:00:12.237709+00:00 0:00:02.918185 13033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T07:00:06.646194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T05:00:00+00:00 TriggerDagRunOperator 2021-04-03T06:11:10.461315+00:00 2021-04-03T06:11:11.039822+00:00 0:00:00.578507 13025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:11:07.996097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T05:00:00+00:00 TriggerDagRunOperator 2021-04-03T06:11:10.401863+00:00 2021-04-03T06:11:10.953020+00:00 0:00:00.551157 13024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:11:07.996057+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T05:00:00+00:00 EmrJobFlowSensor 2021-04-03T06:00:57.337755+00:00 2021-04-03T06:11:00.051453+00:00 0:10:02.713698 13020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T06:00:55.060908+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T06:00:37.334256+00:00 2021-04-03T06:00:39.132760+00:00 0:00:01.798504 13019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T06:00:35.044927+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T05:00:00+00:00 PythonOperator 2021-04-03T06:00:15.678347+00:00 2021-04-03T06:00:18.404053+00:00 0:00:02.725706 13018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T06:00:13.155761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T04:00:00+00:00 TriggerDagRunOperator 2021-04-03T05:09:10.853132+00:00 2021-04-03T05:09:11.365364+00:00 0:00:00.512232 13010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:09:08.256520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T04:00:00+00:00 TriggerDagRunOperator 2021-04-03T05:09:10.591837+00:00 2021-04-03T05:09:10.998800+00:00 0:00:00.406963 13009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:09:08.256488+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T04:00:00+00:00 EmrJobFlowSensor 2021-04-03T05:01:01.325284+00:00 2021-04-03T05:09:04.084811+00:00 0:08:02.759527 13005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:00:59.092593+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:00:39.201011+00:00 2021-04-03T05:00:40.963196+00:00 0:00:01.762185 13004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T05:00:37.015122+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T04:00:00+00:00 PythonOperator 2021-04-03T05:00:19.553062+00:00 2021-04-03T05:00:22.395218+00:00 0:00:02.842156 13003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T05:00:16.996996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T03:00:00+00:00 TriggerDagRunOperator 2021-04-03T04:11:21.258220+00:00 2021-04-03T04:11:21.810953+00:00 0:00:00.552733 12995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:11:18.754095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T03:00:00+00:00 TriggerDagRunOperator 2021-04-03T04:11:21.215493+00:00 2021-04-03T04:11:21.648865+00:00 0:00:00.433372 12994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:11:18.754143+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T03:00:00+00:00 EmrJobFlowSensor 2021-04-03T04:00:57.818546+00:00 2021-04-03T04:11:00.619075+00:00 0:10:02.800529 12990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:00:55.533433+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:00:33.890061+00:00 2021-04-03T04:00:35.684434+00:00 0:00:01.794373 12989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T04:00:31.535223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T03:00:00+00:00 PythonOperator 2021-04-03T04:00:09.779988+00:00 2021-04-03T04:00:12.515866+00:00 0:00:02.735878 12988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T04:00:07.496188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T02:00:00+00:00 TriggerDagRunOperator 2021-04-03T03:10:14.336439+00:00 2021-04-03T03:10:14.748456+00:00 0:00:00.412017 12980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:10:11.827147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T02:00:00+00:00 TriggerDagRunOperator 2021-04-03T03:10:14.355502+00:00 2021-04-03T03:10:14.904565+00:00 0:00:00.549063 12979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:10:11.827181+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T02:00:00+00:00 EmrJobFlowSensor 2021-04-03T03:00:57.206068+00:00 2021-04-03T03:09:59.924775+00:00 0:09:02.718707 12975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:00:54.940877+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:00:35.382806+00:00 2021-04-03T03:00:37.203333+00:00 0:00:01.820527 12974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T03:00:32.843832+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T02:00:00+00:00 PythonOperator 2021-04-03T03:00:12.983727+00:00 2021-04-03T03:00:15.707589+00:00 0:00:02.723862 12973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T03:00:10.717276+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T01:00:00+00:00 TriggerDagRunOperator 2021-04-03T02:09:29.639441+00:00 2021-04-03T02:09:30.164098+00:00 0:00:00.524657 12965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:09:27.006306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T01:00:00+00:00 TriggerDagRunOperator 2021-04-03T02:09:29.407585+00:00 2021-04-03T02:09:29.871259+00:00 0:00:00.463674 12964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:09:27.006276+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T01:00:00+00:00 EmrJobFlowSensor 2021-04-03T02:01:12.592586+00:00 2021-04-03T02:09:15.198978+00:00 0:08:02.606392 12960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:01:10.287195+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:00:44.430249+00:00 2021-04-03T02:00:46.180949+00:00 0:00:01.750700 12959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T02:00:42.222580+00:00 2 default_pool