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-29T17:00:00+00:00 PythonOperator 2021-04-29T18:00:12.116658+00:00 2021-04-29T18:00:15.171509+00:00 0:00:03.054851 22635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T18:00:09.917314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T16:00:00+00:00 TriggerDagRunOperator 2021-04-29T17:10:09.063335+00:00 2021-04-29T17:10:09.605171+00:00 0:00:00.541836 22628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T17:10:06.462740+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T16:00:00+00:00 TriggerDagRunOperator 2021-04-29T17:10:08.911662+00:00 2021-04-29T17:10:09.317779+00:00 0:00:00.406117 22627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T17:10:06.462784+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T16:00:00+00:00 EmrJobFlowSensor 2021-04-29T17:01:00.202465+00:00 2021-04-29T17:10:03.094517+00:00 0:09:02.892052 22622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T17:00:57.560459+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T17:00:39.831237+00:00 2021-04-29T17:00:41.633854+00:00 0:00:01.802617 22621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T17:00:37.484452+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T16:00:00+00:00 PythonOperator 2021-04-29T17:00:17.593719+00:00 2021-04-29T17:00:20.664353+00:00 0:00:03.070634 22620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T17:00:15.400017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T15:00:00+00:00 TriggerDagRunOperator 2021-04-29T16:10:08.415953+00:00 2021-04-29T16:10:08.914262+00:00 0:00:00.498309 22613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T16:10:06.025856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T15:00:00+00:00 TriggerDagRunOperator 2021-04-29T16:10:08.286282+00:00 2021-04-29T16:10:08.875922+00:00 0:00:00.589640 22612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T16:10:06.025887+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T15:00:00+00:00 EmrJobFlowSensor 2021-04-29T16:00:59.226668+00:00 2021-04-29T16:10:01.843094+00:00 0:09:02.616426 22607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T16:00:56.964602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T16:00:39.180251+00:00 2021-04-29T16:00:40.910129+00:00 0:00:01.729878 22606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T16:00:36.893052+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T15:00:00+00:00 PythonOperator 2021-04-29T16:00:17.110493+00:00 2021-04-29T16:00:20.116429+00:00 0:00:03.005936 22605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T16:00:14.824067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T14:00:00+00:00 TriggerDagRunOperator 2021-04-29T15:11:18.128092+00:00 2021-04-29T15:11:18.721134+00:00 0:00:00.593042 22598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T15:11:15.700018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T14:00:00+00:00 TriggerDagRunOperator 2021-04-29T15:11:17.996145+00:00 2021-04-29T15:11:18.447381+00:00 0:00:00.451236 22597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T15:11:15.700052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T14:00:00+00:00 EmrJobFlowSensor 2021-04-29T15:01:09.188673+00:00 2021-04-29T15:11:12.068350+00:00 0:10:02.879677 22592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T15:01:06.306110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T15:00:46.686944+00:00 2021-04-29T15:00:48.572432+00:00 0:00:01.885488 22591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T15:00:44.349702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T14:00:00+00:00 PythonOperator 2021-04-29T15:00:24.406036+00:00 2021-04-29T15:00:27.440241+00:00 0:00:03.034205 22590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T15:00:22.205478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T13:00:00+00:00 TriggerDagRunOperator 2021-04-29T14:12:51.282121+00:00 2021-04-29T14:12:51.876209+00:00 0:00:00.594088 22583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T14:12:49.010551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T13:00:00+00:00 TriggerDagRunOperator 2021-04-29T14:12:51.226757+00:00 2021-04-29T14:12:51.687213+00:00 0:00:00.460456 22582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T14:12:49.010592+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T13:00:00+00:00 EmrJobFlowSensor 2021-04-29T14:02:30.683178+00:00 2021-04-29T14:12:33.566880+00:00 0:10:02.883702 22578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T14:02:28.051546+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T14:02:08.028123+00:00 2021-04-29T14:02:09.861402+00:00 0:00:01.833279 22577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T14:02:05.858324+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T13:00:00+00:00 PythonOperator 2021-04-29T14:01:48.321573+00:00 2021-04-29T14:01:51.359501+00:00 0:00:03.037928 22576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T14:01:45.841949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T12:00:00+00:00 TriggerDagRunOperator 2021-04-29T13:11:15.169430+00:00 2021-04-29T13:11:15.744805+00:00 0:00:00.575375 22568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T13:11:12.574500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T12:00:00+00:00 TriggerDagRunOperator 2021-04-29T13:11:15.021897+00:00 2021-04-29T13:11:15.439215+00:00 0:00:00.417318 22567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T13:11:12.574470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T12:00:00+00:00 EmrJobFlowSensor 2021-04-29T13:01:21.937622+00:00 2021-04-29T13:10:24.766932+00:00 0:09:02.829310 22563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T13:01:19.689764+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T13:00:49.801252+00:00 2021-04-29T13:00:51.525962+00:00 0:00:01.724710 22562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T13:00:47.653737+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T12:00:00+00:00 PythonOperator 2021-04-29T13:00:28.138858+00:00 2021-04-29T13:00:31.261083+00:00 0:00:03.122225 22561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T13:00:25.635004+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T11:00:00+00:00 TriggerDagRunOperator 2021-04-29T12:10:18.839311+00:00 2021-04-29T12:10:19.371395+00:00 0:00:00.532084 22553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T12:10:16.322495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T11:00:00+00:00 TriggerDagRunOperator 2021-04-29T12:10:18.562606+00:00 2021-04-29T12:10:19.006021+00:00 0:00:00.443415 22552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T12:10:16.322454+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T11:00:00+00:00 EmrJobFlowSensor 2021-04-29T12:01:05.739217+00:00 2021-04-29T12:10:08.452419+00:00 0:09:02.713202 22548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T12:01:03.517655+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T12:00:37.713895+00:00 2021-04-29T12:00:39.408247+00:00 0:00:01.694352 22547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T12:00:35.490267+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T11:00:00+00:00 PythonOperator 2021-04-29T12:00:15.889771+00:00 2021-04-29T12:00:18.925839+00:00 0:00:03.036068 22546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T12:00:13.422501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T10:00:00+00:00 TriggerDagRunOperator 2021-04-29T11:11:00.340513+00:00 2021-04-29T11:11:00.890097+00:00 0:00:00.549584 22538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T11:10:57.847171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T10:00:00+00:00 TriggerDagRunOperator 2021-04-29T11:11:00.103099+00:00 2021-04-29T11:11:00.499239+00:00 0:00:00.396140 22537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T11:10:57.847139+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T10:00:00+00:00 EmrJobFlowSensor 2021-04-29T11:00:51.030580+00:00 2021-04-29T11:10:53.988259+00:00 0:10:02.957679 22533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T11:00:48.821499+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T11:00:29.118050+00:00 2021-04-29T11:00:30.927845+00:00 0:00:01.809795 22532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T11:00:26.804257+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T10:00:00+00:00 PythonOperator 2021-04-29T11:00:07.272959+00:00 2021-04-29T11:00:10.384721+00:00 0:00:03.111762 22531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T11:00:04.787899+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T09:00:00+00:00 TriggerDagRunOperator 2021-04-29T10:25:21.019356+00:00 2021-04-29T10:25:21.446219+00:00 0:00:00.426863 22523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T10:25:18.822007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T09:00:00+00:00 TriggerDagRunOperator 2021-04-29T10:25:21.002174+00:00 2021-04-29T10:25:21.541810+00:00 0:00:00.539636 22522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T10:25:18.822038+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T09:00:00+00:00 EmrJobFlowSensor 2021-04-29T10:01:06.548992+00:00 2021-04-29T10:25:11.323403+00:00 0:24:04.774411 22518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T10:01:04.317332+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T10:00:44.983334+00:00 2021-04-29T10:00:46.896288+00:00 0:00:01.912954 22517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T10:00:42.370752+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T09:00:00+00:00 PythonOperator 2021-04-29T10:00:24.946250+00:00 2021-04-29T10:00:27.992016+00:00 0:00:03.045766 22516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T10:00:22.284467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T08:00:00+00:00 TriggerDagRunOperator 2021-04-29T09:09:11.313681+00:00 2021-04-29T09:09:11.886612+00:00 0:00:00.572931 22508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T09:09:08.845158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T08:00:00+00:00 TriggerDagRunOperator 2021-04-29T09:09:11.289936+00:00 2021-04-29T09:09:11.943072+00:00 0:00:00.653136 22507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T09:09:08.845117+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T08:00:00+00:00 EmrJobFlowSensor 2021-04-29T09:01:04.255538+00:00 2021-04-29T09:09:07.042556+00:00 0:08:02.787018 22503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T09:01:02.040680+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T09:00:42.305921+00:00 2021-04-29T09:00:44.038852+00:00 0:00:01.732931 22502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T09:00:40.023272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T08:00:00+00:00 PythonOperator 2021-04-29T09:00:20.394963+00:00 2021-04-29T09:00:23.487465+00:00 0:00:03.092502 22501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T09:00:18.013569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T07:00:00+00:00 TriggerDagRunOperator 2021-04-29T08:10:59.726793+00:00 2021-04-29T08:11:00.192989+00:00 0:00:00.466196 22493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T08:10:57.284610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T07:00:00+00:00 TriggerDagRunOperator 2021-04-29T08:10:59.598893+00:00 2021-04-29T08:11:00.179219+00:00 0:00:00.580326 22492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T08:10:57.284576+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T07:00:00+00:00 EmrJobFlowSensor 2021-04-29T08:00:50.389254+00:00 2021-04-29T08:10:53.271285+00:00 0:10:02.882031 22488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T08:00:48.002145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T08:00:30.523168+00:00 2021-04-29T08:00:32.230059+00:00 0:00:01.706891 22487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T08:00:27.960054+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T07:00:00+00:00 PythonOperator 2021-04-29T08:00:08.208449+00:00 2021-04-29T08:00:11.315172+00:00 0:00:03.106723 22486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T08:00:05.819010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T06:00:00+00:00 TriggerDagRunOperator 2021-04-29T07:10:09.842278+00:00 2021-04-29T07:10:10.346102+00:00 0:00:00.503824 22478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T07:10:07.450013+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T06:00:00+00:00 TriggerDagRunOperator 2021-04-29T07:10:09.713543+00:00 2021-04-29T07:10:10.145783+00:00 0:00:00.432240 22477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T07:10:07.449966+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T06:00:00+00:00 EmrJobFlowSensor 2021-04-29T07:00:54.664120+00:00 2021-04-29T07:09:57.277350+00:00 0:09:02.613230 22473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T07:00:52.307109+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T07:00:34.524251+00:00 2021-04-29T07:00:36.242996+00:00 0:00:01.718745 22472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T07:00:32.284110+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T06:00:00+00:00 PythonOperator 2021-04-29T07:00:10.660398+00:00 2021-04-29T07:00:13.716611+00:00 0:00:03.056213 22471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T07:00:08.211717+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T05:00:00+00:00 TriggerDagRunOperator 2021-04-29T06:11:30.231899+00:00 2021-04-29T06:11:30.758564+00:00 0:00:00.526665 22463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:11:27.456389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T05:00:00+00:00 TriggerDagRunOperator 2021-04-29T06:11:30.019030+00:00 2021-04-29T06:11:30.461869+00:00 0:00:00.442839 22462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:11:27.456343+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T05:00:00+00:00 EmrJobFlowSensor 2021-04-29T06:01:04.886341+00:00 2021-04-29T06:11:07.881551+00:00 0:10:02.995210 22458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:01:02.393014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:00:42.537348+00:00 2021-04-29T06:00:44.243857+00:00 0:00:01.706509 22457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T06:00:40.329412+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T05:00:00+00:00 PythonOperator 2021-04-29T06:00:20.738197+00:00 2021-04-29T06:00:23.776179+00:00 0:00:03.037982 22456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T06:00:18.313674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T04:00:00+00:00 TriggerDagRunOperator 2021-04-29T05:10:19.407075+00:00 2021-04-29T05:10:19.933549+00:00 0:00:00.526474 22448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:10:17.045343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T04:00:00+00:00 TriggerDagRunOperator 2021-04-29T05:10:19.333445+00:00 2021-04-29T05:10:19.750651+00:00 0:00:00.417206 22447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:10:17.045310+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T04:00:00+00:00 EmrJobFlowSensor 2021-04-29T05:00:54.443086+00:00 2021-04-29T05:09:57.095026+00:00 0:09:02.651940 22443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:00:52.040656+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T05:00:30.450782+00:00 2021-04-29T05:00:32.247519+00:00 0:00:01.796737 22442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T05:00:28.046327+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T04:00:00+00:00 PythonOperator 2021-04-29T05:00:08.833251+00:00 2021-04-29T05:00:11.948831+00:00 0:00:03.115580 22441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T05:00:06.067456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T03:00:00+00:00 TriggerDagRunOperator 2021-04-29T04:10:17.763170+00:00 2021-04-29T04:10:18.204780+00:00 0:00:00.441610 22433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T04:10:15.258429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T03:00:00+00:00 TriggerDagRunOperator 2021-04-29T04:10:17.746020+00:00 2021-04-29T04:10:18.346501+00:00 0:00:00.600481 22432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T04:10:15.258477+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T03:00:00+00:00 EmrJobFlowSensor 2021-04-29T04:01:00.509129+00:00 2021-04-29T04:10:03.378298+00:00 0:09:02.869169 22428 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T04:00:58.140915+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T04:00:38.215372+00:00 2021-04-29T04:00:39.952222+00:00 0:00:01.736850 22427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T04:00:35.949080+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T03:00:00+00:00 PythonOperator 2021-04-29T04:00:18.857173+00:00 2021-04-29T04:00:21.922986+00:00 0:00:03.065813 22426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T04:00:15.928552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T02:00:00+00:00 TriggerDagRunOperator 2021-04-29T03:10:24.567305+00:00 2021-04-29T03:10:25.036453+00:00 0:00:00.469148 22417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T03:10:22.104536+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T02:00:00+00:00 TriggerDagRunOperator 2021-04-29T03:10:24.512487+00:00 2021-04-29T03:10:25.106851+00:00 0:00:00.594364 22416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T03:10:22.104504+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T02:00:00+00:00 EmrJobFlowSensor 2021-04-29T03:01:01.664046+00:00 2021-04-29T03:10:04.499782+00:00 0:09:02.835736 22412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T03:00:59.278425+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T03:00:39.856141+00:00 2021-04-29T03:00:41.673622+00:00 0:00:01.817481 22411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T03:00:37.260818+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T02:00:00+00:00 PythonOperator 2021-04-29T03:00:19.591349+00:00 2021-04-29T03:00:22.716892+00:00 0:00:03.125543 22410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T03:00:17.155624+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T01:00:00+00:00 TriggerDagRunOperator 2021-04-29T02:10:13.662395+00:00 2021-04-29T02:10:14.183841+00:00 0:00:00.521446 22402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T02:10:11.203350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T01:00:00+00:00 TriggerDagRunOperator 2021-04-29T02:10:13.594947+00:00 2021-04-29T02:10:14.039977+00:00 0:00:00.445030 22401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T02:10:11.203324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T01:00:00+00:00 EmrJobFlowSensor 2021-04-29T02:01:00.431049+00:00 2021-04-29T02:10:03.090852+00:00 0:09:02.659803 22397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T02:00:58.194339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T02:00:38.317780+00:00 2021-04-29T02:00:40.050290+00:00 0:00:01.732510 22396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T02:00:36.131606+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T01:00:00+00:00 PythonOperator 2021-04-29T02:00:16.943499+00:00 2021-04-29T02:00:19.969561+00:00 0:00:03.026062 22395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T02:00:14.245582+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T00:00:00+00:00 TriggerDagRunOperator 2021-04-29T01:11:30.209430+00:00 2021-04-29T01:11:30.609021+00:00 0:00:00.399591 22387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T01:11:27.321608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T00:00:00+00:00 TriggerDagRunOperator 2021-04-29T01:11:29.848406+00:00 2021-04-29T01:11:30.408913+00:00 0:00:00.560507 22386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T01:11:27.321574+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T00:00:00+00:00 EmrJobFlowSensor 2021-04-29T01:01:18.430707+00:00 2021-04-29T01:11:21.199471+00:00 0:10:02.768764 22382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T01:01:16.237245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T01:00:56.391345+00:00 2021-04-29T01:00:58.103852+00:00 0:00:01.712507 22381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T01:00:54.205073+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T00:00:00+00:00 PythonOperator 2021-04-29T01:00:33.036015+00:00 2021-04-29T01:00:36.064708+00:00 0:00:03.028693 22380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T01:00:30.187129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T23:00:00+00:00 TriggerDagRunOperator 2021-04-29T00:10:01.823562+00:00 2021-04-29T00:10:02.357007+00:00 0:00:00.533445 22372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T00:09:59.269551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T23:00:00+00:00 TriggerDagRunOperator 2021-04-29T00:10:01.766625+00:00 2021-04-29T00:10:02.220190+00:00 0:00:00.453565 22371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T00:09:59.269627+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T23:00:00+00:00 EmrJobFlowSensor 2021-04-29T00:00:48.822793+00:00 2021-04-29T00:09:51.586009+00:00 0:09:02.763216 22367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T00:00:46.302672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T00:00:26.666218+00:00 2021-04-29T00:00:28.375560+00:00 0:00:01.709342 22366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T00:00:24.349989+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T23:00:00+00:00 PythonOperator 2021-04-29T00:00:04.796950+00:00 2021-04-29T00:00:07.872603+00:00 0:00:03.075653 22365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T00:00:02.244450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T22:00:00+00:00 TriggerDagRunOperator 2021-04-28T23:11:23.800347+00:00 2021-04-28T23:11:24.368562+00:00 0:00:00.568215 22357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T23:11:21.163223+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T22:00:00+00:00 TriggerDagRunOperator 2021-04-28T23:11:23.591770+00:00 2021-04-28T23:11:24.045998+00:00 0:00:00.454228 22356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T23:11:21.163174+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T22:00:00+00:00 EmrJobFlowSensor 2021-04-28T23:00:48.370749+00:00 2021-04-28T23:10:51.080548+00:00 0:10:02.709799 22351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T23:00:46.159748+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T23:00:26.287739+00:00 2021-04-28T23:00:27.996923+00:00 0:00:01.709184 22349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T23:00:24.103725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T22:00:00+00:00 PythonOperator 2021-04-28T23:00:04.892905+00:00 2021-04-28T23:00:08.040029+00:00 0:00:03.147124 22347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T23:00:02.098555+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T21:00:00+00:00 TriggerDagRunOperator 2021-04-28T22:09:29.385294+00:00 2021-04-28T22:09:29.917702+00:00 0:00:00.532408 22339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:09:26.934028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T21:00:00+00:00 TriggerDagRunOperator 2021-04-28T22:09:29.243868+00:00 2021-04-28T22:09:29.662989+00:00 0:00:00.419121 22338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:09:26.934060+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T21:00:00+00:00 EmrJobFlowSensor 2021-04-28T22:01:00.501954+00:00 2021-04-28T22:09:03.077504+00:00 0:08:02.575550 22334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T22:00:58.247197+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T22:00:38.601141+00:00 2021-04-28T22:00:40.304258+00:00 0:00:01.703117 22333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T22:00:36.179481+00:00 2 default_pool