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-18T21:00:00+00:00 PythonOperator 2021-04-18T22:00:18.955300+00:00 2021-04-18T22:00:21.926397+00:00 0:00:02.971097 18681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T22:00:16.635064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T20:00:00+00:00 TriggerDagRunOperator 2021-04-18T21:09:08.542366+00:00 2021-04-18T21:09:09.103353+00:00 0:00:00.560987 18673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T21:09:05.989947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T20:00:00+00:00 TriggerDagRunOperator 2021-04-18T21:09:08.510913+00:00 2021-04-18T21:09:08.967208+00:00 0:00:00.456295 18672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T21:09:05.989916+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T20:00:00+00:00 EmrJobFlowSensor 2021-04-18T21:00:53.667687+00:00 2021-04-18T21:08:56.221792+00:00 0:08:02.554105 18668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T21:00:51.414417+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T21:00:27.626766+00:00 2021-04-18T21:00:29.466663+00:00 0:00:01.839897 18667 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T21:00:25.392035+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T20:00:00+00:00 PythonOperator 2021-04-18T21:00:05.641548+00:00 2021-04-18T21:00:08.544935+00:00 0:00:02.903387 18666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T21:00:03.363111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T19:00:00+00:00 TriggerDagRunOperator 2021-04-18T20:11:15.866206+00:00 2021-04-18T20:11:16.392301+00:00 0:00:00.526095 18658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T20:11:13.495319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T19:00:00+00:00 TriggerDagRunOperator 2021-04-18T20:11:15.785180+00:00 2021-04-18T20:11:16.191013+00:00 0:00:00.405833 18657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T20:11:13.495350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T19:00:00+00:00 EmrJobFlowSensor 2021-04-18T20:01:00.742823+00:00 2021-04-18T20:11:03.658844+00:00 0:10:02.916021 18653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T20:00:58.267754+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T20:00:38.669151+00:00 2021-04-18T20:00:40.467771+00:00 0:00:01.798620 18652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T20:00:36.139266+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T19:00:00+00:00 PythonOperator 2021-04-18T20:00:16.675826+00:00 2021-04-18T20:00:19.705674+00:00 0:00:03.029848 18651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T20:00:14.145313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T18:00:00+00:00 TriggerDagRunOperator 2021-04-18T19:11:19.523625+00:00 2021-04-18T19:11:20.075386+00:00 0:00:00.551761 18643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T19:11:17.194640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T18:00:00+00:00 TriggerDagRunOperator 2021-04-18T19:11:19.403333+00:00 2021-04-18T19:11:19.835081+00:00 0:00:00.431748 18642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T19:11:17.194687+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T18:00:00+00:00 EmrJobFlowSensor 2021-04-18T19:01:00.815662+00:00 2021-04-18T19:11:03.776733+00:00 0:10:02.961071 18638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T19:00:58.258886+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T19:00:40.409564+00:00 2021-04-18T19:00:42.179784+00:00 0:00:01.770220 18637 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T19:00:38.108214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T18:00:00+00:00 PythonOperator 2021-04-18T19:00:18.530959+00:00 2021-04-18T19:00:21.523691+00:00 0:00:02.992732 18636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T19:00:16.098944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T17:00:00+00:00 TriggerDagRunOperator 2021-04-18T18:09:03.702221+00:00 2021-04-18T18:09:04.207565+00:00 0:00:00.505344 18628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T18:09:01.148243+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T17:00:00+00:00 TriggerDagRunOperator 2021-04-18T18:09:03.402766+00:00 2021-04-18T18:09:03.844123+00:00 0:00:00.441357 18627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T18:09:01.148192+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T17:00:00+00:00 EmrJobFlowSensor 2021-04-18T18:00:48.972803+00:00 2021-04-18T18:08:51.550663+00:00 0:08:02.577860 18623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T18:00:46.195357+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T18:00:26.322745+00:00 2021-04-18T18:00:28.014906+00:00 0:00:01.692161 18622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T18:00:24.157648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T17:00:00+00:00 PythonOperator 2021-04-18T18:00:06.691923+00:00 2021-04-18T18:00:10.243573+00:00 0:00:03.551650 18621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T18:00:04.141094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T16:00:00+00:00 TriggerDagRunOperator 2021-04-18T17:10:20.621258+00:00 2021-04-18T17:10:21.135643+00:00 0:00:00.514385 18613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T17:10:17.859893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T16:00:00+00:00 TriggerDagRunOperator 2021-04-18T17:10:20.501334+00:00 2021-04-18T17:10:20.922814+00:00 0:00:00.421480 18612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T17:10:17.859860+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T16:00:00+00:00 EmrJobFlowSensor 2021-04-18T17:01:01.422554+00:00 2021-04-18T17:10:04.136427+00:00 0:09:02.713873 18608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T17:00:59.040786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T17:00:39.729984+00:00 2021-04-18T17:00:41.520050+00:00 0:00:01.790066 18607 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T17:00:36.798245+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T16:00:00+00:00 PythonOperator 2021-04-18T17:00:17.060840+00:00 2021-04-18T17:00:20.958115+00:00 0:00:03.897275 18606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T17:00:14.773643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T15:00:00+00:00 TriggerDagRunOperator 2021-04-18T16:11:08.959913+00:00 2021-04-18T16:11:09.484092+00:00 0:00:00.524179 18598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T16:11:06.349117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T15:00:00+00:00 TriggerDagRunOperator 2021-04-18T16:11:08.785593+00:00 2021-04-18T16:11:09.216978+00:00 0:00:00.431385 18597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T16:11:06.349060+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T15:00:00+00:00 EmrJobFlowSensor 2021-04-18T16:00:55.448375+00:00 2021-04-18T16:10:58.317007+00:00 0:10:02.868632 18593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T16:00:53.195454+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T16:00:33.466729+00:00 2021-04-18T16:00:35.415999+00:00 0:00:01.949270 18592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T16:00:31.146612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T15:00:00+00:00 PythonOperator 2021-04-18T16:00:11.464075+00:00 2021-04-18T16:00:14.396048+00:00 0:00:02.931973 18591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T16:00:09.126788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T14:00:00+00:00 TriggerDagRunOperator 2021-04-18T15:11:32.769316+00:00 2021-04-18T15:11:33.294297+00:00 0:00:00.524981 18583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T15:11:29.759687+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T14:00:00+00:00 TriggerDagRunOperator 2021-04-18T15:11:32.395684+00:00 2021-04-18T15:11:32.838282+00:00 0:00:00.442598 18582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T15:11:29.759726+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T14:00:00+00:00 EmrJobFlowSensor 2021-04-18T15:01:03.052488+00:00 2021-04-18T15:11:05.834670+00:00 0:10:02.782182 18578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T15:01:00.786806+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T15:00:38.980439+00:00 2021-04-18T15:00:40.655148+00:00 0:00:01.674709 18577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T15:00:36.737773+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T14:00:00+00:00 PythonOperator 2021-04-18T15:00:09.718450+00:00 2021-04-18T15:00:12.923256+00:00 0:00:03.204806 18576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T15:00:06.758455+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T13:00:00+00:00 TriggerDagRunOperator 2021-04-18T14:11:16.959102+00:00 2021-04-18T14:11:17.477879+00:00 0:00:00.518777 18568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T14:11:14.628884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T13:00:00+00:00 TriggerDagRunOperator 2021-04-18T14:11:16.827440+00:00 2021-04-18T14:11:17.289635+00:00 0:00:00.462195 18567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T14:11:14.628918+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T13:00:00+00:00 EmrJobFlowSensor 2021-04-18T14:00:53.994042+00:00 2021-04-18T14:10:56.670875+00:00 0:10:02.676833 18563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T14:00:51.695711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T14:00:34.183040+00:00 2021-04-18T14:00:36.062126+00:00 0:00:01.879086 18562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T14:00:31.677112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T13:00:00+00:00 PythonOperator 2021-04-18T14:00:11.827080+00:00 2021-04-18T14:00:15.047590+00:00 0:00:03.220510 18561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T14:00:09.615942+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T12:00:00+00:00 TriggerDagRunOperator 2021-04-18T13:15:10.013607+00:00 2021-04-18T13:15:10.527834+00:00 0:00:00.514227 18554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T13:15:07.478420+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T12:00:00+00:00 TriggerDagRunOperator 2021-04-18T13:15:09.882575+00:00 2021-04-18T13:15:10.295084+00:00 0:00:00.412509 18553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T13:15:07.478376+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T12:00:00+00:00 EmrJobFlowSensor 2021-04-18T13:00:54.878257+00:00 2021-04-18T13:08:57.414974+00:00 0:08:02.536717 18548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T13:00:52.549376+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T13:00:34.924405+00:00 2021-04-18T13:00:36.709061+00:00 0:00:01.784656 18547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T13:00:32.436131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T12:00:00+00:00 PythonOperator 2021-04-18T13:00:10.816115+00:00 2021-04-18T13:00:13.948526+00:00 0:00:03.132411 18546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T13:00:08.414156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T11:00:00+00:00 TriggerDagRunOperator 2021-04-18T12:10:19.898597+00:00 2021-04-18T12:10:20.423360+00:00 0:00:00.524763 18539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T12:10:17.492484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T11:00:00+00:00 TriggerDagRunOperator 2021-04-18T12:10:19.696745+00:00 2021-04-18T12:10:20.121662+00:00 0:00:00.424917 18538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T12:10:17.492531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T11:00:00+00:00 EmrJobFlowSensor 2021-04-18T12:01:04.947537+00:00 2021-04-18T12:10:07.911864+00:00 0:09:02.964327 18533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T12:01:02.586944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T12:00:43.166338+00:00 2021-04-18T12:00:44.886855+00:00 0:00:01.720517 18532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T12:00:40.559681+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T11:00:00+00:00 PythonOperator 2021-04-18T12:00:22.776245+00:00 2021-04-18T12:00:25.712313+00:00 0:00:02.936068 18531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T12:00:20.499017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T10:00:00+00:00 TriggerDagRunOperator 2021-04-18T11:10:56.757932+00:00 2021-04-18T11:10:57.255223+00:00 0:00:00.497291 18524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T11:10:54.076397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T10:00:00+00:00 TriggerDagRunOperator 2021-04-18T11:10:56.373061+00:00 2021-04-18T11:10:56.823794+00:00 0:00:00.450733 18523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T11:10:54.076350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T10:00:00+00:00 EmrJobFlowSensor 2021-04-18T11:00:48.278753+00:00 2021-04-18T11:10:51.194605+00:00 0:10:02.915852 18518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T11:00:45.950085+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T11:00:28.128519+00:00 2021-04-18T11:00:29.972560+00:00 0:00:01.844041 18517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T11:00:25.826551+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T10:00:00+00:00 PythonOperator 2021-04-18T11:00:06.234797+00:00 2021-04-18T11:00:09.670790+00:00 0:00:03.435993 18516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T11:00:03.804946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T09:00:00+00:00 TriggerDagRunOperator 2021-04-18T10:12:52.295225+00:00 2021-04-18T10:12:52.757687+00:00 0:00:00.462462 18509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T10:12:49.166264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T09:00:00+00:00 TriggerDagRunOperator 2021-04-18T10:12:51.964535+00:00 2021-04-18T10:12:52.475619+00:00 0:00:00.511084 18508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T10:12:49.166229+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T09:00:00+00:00 EmrJobFlowSensor 2021-04-18T10:03:40.512670+00:00 2021-04-18T10:12:43.178489+00:00 0:09:02.665819 18504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T10:03:38.235533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T10:03:20.578264+00:00 2021-04-18T10:03:22.327031+00:00 0:00:01.748767 18503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T10:03:18.278988+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T09:00:00+00:00 PythonOperator 2021-04-18T10:02:58.918343+00:00 2021-04-18T10:03:02.035410+00:00 0:00:03.117067 18502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T10:02:56.119059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T08:00:00+00:00 TriggerDagRunOperator 2021-04-18T09:12:22.888021+00:00 2021-04-18T09:12:23.410130+00:00 0:00:00.522109 18494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T09:12:20.335478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T08:00:00+00:00 TriggerDagRunOperator 2021-04-18T09:12:22.543472+00:00 2021-04-18T09:12:22.959627+00:00 0:00:00.416155 18493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T09:12:20.335443+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T08:00:00+00:00 EmrJobFlowSensor 2021-04-18T09:00:55.711674+00:00 2021-04-18T09:11:58.721335+00:00 0:11:03.009661 18489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T09:00:53.343524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T09:00:33.669622+00:00 2021-04-18T09:00:35.492532+00:00 0:00:01.822910 18488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T09:00:31.355776+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T08:00:00+00:00 PythonOperator 2021-04-18T09:00:11.913703+00:00 2021-04-18T09:00:14.913087+00:00 0:00:02.999384 18487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T09:00:09.240890+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T07:00:00+00:00 TriggerDagRunOperator 2021-04-18T08:10:18.853437+00:00 2021-04-18T08:10:19.431509+00:00 0:00:00.578072 18479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T08:10:16.125370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T07:00:00+00:00 TriggerDagRunOperator 2021-04-18T08:10:18.626630+00:00 2021-04-18T08:10:19.058114+00:00 0:00:00.431484 18478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T08:10:16.125405+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T07:00:00+00:00 EmrJobFlowSensor 2021-04-18T08:00:54.005264+00:00 2021-04-18T08:09:56.754645+00:00 0:09:02.749381 18474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T08:00:51.240766+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T08:00:33.307159+00:00 2021-04-18T08:00:35.060512+00:00 0:00:01.753353 18473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T08:00:31.116325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T07:00:00+00:00 PythonOperator 2021-04-18T08:00:11.450114+00:00 2021-04-18T08:00:14.504700+00:00 0:00:03.054586 18472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T08:00:09.096987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T06:00:00+00:00 TriggerDagRunOperator 2021-04-18T07:11:19.419248+00:00 2021-04-18T07:11:19.830351+00:00 0:00:00.411103 18464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T07:11:17.069014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T06:00:00+00:00 TriggerDagRunOperator 2021-04-18T07:11:19.414264+00:00 2021-04-18T07:11:19.950679+00:00 0:00:00.536415 18463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T07:11:17.069044+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T06:00:00+00:00 EmrJobFlowSensor 2021-04-18T07:00:56.858824+00:00 2021-04-18T07:10:59.604402+00:00 0:10:02.745578 18459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T07:00:53.861141+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T07:00:36.149648+00:00 2021-04-18T07:00:37.928993+00:00 0:00:01.779345 18458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T07:00:33.791715+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T06:00:00+00:00 PythonOperator 2021-04-18T07:00:14.299653+00:00 2021-04-18T07:00:17.256891+00:00 0:00:02.957238 18457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T07:00:11.746894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T05:00:00+00:00 TriggerDagRunOperator 2021-04-18T06:10:19.511768+00:00 2021-04-18T06:10:20.047881+00:00 0:00:00.536113 18449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T06:10:17.047557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T05:00:00+00:00 TriggerDagRunOperator 2021-04-18T06:10:19.367692+00:00 2021-04-18T06:10:19.800928+00:00 0:00:00.433236 18448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T06:10:17.047509+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T05:00:00+00:00 EmrJobFlowSensor 2021-04-18T06:00:53.907035+00:00 2021-04-18T06:09:56.487916+00:00 0:09:02.580881 18444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T06:00:51.548341+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T06:00:33.861410+00:00 2021-04-18T06:00:35.675167+00:00 0:00:01.813757 18443 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T06:00:31.443937+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T05:00:00+00:00 PythonOperator 2021-04-18T06:00:11.953129+00:00 2021-04-18T06:00:14.881925+00:00 0:00:02.928796 18442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T06:00:09.371801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T04:00:00+00:00 TriggerDagRunOperator 2021-04-18T05:09:58.575588+00:00 2021-04-18T05:09:59.045782+00:00 0:00:00.470194 18434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T05:09:56.213689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T04:00:00+00:00 TriggerDagRunOperator 2021-04-18T05:09:58.506966+00:00 2021-04-18T05:09:59.087933+00:00 0:00:00.580967 18433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T05:09:56.213721+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T04:00:00+00:00 EmrJobFlowSensor 2021-04-18T05:00:49.503312+00:00 2021-04-18T05:09:52.385578+00:00 0:09:02.882266 18429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T05:00:47.354047+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T05:00:27.538730+00:00 2021-04-18T05:00:29.340546+00:00 0:00:01.801816 18428 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T05:00:25.289129+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T04:00:00+00:00 PythonOperator 2021-04-18T05:00:05.590698+00:00 2021-04-18T05:00:08.562170+00:00 0:00:02.971472 18427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T05:00:03.253275+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T03:00:00+00:00 TriggerDagRunOperator 2021-04-18T04:10:09.733495+00:00 2021-04-18T04:10:10.246430+00:00 0:00:00.512935 18419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T04:10:07.251104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T03:00:00+00:00 TriggerDagRunOperator 2021-04-18T04:10:09.594206+00:00 2021-04-18T04:10:10.040780+00:00 0:00:00.446574 18418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T04:10:07.251139+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T03:00:00+00:00 EmrJobFlowSensor 2021-04-18T04:00:56.649434+00:00 2021-04-18T04:09:59.407542+00:00 0:09:02.758108 18414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T04:00:54.252541+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T04:00:36.390417+00:00 2021-04-18T04:00:38.743451+00:00 0:00:02.353034 18413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T04:00:34.190369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T03:00:00+00:00 PythonOperator 2021-04-18T04:00:14.446849+00:00 2021-04-18T04:00:17.350172+00:00 0:00:02.903323 18412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T04:00:12.105924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T02:00:00+00:00 TriggerDagRunOperator 2021-04-18T03:11:18.133188+00:00 2021-04-18T03:11:18.699761+00:00 0:00:00.566573 18404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T03:11:15.799296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T02:00:00+00:00 TriggerDagRunOperator 2021-04-18T03:11:17.997222+00:00 2021-04-18T03:11:18.451554+00:00 0:00:00.454332 18403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T03:11:15.799330+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T02:00:00+00:00 EmrJobFlowSensor 2021-04-18T03:01:50.803571+00:00 2021-04-18T03:10:53.519462+00:00 0:09:02.715891 18399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T03:01:48.631260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T03:01:28.913359+00:00 2021-04-18T03:01:30.713189+00:00 0:00:01.799830 18398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T03:01:26.614061+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T02:00:00+00:00 PythonOperator 2021-04-18T03:01:09.201110+00:00 2021-04-18T03:01:12.505663+00:00 0:00:03.304553 18397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T03:01:06.659808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T01:00:00+00:00 TriggerDagRunOperator 2021-04-18T02:09:25.247781+00:00 2021-04-18T02:09:25.753801+00:00 0:00:00.506020 18389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T02:09:22.543673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T01:00:00+00:00 TriggerDagRunOperator 2021-04-18T02:09:24.830967+00:00 2021-04-18T02:09:25.307043+00:00 0:00:00.476076 18388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T02:09:22.543625+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T01:00:00+00:00 EmrJobFlowSensor 2021-04-18T02:01:11.954804+00:00 2021-04-18T02:09:14.656836+00:00 0:08:02.702032 18384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T02:01:09.623518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T02:00:49.792247+00:00 2021-04-18T02:00:51.546896+00:00 0:00:01.754649 18383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T02:00:47.603334+00:00 2 default_pool