Task Instances

  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 booking-processing-job_v002 create_emr_steps 2021-07-14T03:00:00+00:00 PythonOperator 2021-07-14T11:22:49.660314+00:00 2021-07-14T11:22:53.597685+00:00 0:00:03.937371 53241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:22:47.421970+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-14T02:00:00+00:00 PythonOperator 2021-07-14T11:22:27.921699+00:00 2021-07-14T11:22:31.855714+00:00 0:00:03.934015 53240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:22:25.411217+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-14T01:00:00+00:00 PythonOperator 2021-07-14T11:22:05.801709+00:00 2021-07-14T11:22:09.774212+00:00 0:00:03.972503 53239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:22:03.385287+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-13T19:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:21:43.702324+00:00 2021-07-14T11:24:45.795825+00:00 0:03:02.093501 53238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T11:21:41.350215+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-14T00:00:00+00:00 PythonOperator 2021-07-14T11:21:43.614948+00:00 2021-07-14T11:21:47.590525+00:00 0:00:03.975577 53237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:21:41.350172+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T23:00:00+00:00 PythonOperator 2021-07-14T11:21:21.615711+00:00 2021-07-14T11:21:25.365058+00:00 0:00:03.749347 53236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:21:19.294098+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:21:21.491621+00:00 2021-07-14T11:21:23.237650+00:00 0:00:01.746029 53235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T11:21:19.294125+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T19:00:00+00:00 PythonOperator 2021-07-14T11:20:57.729411+00:00 2021-07-14T11:21:01.791899+00:00 0:00:04.062488 53233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:20:55.283095+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-11T03:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:20:03.011377+00:00 53232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:19:50.652987+00:00 2021-07-14T11:19:52.347544+00:00 0:00:01.694557 53231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-13T17:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:19:48.558043+00:00 2021-07-14T11:22:50.964624+00:00 0:03:02.406581 53230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T11:19:45.168854+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T18:00:00+00:00 PythonOperator 2021-07-14T11:19:47.664623+00:00 2021-07-14T11:19:51.314628+00:00 0:00:03.650005 53229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:19:45.168814+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-11T03:00:00+00:00 PythonOperator 2021-07-14T11:19:41.534309+00:00 2021-07-14T11:19:45.590141+00:00 0:00:04.055832 53228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-13T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:19:23.565691+00:00 2021-07-14T11:19:25.297338+00:00 0:00:01.731647 53227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T11:19:21.088430+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-11T02:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:19:05.812840+00:00 53226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T17:00:00+00:00 PythonOperator 2021-07-14T11:19:01.581795+00:00 2021-07-14T11:19:06.792184+00:00 0:00:05.210389 53225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:18:59.090272+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:18:57.206476+00:00 2021-07-14T11:18:59.051840+00:00 0:00:01.845364 53224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-11T02:00:00+00:00 PythonOperator 2021-07-14T11:18:48.610687+00:00 2021-07-14T11:18:52.584108+00:00 0:00:03.973421 53223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T16:00:00+00:00 PythonOperator 2021-07-14T11:18:37.335640+00:00 2021-07-14T11:18:41.357597+00:00 0:00:04.021957 53222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:18:34.990598+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T13:00:00+00:00 PythonOperator 2021-07-14T11:17:29.133572+00:00 2021-07-14T11:17:33.201589+00:00 0:00:04.068017 53221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:17:26.908113+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T12:00:00+00:00 PythonOperator 2021-07-14T11:17:05.444525+00:00 2021-07-14T11:17:09.286037+00:00 0:00:03.841512 53220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:17:02.946232+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:16:43.227119+00:00 2021-07-14T11:16:44.900499+00:00 0:00:01.673380 53219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T11:16:40.846284+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T10:00:00+00:00 PythonOperator 2021-07-14T11:16:21.087168+00:00 2021-07-14T11:16:24.907442+00:00 0:00:03.820274 53218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:16:18.777618+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T09:00:00+00:00 PythonOperator 2021-07-14T11:15:56.888706+00:00 2021-07-14T11:16:01.004724+00:00 0:00:04.116018 53217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:15:54.705159+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T07:00:00+00:00 PythonOperator 2021-07-14T11:15:33.111401+00:00 2021-07-14T11:15:36.820096+00:00 0:00:03.708695 53216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:15:30.752436+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-13T05:00:00+00:00 PythonOperator 2021-07-14T11:15:08.805250+00:00 2021-07-14T11:15:12.899122+00:00 0:00:04.093872 53215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:15:06.621076+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-12T23:00:00+00:00 PythonOperator 2021-07-14T11:13:36.606932+00:00 2021-07-14T11:13:40.578514+00:00 0:00:03.971582 53213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:13:34.464430+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-12T21:00:00+00:00 PythonOperator 2021-07-14T11:13:14.689700+00:00 2021-07-14T11:13:18.454004+00:00 0:00:03.764304 53212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:13:12.415981+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-12T19:00:00+00:00 PythonOperator 2021-07-14T11:12:50.797788+00:00 2021-07-14T11:12:54.709828+00:00 0:00:03.912040 53211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:12:48.457669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-14T10:00:00+00:00 TriggerDagRunOperator 2021-07-14T11:11:10.685623+00:00 2021-07-14T11:11:11.186038+00:00 0:00:00.500415 53208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T11:11:08.097362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-14T10:00:00+00:00 TriggerDagRunOperator 2021-07-14T11:11:10.580771+00:00 2021-07-14T11:11:11.222941+00:00 0:00:00.642170 53207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T11:11:08.097330+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-12T09:00:00+00:00 PythonOperator 2021-07-14T11:10:52.145705+00:00 2021-07-14T11:10:56.066820+00:00 0:00:03.921115 53206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:10:50.007510+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-12T07:00:00+00:00 PythonOperator 2021-07-14T11:10:28.195364+00:00 2021-07-14T11:10:32.247707+00:00 0:00:04.052343 53205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:10:25.940199+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-11T01:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:09:11.737060+00:00 53204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:09:06.377684+00:00 2021-07-14T11:09:08.169000+00:00 0:00:01.791316 53203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-11T01:00:00+00:00 PythonOperator 2021-07-14T11:08:54.624779+00:00 2021-07-14T11:08:58.554068+00:00 0:00:03.929289 53202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-11T00:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:08:40.254196+00:00 53201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:08:32.218346+00:00 2021-07-14T11:08:34.087697+00:00 0:00:01.869351 53200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-11T00:00:00+00:00 PythonOperator 2021-07-14T11:08:19.117972+00:00 2021-07-14T11:08:23.206872+00:00 0:00:04.088900 53199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T23:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:08:04.199850+00:00 53198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:07:58.624711+00:00 2021-07-14T11:08:00.537009+00:00 0:00:01.912298 53197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T23:00:00+00:00 PythonOperator 2021-07-14T11:07:51.854539+00:00 2021-07-14T11:07:55.836309+00:00 0:00:03.981770 53196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T22:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:07:23.729704+00:00 53195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:07:17.171796+00:00 2021-07-14T11:07:18.925618+00:00 0:00:01.753822 53194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T22:00:00+00:00 PythonOperator 2021-07-14T11:07:08.877636+00:00 2021-07-14T11:07:12.611441+00:00 0:00:03.733805 53193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T21:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:06:44.375559+00:00 53192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:06:34.550989+00:00 2021-07-14T11:06:36.440613+00:00 0:00:01.889624 53191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T21:00:00+00:00 PythonOperator 2021-07-14T11:06:26.010033+00:00 2021-07-14T11:06:29.917401+00:00 0:00:03.907368 53190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T20:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:06:08.519464+00:00 53189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:05:58.606512+00:00 2021-07-14T11:06:00.286229+00:00 0:00:01.679717 53188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-14T10:05:00+00:00 EmrJobFlowSensor 2021-07-14T11:05:51.479274+00:00 2021-07-14T11:13:54.146530+00:00 0:08:02.667256 53187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T11:05:47.645728+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T20:00:00+00:00 PythonOperator 2021-07-14T11:05:49.704487+00:00 2021-07-14T11:05:54.154965+00:00 0:00:04.450478 53186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-14T10:05:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:05:27.882314+00:00 2021-07-14T11:05:29.651722+00:00 0:00:01.769408 53185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T11:05:25.552715+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T19:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:05:25.711673+00:00 53184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-14T10:05:00+00:00 PythonOperator 2021-07-14T11:05:09.208841+00:00 2021-07-14T11:05:12.750977+00:00 0:00:03.542136 53183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:05:05.386145+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T13:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:05:07.581389+00:00 2021-07-14T11:05:09.552119+00:00 0:00:01.970730 53182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:04:43.808352+00:00 2021-07-14T11:04:45.677108+00:00 0:00:01.868756 53181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T19:00:00+00:00 PythonOperator 2021-07-14T11:04:21.304466+00:00 2021-07-14T11:04:25.114087+00:00 0:00:03.809621 53180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-14T10:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:00:59.208568+00:00 2021-07-14T11:11:02.037349+00:00 0:10:02.828781 53179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:00:56.965744+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 check_cluster_status 2021-07-14T10:00:00+00:00 EmrJobFlowSensor 2021-07-14T11:00:57.175242+00:00 2021-07-14T11:15:00.892235+00:00 0:14:03.716993 53178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T11:00:54.959856+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:00:39.342929+00:00 2021-07-14T11:00:41.181532+00:00 0:00:01.838603 53177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-14T11:00:36.952288+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_cluster_and_add_emr_steps 2021-07-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T11:00:35.091006+00:00 2021-07-14T11:00:36.900033+00:00 0:00:01.809027 53176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T11:00:32.892397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-14T10:00:00+00:00 PythonOperator 2021-07-14T11:00:17.013193+00:00 2021-07-14T11:00:20.758001+00:00 0:00:03.744808 53175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-14T11:00:14.824560+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_emr_steps 2021-07-14T10:00:00+00:00 PythonOperator 2021-07-14T11:00:13.123836+00:00 2021-07-14T11:00:17.053103+00:00 0:00:03.929267 53174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T11:00:10.820032+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T18:00:00+00:00 EmrJobFlowSensor 2021-07-14T10:59:42.792541+00:00 2021-07-14T10:59:44.299036+00:00 0:00:01.506495 53173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T10:23:43.904244+00:00 2021-07-14T10:23:45.723126+00:00 0:00:01.818882 53171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T13:00:00+00:00 PythonOperator 2021-07-14T10:23:33.981187+00:00 2021-07-14T10:23:37.759614+00:00 0:00:03.778427 53170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T10:19:46.462965+00:00 2021-07-14T10:19:48.189595+00:00 0:00:01.726630 53169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T18:00:00+00:00 PythonOperator 2021-07-14T10:19:37.215921+00:00 2021-07-14T10:19:41.000850+00:00 0:00:03.784929 53168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-14T09:05:00+00:00 EmrJobFlowSensor 2021-07-14T10:14:50.515845+00:00 2021-07-14T10:14:52.006687+00:00 0:00:01.490842 53167 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T10:14:48.089794+00:00 3 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-14T09:00:00+00:00 TriggerDagRunOperator 2021-07-14T10:10:00.716610+00:00 2021-07-14T10:10:01.202742+00:00 0:00:00.486132 53166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T10:09:57.610307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-14T09:00:00+00:00 TriggerDagRunOperator 2021-07-14T10:09:59.976151+00:00 2021-07-14T10:10:00.496016+00:00 0:00:00.519865 53165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T10:09:57.610354+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-14T09:05:00+00:00 EmrCreateJobFlowOperator 2021-07-14T10:05:41.343027+00:00 2021-07-14T10:05:43.189889+00:00 0:00:01.846862 53163 airflow-worker-3.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T10:05:39.090458+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-14T09:05:00+00:00 PythonOperator 2021-07-14T10:05:15.192398+00:00 2021-07-14T10:05:18.912459+00:00 0:00:03.720061 53162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T10:05:13.011165+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 check_cluster_status 2021-07-14T09:00:00+00:00 EmrJobFlowSensor 2021-07-14T10:00:50.709721+00:00 2021-07-14T10:14:54.118993+00:00 0:14:03.409272 53161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T10:00:48.474809+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-14T09:00:00+00:00 EmrJobFlowSensor 2021-07-14T10:00:48.862383+00:00 2021-07-14T10:09:52.000159+00:00 0:09:03.137776 53160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T10:00:46.441426+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_cluster_and_add_emr_steps 2021-07-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T10:00:31.038525+00:00 2021-07-14T10:00:32.767442+00:00 0:00:01.728917 53159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T10:00:28.462495+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T10:00:28.579550+00:00 2021-07-14T10:00:30.579631+00:00 0:00:02.000081 53158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-14T10:00:26.404038+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_emr_steps 2021-07-14T09:00:00+00:00 PythonOperator 2021-07-14T10:00:09.342876+00:00 2021-07-14T10:00:13.605098+00:00 0:00:04.262222 53157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T10:00:06.376781+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-14T09:00:00+00:00 PythonOperator 2021-07-14T10:00:07.129670+00:00 2021-07-14T10:00:11.351915+00:00 0:00:04.222245 53156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-14T10:00:04.387752+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T17:00:00+00:00 EmrJobFlowSensor 2021-07-14T09:42:40.750804+00:00 2021-07-14T09:42:42.245931+00:00 0:00:01.495127 53155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T09:28:35.758966+00:00 2021-07-14T09:28:37.691408+00:00 0:00:01.932442 53154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T17:00:00+00:00 PythonOperator 2021-07-14T09:28:27.637107+00:00 2021-07-14T09:28:31.713022+00:00 0:00:04.075915 53153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T16:00:00+00:00 EmrJobFlowSensor 2021-07-14T09:15:18.086695+00:00 2021-07-14T09:25:21.160772+00:00 0:10:03.074077 53151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T09:15:03.408436+00:00 2021-07-14T09:15:05.210113+00:00 0:00:01.801677 53150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-14T08:00:00+00:00 TriggerDagRunOperator 2021-07-14T09:11:23.760075+00:00 2021-07-14T09:11:24.285472+00:00 0:00:00.525397 53149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T09:11:21.210352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-14T08:00:00+00:00 TriggerDagRunOperator 2021-07-14T09:11:23.669286+00:00 2021-07-14T09:11:24.082194+00:00 0:00:00.412908 53148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T09:11:21.210386+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-14T08:05:00+00:00 EmrJobFlowSensor 2021-07-14T09:05:58.867261+00:00 2021-07-14T09:15:01.518731+00:00 0:09:02.651470 53147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T09:05:56.590316+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-14T08:05:00+00:00 EmrCreateJobFlowOperator 2021-07-14T09:05:34.893327+00:00 2021-07-14T09:05:36.669015+00:00 0:00:01.775688 53146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T09:05:32.541791+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-14T08:05:00+00:00 PythonOperator 2021-07-14T09:05:10.660714+00:00 2021-07-14T09:05:14.581568+00:00 0:00:03.920854 53145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T09:05:08.509429+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T16:00:00+00:00 PythonOperator 2021-07-14T09:04:02.097309+00:00 2021-07-14T09:04:05.961190+00:00 0:00:03.863881 53144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T15:00:00+00:00 EmrJobFlowSensor 2021-07-14T09:03:52.481058+00:00 2021-07-14T09:14:55.503625+00:00 0:11:03.022567 53143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T09:03:41.231337+00:00 2021-07-14T09:03:42.944023+00:00 0:00:01.712686 53142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T15:00:00+00:00 PythonOperator 2021-07-14T09:03:34.817911+00:00 2021-07-14T09:03:38.697834+00:00 0:00:03.879923 53141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 check_cluster_status 2021-07-14T08:00:00+00:00 EmrJobFlowSensor 2021-07-14T09:01:04.639760+00:00 2021-07-14T09:14:08.090678+00:00 0:13:03.450918 53140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T09:01:02.211777+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-14T08:00:00+00:00 EmrJobFlowSensor 2021-07-14T09:00:56.717834+00:00 2021-07-14T09:10:59.680478+00:00 0:10:02.962644 53139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T09:00:54.348312+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_cluster_and_add_emr_steps 2021-07-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T09:00:42.490691+00:00 2021-07-14T09:00:44.309141+00:00 0:00:01.818450 53138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T09:00:40.186285+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T09:00:36.528185+00:00 2021-07-14T09:00:38.302045+00:00 0:00:01.773860 53137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-14T09:00:34.179368+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_emr_steps 2021-07-14T08:00:00+00:00 PythonOperator 2021-07-14T09:00:20.493145+00:00 2021-07-14T09:00:24.378415+00:00 0:00:03.885270 53136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T09:00:18.098439+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-14T08:00:00+00:00 PythonOperator 2021-07-14T09:00:12.448243+00:00 2021-07-14T09:00:16.232233+00:00 0:00:03.783990 53135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-14T09:00:10.092566+00:00 2 default_pool