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-01T09:00:00+00:00 PythonOperator 2021-04-01T10:00:18.466506+00:00 2021-04-01T10:00:21.302408+00:00 0:00:02.835902 12358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T10:00:15.882955+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T08:00:00+00:00 TriggerDagRunOperator 2021-04-01T09:18:00.670337+00:00 2021-04-01T09:18:01.096632+00:00 0:00:00.426295 12351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:17:57.983193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T08:00:00+00:00 TriggerDagRunOperator 2021-04-01T09:18:00.679113+00:00 2021-04-01T09:18:01.203499+00:00 0:00:00.524386 12350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:17:57.983220+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:01:03.918941+00:00 2021-04-01T09:15:07.350870+00:00 0:14:03.431929 12345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:01:01.591451+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:00:41.709460+00:00 2021-04-01T09:00:43.423402+00:00 0:00:01.713942 12344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T09:00:39.549774+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:00:19.673721+00:00 2021-04-01T09:00:22.383540+00:00 0:00:02.709819 12343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T09:00:17.477691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T07:00:00+00:00 TriggerDagRunOperator 2021-04-01T08:17:05.620360+00:00 2021-04-01T08:17:06.067764+00:00 0:00:00.447404 12336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:17:02.832208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T07:00:00+00:00 TriggerDagRunOperator 2021-04-01T08:17:05.408787+00:00 2021-04-01T08:17:06.005191+00:00 0:00:00.596404 12335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:17:02.832179+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:00:55.241494+00:00 2021-04-01T08:16:58.760596+00:00 0:16:03.519102 12330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:00:52.900154+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:00:33.149024+00:00 2021-04-01T08:00:34.830519+00:00 0:00:01.681495 12329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T08:00:30.866082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:00:11.209819+00:00 2021-04-01T08:00:13.990249+00:00 0:00:02.780430 12328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T08:00:08.863725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T06:00:00+00:00 TriggerDagRunOperator 2021-04-01T07:12:56.263666+00:00 2021-04-01T07:12:56.786369+00:00 0:00:00.522703 12321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:12:53.810978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T06:00:00+00:00 TriggerDagRunOperator 2021-04-01T07:12:56.045751+00:00 2021-04-01T07:12:56.459134+00:00 0:00:00.413383 12320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:12:53.811007+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:01:15.576380+00:00 2021-04-01T07:11:18.444671+00:00 0:10:02.868291 12315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:01:13.290033+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:00:51.570536+00:00 2021-04-01T07:00:53.373486+00:00 0:00:01.802950 12314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T07:00:49.269788+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:00:27.548746+00:00 2021-04-01T07:00:30.266755+00:00 0:00:02.718009 12313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T07:00:25.275233+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T05:00:00+00:00 TriggerDagRunOperator 2021-04-01T06:10:29.128092+00:00 2021-04-01T06:10:29.675417+00:00 0:00:00.547325 12306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:10:26.310664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T05:00:00+00:00 TriggerDagRunOperator 2021-04-01T06:10:28.925518+00:00 2021-04-01T06:10:29.347993+00:00 0:00:00.422475 12305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:10:26.310637+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:01:02.631103+00:00 2021-04-01T06:10:05.327143+00:00 0:09:02.696040 12300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:01:00.380715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:00:40.565336+00:00 2021-04-01T06:00:42.375533+00:00 0:00:01.810197 12299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T06:00:38.296448+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:00:20.529161+00:00 2021-04-01T06:00:23.249023+00:00 0:00:02.719862 12298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T06:00:18.241804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T04:00:00+00:00 TriggerDagRunOperator 2021-04-01T05:10:17.943409+00:00 2021-04-01T05:10:18.482341+00:00 0:00:00.538932 12291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:10:15.270693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T04:00:00+00:00 TriggerDagRunOperator 2021-04-01T05:10:17.636372+00:00 2021-04-01T05:10:18.050885+00:00 0:00:00.414513 12290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:10:15.270731+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T04:00:00+00:00 EmrJobFlowSensor 2021-04-01T05:01:03.568998+00:00 2021-04-01T05:10:06.306620+00:00 0:09:02.737622 12285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:01:01.154968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:00:39.703760+00:00 2021-04-01T05:00:41.481725+00:00 0:00:01.777965 12284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T05:00:37.175350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T04:00:00+00:00 PythonOperator 2021-04-01T05:00:19.641469+00:00 2021-04-01T05:00:22.367466+00:00 0:00:02.725997 12283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T05:00:17.093780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T03:00:00+00:00 TriggerDagRunOperator 2021-04-01T04:12:20.920521+00:00 2021-04-01T04:12:21.332754+00:00 0:00:00.412233 12276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:12:18.356273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T03:00:00+00:00 TriggerDagRunOperator 2021-04-01T04:12:20.727973+00:00 2021-04-01T04:12:21.253699+00:00 0:00:00.525726 12275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:12:18.356349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T03:00:00+00:00 EmrJobFlowSensor 2021-04-01T04:03:07.952201+00:00 2021-04-01T04:12:10.612355+00:00 0:09:02.660154 12271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:03:05.563828+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:02:39.728759+00:00 2021-04-01T04:02:41.422565+00:00 0:00:01.693806 12270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T04:02:37.511269+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:02:17.818538+00:00 2021-04-01T04:02:20.574514+00:00 0:00:02.755976 12269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T04:02:15.490681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T02:00:00+00:00 TriggerDagRunOperator 2021-04-01T03:11:03.924114+00:00 2021-04-01T03:11:04.361984+00:00 0:00:00.437870 12261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:11:01.553883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T02:00:00+00:00 TriggerDagRunOperator 2021-04-01T03:11:03.902373+00:00 2021-04-01T03:11:04.484108+00:00 0:00:00.581735 12260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:11:01.553915+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T02:00:00+00:00 EmrJobFlowSensor 2021-04-01T03:00:54.854891+00:00 2021-04-01T03:10:57.634113+00:00 0:10:02.779222 12256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:00:52.494237+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:00:34.674817+00:00 2021-04-01T03:00:36.371078+00:00 0:00:01.696261 12255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T03:00:32.449952+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T02:00:00+00:00 PythonOperator 2021-04-01T03:00:12.837654+00:00 2021-04-01T03:00:15.568722+00:00 0:00:02.731068 12254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T03:00:10.430746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T01:00:00+00:00 TriggerDagRunOperator 2021-04-01T02:11:08.139683+00:00 2021-04-01T02:11:08.705961+00:00 0:00:00.566278 12246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:11:05.584696+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T01:00:00+00:00 TriggerDagRunOperator 2021-04-01T02:11:07.970829+00:00 2021-04-01T02:11:08.382326+00:00 0:00:00.411497 12245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:11:05.584664+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T01:00:00+00:00 EmrJobFlowSensor 2021-04-01T02:00:50.798903+00:00 2021-04-01T02:10:53.624650+00:00 0:10:02.825747 12241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:00:48.481740+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:00:30.973226+00:00 2021-04-01T02:00:32.695345+00:00 0:00:01.722119 12240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T02:00:28.557678+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T01:00:00+00:00 PythonOperator 2021-04-01T02:00:09.258182+00:00 2021-04-01T02:00:12.136915+00:00 0:00:02.878733 12239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T02:00:06.390566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T00:00:00+00:00 TriggerDagRunOperator 2021-04-01T01:10:22.098398+00:00 2021-04-01T01:10:22.498333+00:00 0:00:00.399935 12231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:10:19.817178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T00:00:00+00:00 TriggerDagRunOperator 2021-04-01T01:10:22.115200+00:00 2021-04-01T01:10:22.756828+00:00 0:00:00.641628 12230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:10:19.817213+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T00:00:00+00:00 EmrJobFlowSensor 2021-04-01T01:00:55.138507+00:00 2021-04-01T01:09:57.859787+00:00 0:09:02.721280 12226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T01:00:52.834103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T01:00:33.123039+00:00 2021-04-01T01:00:34.947292+00:00 0:00:01.824253 12225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T01:00:30.814489+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T00:00:00+00:00 PythonOperator 2021-04-01T01:00:11.260377+00:00 2021-04-01T01:00:14.037546+00:00 0:00:02.777169 12224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T01:00:08.800565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T23:00:00+00:00 TriggerDagRunOperator 2021-04-01T00:11:06.735676+00:00 2021-04-01T00:11:07.234167+00:00 0:00:00.498491 12216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:11:04.030959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T23:00:00+00:00 TriggerDagRunOperator 2021-04-01T00:11:06.223634+00:00 2021-04-01T00:11:06.632401+00:00 0:00:00.408767 12215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:11:04.030992+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T23:00:00+00:00 EmrJobFlowSensor 2021-04-01T00:00:57.606862+00:00 2021-04-01T00:11:00.406859+00:00 0:10:02.799997 12211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:00:55.332367+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:00:37.637197+00:00 2021-04-01T00:00:39.454693+00:00 0:00:01.817496 12210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T00:00:35.315027+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T23:00:00+00:00 PythonOperator 2021-04-01T00:00:03.633240+00:00 2021-04-01T00:00:06.477073+00:00 0:00:02.843833 12209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T00:00:01.284056+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T22:00:00+00:00 TriggerDagRunOperator 2021-03-31T23:11:02.571136+00:00 2021-03-31T23:11:03.288803+00:00 0:00:00.717667 12201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:11:00.093962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T22:00:00+00:00 TriggerDagRunOperator 2021-03-31T23:11:02.377303+00:00 2021-03-31T23:11:02.835053+00:00 0:00:00.457750 12200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:11:00.093928+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T22:00:00+00:00 EmrJobFlowSensor 2021-03-31T23:00:49.411251+00:00 2021-03-31T23:10:52.390451+00:00 0:10:02.979200 12196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:00:47.030932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:00:27.294368+00:00 2021-03-31T23:00:29.107023+00:00 0:00:01.812655 12195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T23:00:25.006361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T22:00:00+00:00 PythonOperator 2021-03-31T23:00:07.289510+00:00 2021-03-31T23:00:10.040561+00:00 0:00:02.751051 12194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T23:00:04.987123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T21:00:00+00:00 TriggerDagRunOperator 2021-03-31T22:11:29.025081+00:00 2021-03-31T22:11:29.561027+00:00 0:00:00.535946 12186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:11:26.544800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T21:00:00+00:00 TriggerDagRunOperator 2021-03-31T22:11:28.888016+00:00 2021-03-31T22:11:29.300898+00:00 0:00:00.412882 12185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:11:26.544830+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T21:00:00+00:00 EmrJobFlowSensor 2021-03-31T22:00:53.807986+00:00 2021-03-31T22:10:56.640402+00:00 0:10:02.832416 12181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:00:51.633166+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:00:32.037765+00:00 2021-03-31T22:00:33.719758+00:00 0:00:01.681993 12180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T22:00:29.668714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T21:00:00+00:00 PythonOperator 2021-03-31T22:00:10.102942+00:00 2021-03-31T22:00:12.815788+00:00 0:00:02.712846 12179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T22:00:07.657862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T20:00:00+00:00 TriggerDagRunOperator 2021-03-31T21:10:19.333237+00:00 2021-03-31T21:10:19.899079+00:00 0:00:00.565842 12171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:10:16.758123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T20:00:00+00:00 TriggerDagRunOperator 2021-03-31T21:10:19.260731+00:00 2021-03-31T21:10:19.681999+00:00 0:00:00.421268 12170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:10:16.758154+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T20:00:00+00:00 EmrJobFlowSensor 2021-03-31T21:01:08.258728+00:00 2021-03-31T21:10:11.012891+00:00 0:09:02.754163 12166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T21:01:06.042331+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T21:00:44.364334+00:00 2021-03-31T21:00:46.188465+00:00 0:00:01.824131 12165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T21:00:42.022541+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T20:00:00+00:00 PythonOperator 2021-03-31T21:00:20.405470+00:00 2021-03-31T21:00:23.174981+00:00 0:00:02.769511 12164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T21:00:18.008575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T19:00:00+00:00 TriggerDagRunOperator 2021-03-31T20:10:11.738250+00:00 2021-03-31T20:10:12.150430+00:00 0:00:00.412180 12156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T20:10:09.059219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T19:00:00+00:00 TriggerDagRunOperator 2021-03-31T20:10:11.523202+00:00 2021-03-31T20:10:12.037404+00:00 0:00:00.514202 12155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T20:10:09.059253+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T19:00:00+00:00 EmrJobFlowSensor 2021-03-31T20:00:58.387977+00:00 2021-03-31T20:10:01.083064+00:00 0:09:02.695087 12151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T20:00:56.106351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T20:00:36.270580+00:00 2021-03-31T20:00:37.993227+00:00 0:00:01.722647 12150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T20:00:34.085658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T19:00:00+00:00 PythonOperator 2021-03-31T20:00:14.559722+00:00 2021-03-31T20:00:17.276349+00:00 0:00:02.716627 12149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T20:00:12.030174+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T18:00:00+00:00 TriggerDagRunOperator 2021-03-31T19:11:15.270380+00:00 2021-03-31T19:11:15.817800+00:00 0:00:00.547420 12141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:11:12.779686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T18:00:00+00:00 TriggerDagRunOperator 2021-03-31T19:11:15.099605+00:00 2021-03-31T19:11:15.597340+00:00 0:00:00.497735 12140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:11:12.779653+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T18:00:00+00:00 EmrJobFlowSensor 2021-03-31T19:01:08.180643+00:00 2021-03-31T19:11:10.901757+00:00 0:10:02.721114 12136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:01:05.891890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:00:46.097055+00:00 2021-03-31T19:00:47.835019+00:00 0:00:01.737964 12135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T19:00:43.823206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T18:00:00+00:00 PythonOperator 2021-03-31T19:00:12.206489+00:00 2021-03-31T19:00:15.036559+00:00 0:00:02.830070 12134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T19:00:09.792104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T17:00:00+00:00 TriggerDagRunOperator 2021-03-31T18:10:20.314556+00:00 2021-03-31T18:10:20.830483+00:00 0:00:00.515927 12126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:10:17.854863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T17:00:00+00:00 TriggerDagRunOperator 2021-03-31T18:10:20.090964+00:00 2021-03-31T18:10:20.532889+00:00 0:00:00.441925 12125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:10:17.854891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T17:00:00+00:00 EmrJobFlowSensor 2021-03-31T18:01:03.308097+00:00 2021-03-31T18:10:06.205754+00:00 0:09:02.897657 12121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:01:00.943961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:00:43.267585+00:00 2021-03-31T18:00:45.161177+00:00 0:00:01.893592 12120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T18:00:40.882981+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T17:00:00+00:00 PythonOperator 2021-03-31T18:00:21.123111+00:00 2021-03-31T18:00:23.923941+00:00 0:00:02.800830 12119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T18:00:18.855348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T16:00:00+00:00 TriggerDagRunOperator 2021-03-31T17:27:26.299460+00:00 2021-03-31T17:27:26.892042+00:00 0:00:00.592582 12111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:27:23.674683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T16:00:00+00:00 TriggerDagRunOperator 2021-03-31T17:27:26.092994+00:00 2021-03-31T17:27:26.527585+00:00 0:00:00.434591 12110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:27:23.674713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T16:00:00+00:00 EmrJobFlowSensor 2021-03-31T17:01:05.385901+00:00 2021-03-31T17:27:10.399493+00:00 0:26:05.013592 12106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T17:01:02.843724+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T17:00:43.086545+00:00 2021-03-31T17:00:44.880048+00:00 0:00:01.793503 12105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T17:00:40.721080+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T16:00:00+00:00 PythonOperator 2021-03-31T17:00:21.009753+00:00 2021-03-31T17:00:23.738203+00:00 0:00:02.728450 12104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T17:00:18.701915+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T15:00:00+00:00 TriggerDagRunOperator 2021-03-31T16:11:34.282893+00:00 2021-03-31T16:11:34.847819+00:00 0:00:00.564926 12096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T16:11:31.808785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T15:00:00+00:00 TriggerDagRunOperator 2021-03-31T16:11:34.114341+00:00 2021-03-31T16:11:34.553736+00:00 0:00:00.439395 12095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T16:11:31.808751+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T15:00:00+00:00 EmrJobFlowSensor 2021-03-31T16:01:05.245598+00:00 2021-03-31T16:11:08.242769+00:00 0:10:02.997171 12091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T16:01:02.776896+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T16:00:42.962069+00:00 2021-03-31T16:00:44.661942+00:00 0:00:01.699873 12090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T16:00:40.692623+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T15:00:00+00:00 PythonOperator 2021-03-31T16:00:21.066791+00:00 2021-03-31T16:00:23.899277+00:00 0:00:02.832486 12089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T16:00:18.658098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T14:00:00+00:00 TriggerDagRunOperator 2021-03-31T15:10:21.662035+00:00 2021-03-31T15:10:22.170090+00:00 0:00:00.508055 12081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T15:10:19.300786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T14:00:00+00:00 TriggerDagRunOperator 2021-03-31T15:10:21.586567+00:00 2021-03-31T15:10:22.022006+00:00 0:00:00.435439 12080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T15:10:19.300837+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T14:00:00+00:00 EmrJobFlowSensor 2021-03-31T15:01:04.618463+00:00 2021-03-31T15:10:07.308529+00:00 0:09:02.690066 12076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T15:01:02.391575+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T15:00:42.522598+00:00 2021-03-31T15:00:44.237748+00:00 0:00:01.715150 12075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T15:00:40.325384+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T14:00:00+00:00 PythonOperator 2021-03-31T15:00:20.517336+00:00 2021-03-31T15:00:23.269520+00:00 0:00:02.752184 12074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T15:00:18.305420+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T13:00:00+00:00 TriggerDagRunOperator 2021-03-31T14:17:34.934192+00:00 2021-03-31T14:17:35.481378+00:00 0:00:00.547186 12067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:17:32.404366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T13:00:00+00:00 TriggerDagRunOperator 2021-03-31T14:17:34.807514+00:00 2021-03-31T14:17:35.250163+00:00 0:00:00.442649 12066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:17:32.404335+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T13:00:00+00:00 EmrJobFlowSensor 2021-03-31T14:00:55.304952+00:00 2021-03-31T14:10:58.144259+00:00 0:10:02.839307 12061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:00:53.094295+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:00:35.244500+00:00 2021-03-31T14:00:36.974174+00:00 0:00:01.729674 12060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T14:00:33.060922+00:00 2 default_pool