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 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-28T08:00:00+00:00 TriggerDagRunOperator 2021-05-28T09:10:25.344711+00:00 2021-05-28T09:10:25.855763+00:00 0:00:00.511052 33326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T09:10:22.916677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-28T08:00:00+00:00 TriggerDagRunOperator 2021-05-28T09:10:25.186939+00:00 2021-05-28T09:10:25.767368+00:00 0:00:00.580429 33325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T09:10:22.916705+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-28T08:05:00+00:00 EmrJobFlowSensor 2021-05-28T09:06:06.618293+00:00 2021-05-28T09:15:09.247478+00:00 0:09:02.629185 33324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T09:06:04.428760+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-28T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-28T09:05:46.712787+00:00 2021-05-28T09:05:48.362025+00:00 0:00:01.649238 33323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T09:05:44.413581+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-28T08:05:00+00:00 PythonOperator 2021-05-28T09:05:24.617391+00:00 2021-05-28T09:05:27.839263+00:00 0:00:03.221872 33322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T09:05:22.445992+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-28T08:00:00+00:00 EmrJobFlowSensor 2021-05-28T09:01:15.956798+00:00 2021-05-28T09:10:18.617441+00:00 0:09:02.660643 33321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T09:01:13.892047+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-28T08:00:00+00:00 EmrJobFlowSensor 2021-05-28T09:01:04.159455+00:00 2021-05-28T09:10:06.950058+00:00 0:09:02.790603 33320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T09:01:01.850872+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T09:00:37.998516+00:00 2021-05-28T09:00:39.663788+00:00 0:00:01.665272 33319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T09:00:35.833215+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T09:00:33.930535+00:00 2021-05-28T09:00:35.617617+00:00 0:00:01.687082 33318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-28T09:00:31.820921+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-28T08:00:00+00:00 PythonOperator 2021-05-28T09:00:16.146536+00:00 2021-05-28T09:00:19.323164+00:00 0:00:03.176628 33317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T09:00:13.809302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-28T08:00:00+00:00 PythonOperator 2021-05-28T09:00:12.270083+00:00 2021-05-28T09:00:15.519521+00:00 0:00:03.249438 33316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-28T09:00:09.813360+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-28T07:00:00+00:00 EmrJobFlowSensor 2021-05-28T08:12:19.010453+00:00 2021-05-28T08:21:21.683528+00:00 0:09:02.673075 33314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T08:12:16.821956+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-28T07:00:00+00:00 EmrJobFlowSensor 2021-05-28T08:12:11.023618+00:00 2021-05-28T08:22:13.908392+00:00 0:10:02.884774 33313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T08:12:08.818528+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T08:11:59.510205+00:00 2021-05-28T08:12:01.273294+00:00 0:00:01.763089 33312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T08:11:56.806024+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T08:11:50.989831+00:00 2021-05-28T08:11:52.742807+00:00 0:00:01.752976 33311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T08:11:48.853514+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-28T07:00:00+00:00 PythonOperator 2021-05-28T08:11:37.280548+00:00 2021-05-28T08:11:40.759010+00:00 0:00:03.478462 33310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T08:11:34.785538+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-28T07:00:00+00:00 PythonOperator 2021-05-28T08:11:29.224402+00:00 2021-05-28T08:11:32.448557+00:00 0:00:03.224155 33309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T08:11:26.856219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-28T07:00:00+00:00 TriggerDagRunOperator 2021-05-28T08:11:13.082264+00:00 2021-05-28T08:11:13.502989+00:00 0:00:00.420725 33308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T08:11:10.712513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-28T07:00:00+00:00 TriggerDagRunOperator 2021-05-28T08:11:13.015542+00:00 2021-05-28T08:11:13.549500+00:00 0:00:00.533958 33307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T08:11:10.712477+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-28T07:05:00+00:00 EmrJobFlowSensor 2021-05-28T08:06:06.394537+00:00 2021-05-28T08:14:08.961322+00:00 0:08:02.566785 33306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T08:06:04.188519+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-28T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-28T08:05:46.337826+00:00 2021-05-28T08:05:48.062282+00:00 0:00:01.724456 33305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T08:05:44.121310+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-28T07:05:00+00:00 PythonOperator 2021-05-28T08:05:24.461690+00:00 2021-05-28T08:05:27.754095+00:00 0:00:03.292405 33304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T08:05:22.161580+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-28T07:00:00+00:00 EmrJobFlowSensor 2021-05-28T08:01:04.240505+00:00 2021-05-28T08:10:06.824597+00:00 0:09:02.584092 33303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T08:01:01.850030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-28T07:00:00+00:00 EmrJobFlowSensor 2021-05-28T08:01:02.570347+00:00 2021-05-28T08:11:05.456830+00:00 0:10:02.886483 33302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T08:00:59.666910+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T08:00:42.402540+00:00 2021-05-28T08:00:44.076787+00:00 0:00:01.674247 33301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T08:00:39.489853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T08:00:40.134023+00:00 2021-05-28T08:00:42.232778+00:00 0:00:02.098755 33300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-28T08:00:37.562459+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-28T07:00:00+00:00 PythonOperator 2021-05-28T08:00:19.621307+00:00 2021-05-28T08:00:22.952830+00:00 0:00:03.331523 33299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T08:00:17.445345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-28T07:00:00+00:00 PythonOperator 2021-05-28T08:00:18.079307+00:00 2021-05-28T08:00:21.287497+00:00 0:00:03.208190 33298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-28T08:00:15.441035+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-28T06:00:00+00:00 EmrJobFlowSensor 2021-05-28T07:10:17.990853+00:00 2021-05-28T07:19:20.632046+00:00 0:09:02.641193 33296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T07:10:15.770923+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-28T06:00:00+00:00 EmrJobFlowSensor 2021-05-28T07:10:16.136481+00:00 2021-05-28T07:19:19.015674+00:00 0:09:02.879193 33295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T07:10:13.755811+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T07:09:51.852379+00:00 2021-05-28T07:09:53.512348+00:00 0:00:01.659969 33294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T07:09:49.648704+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T07:09:41.795010+00:00 2021-05-28T07:09:43.501801+00:00 0:00:01.706791 33293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T07:09:39.641169+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-28T06:00:00+00:00 PythonOperator 2021-05-28T07:09:26.034691+00:00 2021-05-28T07:09:29.260875+00:00 0:00:03.226184 33292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T07:09:23.626291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-28T06:00:00+00:00 PythonOperator 2021-05-28T07:09:21.776791+00:00 2021-05-28T07:09:25.195537+00:00 0:00:03.418746 33291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T07:09:19.626947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-28T06:00:00+00:00 TriggerDagRunOperator 2021-05-28T07:09:07.954639+00:00 2021-05-28T07:09:08.592420+00:00 0:00:00.637781 33290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T07:09:05.610824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-28T06:00:00+00:00 TriggerDagRunOperator 2021-05-28T07:09:07.807623+00:00 2021-05-28T07:09:08.284025+00:00 0:00:00.476402 33289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T07:09:05.610861+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-28T06:05:00+00:00 EmrJobFlowSensor 2021-05-28T07:05:57.735579+00:00 2021-05-28T07:15:00.320142+00:00 0:09:02.584563 33288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T07:05:55.452022+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-28T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-28T07:05:37.578745+00:00 2021-05-28T07:05:39.332455+00:00 0:00:01.753710 33287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T07:05:35.369982+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-28T06:05:00+00:00 PythonOperator 2021-05-28T07:05:15.455771+00:00 2021-05-28T07:05:18.661212+00:00 0:00:03.205441 33286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T07:05:13.349338+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-28T06:00:00+00:00 EmrJobFlowSensor 2021-05-28T07:01:01.290007+00:00 2021-05-28T07:09:03.870149+00:00 0:08:02.580142 33285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T07:00:59.066305+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-28T06:00:00+00:00 EmrJobFlowSensor 2021-05-28T07:00:47.565421+00:00 2021-05-28T07:09:50.126733+00:00 0:09:02.561312 33284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T07:00:45.081508+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T07:00:39.314285+00:00 2021-05-28T07:00:41.016098+00:00 0:00:01.701813 33283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-28T07:00:37.047996+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T07:00:25.379187+00:00 2021-05-28T07:00:27.106525+00:00 0:00:01.727338 33282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T07:00:23.094973+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-28T06:00:00+00:00 PythonOperator 2021-05-28T07:00:19.745403+00:00 2021-05-28T07:00:22.975383+00:00 0:00:03.229980 33281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-28T07:00:17.063693+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-28T06:00:00+00:00 PythonOperator 2021-05-28T07:00:05.371359+00:00 2021-05-28T07:00:08.574659+00:00 0:00:03.203300 33280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T07:00:02.964082+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-28T05:00:00+00:00 EmrJobFlowSensor 2021-05-28T06:10:48.124273+00:00 2021-05-28T06:19:50.864717+00:00 0:09:02.740444 33278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T06:10:45.693911+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-28T05:00:00+00:00 EmrJobFlowSensor 2021-05-28T06:10:42.000849+00:00 2021-05-28T06:19:44.535663+00:00 0:09:02.534814 33277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T06:10:39.755944+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T06:10:25.958802+00:00 2021-05-28T06:10:27.698237+00:00 0:00:01.739435 33276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T06:10:23.628741+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T06:10:20.317900+00:00 2021-05-28T06:10:22.091596+00:00 0:00:01.773696 33275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T06:10:17.684427+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-28T05:00:00+00:00 PythonOperator 2021-05-28T06:10:03.804884+00:00 2021-05-28T06:10:07.211176+00:00 0:00:03.406292 33274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T06:10:01.616424+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-28T05:00:00+00:00 PythonOperator 2021-05-28T06:10:00.341721+00:00 2021-05-28T06:10:03.771234+00:00 0:00:03.429513 33273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T06:09:57.667140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-28T05:00:00+00:00 TriggerDagRunOperator 2021-05-28T06:09:42.001344+00:00 2021-05-28T06:09:42.573681+00:00 0:00:00.572337 33272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T06:09:39.597512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-28T05:00:00+00:00 TriggerDagRunOperator 2021-05-28T06:09:41.880532+00:00 2021-05-28T06:09:42.303123+00:00 0:00:00.422591 33271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T06:09:39.597557+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-28T05:05:00+00:00 EmrJobFlowSensor 2021-05-28T06:05:53.378605+00:00 2021-05-28T06:13:55.891232+00:00 0:08:02.512627 33270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T06:05:51.225468+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-28T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-28T06:05:31.591216+00:00 2021-05-28T06:05:33.230903+00:00 0:00:01.639687 33269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T06:05:29.245126+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-28T05:05:00+00:00 PythonOperator 2021-05-28T06:05:09.577913+00:00 2021-05-28T06:05:12.728865+00:00 0:00:03.150952 33268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T06:05:07.085705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-28T05:00:00+00:00 EmrJobFlowSensor 2021-05-28T06:01:14.836371+00:00 2021-05-28T06:09:17.460437+00:00 0:08:02.624066 33267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T06:01:12.650970+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-28T05:00:00+00:00 EmrJobFlowSensor 2021-05-28T06:01:09.042468+00:00 2021-05-28T06:10:11.639101+00:00 0:09:02.596633 33266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T06:01:06.641950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T06:00:42.799731+00:00 2021-05-28T06:00:44.519286+00:00 0:00:01.719555 33265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-28T06:00:40.618321+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T06:00:41.017259+00:00 2021-05-28T06:00:42.868832+00:00 0:00:01.851573 33264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T06:00:38.665681+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-28T05:00:00+00:00 PythonOperator 2021-05-28T06:00:20.762137+00:00 2021-05-28T06:00:24.030664+00:00 0:00:03.268527 33263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-28T06:00:18.609519+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-28T05:00:00+00:00 PythonOperator 2021-05-28T06:00:19.075485+00:00 2021-05-28T06:00:22.205360+00:00 0:00:03.129875 33262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T06:00:16.597948+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-28T04:00:00+00:00 EmrJobFlowSensor 2021-05-28T05:11:05.666166+00:00 2021-05-28T05:20:08.156379+00:00 0:09:02.490213 33260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T05:11:03.378948+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-28T04:00:00+00:00 EmrJobFlowSensor 2021-05-28T05:11:03.900197+00:00 2021-05-28T05:21:06.842236+00:00 0:10:02.942039 33259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T05:11:01.364607+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T05:10:43.938939+00:00 2021-05-28T05:10:45.762284+00:00 0:00:01.823345 33258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T05:10:41.356500+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T05:10:43.626540+00:00 2021-05-28T05:10:45.389698+00:00 0:00:01.763158 33257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T05:10:41.356454+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-28T04:00:00+00:00 PythonOperator 2021-05-28T05:10:23.400154+00:00 2021-05-28T05:10:26.626463+00:00 0:00:03.226309 33256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T05:10:21.239194+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-28T04:00:00+00:00 PythonOperator 2021-05-28T05:10:21.531117+00:00 2021-05-28T05:10:24.949402+00:00 0:00:03.418285 33255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T05:10:19.240509+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-28T04:00:00+00:00 TriggerDagRunOperator 2021-05-28T05:10:07.545356+00:00 2021-05-28T05:10:08.093642+00:00 0:00:00.548286 33254 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T05:10:05.223137+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-28T04:00:00+00:00 TriggerDagRunOperator 2021-05-28T05:10:07.387056+00:00 2021-05-28T05:10:07.813954+00:00 0:00:00.426898 33253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T05:10:05.223103+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-28T04:05:00+00:00 EmrJobFlowSensor 2021-05-28T05:06:23.155404+00:00 2021-05-28T05:14:25.692719+00:00 0:08:02.537315 33252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T05:06:20.826374+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-28T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-28T05:06:01.093268+00:00 2021-05-28T05:06:02.785052+00:00 0:00:01.691784 33251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T05:05:58.944440+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-28T04:05:00+00:00 PythonOperator 2021-05-28T05:05:26.866897+00:00 2021-05-28T05:05:30.073513+00:00 0:00:03.206616 33250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T05:05:24.744632+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-28T04:00:00+00:00 EmrJobFlowSensor 2021-05-28T05:01:06.420054+00:00 2021-05-28T05:09:08.884787+00:00 0:08:02.464733 33249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T05:01:04.319368+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-28T04:00:00+00:00 EmrJobFlowSensor 2021-05-28T05:00:48.498659+00:00 2021-05-28T05:09:51.117925+00:00 0:09:02.619266 33248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T05:00:46.293209+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T05:00:42.420938+00:00 2021-05-28T05:00:44.070909+00:00 0:00:01.649971 33247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T05:00:40.285462+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T05:00:26.684683+00:00 2021-05-28T05:00:28.385422+00:00 0:00:01.700739 33246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-28T05:00:24.235106+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-28T04:00:00+00:00 PythonOperator 2021-05-28T05:00:20.484606+00:00 2021-05-28T05:00:23.715814+00:00 0:00:03.231208 33245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T05:00:18.233455+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-28T04:00:00+00:00 PythonOperator 2021-05-28T05:00:04.626192+00:00 2021-05-28T05:00:07.863534+00:00 0:00:03.237342 33244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-28T05:00:02.217591+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-28T03:00:00+00:00 EmrJobFlowSensor 2021-05-28T04:11:30.517287+00:00 2021-05-28T04:20:33.265253+00:00 0:09:02.747966 33242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T04:11:28.140688+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-28T03:00:00+00:00 EmrJobFlowSensor 2021-05-28T04:11:16.361517+00:00 2021-05-28T04:20:19.193510+00:00 0:09:02.831993 33241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T04:11:14.057025+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T04:11:08.198783+00:00 2021-05-28T04:11:09.977037+00:00 0:00:01.778254 33240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T04:11:06.044562+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T04:10:54.505307+00:00 2021-05-28T04:10:56.349812+00:00 0:00:01.844505 33239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T04:10:52.031978+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-28T03:00:00+00:00 PythonOperator 2021-05-28T04:10:48.274548+00:00 2021-05-28T04:10:51.754822+00:00 0:00:03.480274 33238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T04:10:46.023816+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-28T03:00:00+00:00 PythonOperator 2021-05-28T04:10:32.571737+00:00 2021-05-28T04:10:35.800222+00:00 0:00:03.228485 33237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T04:10:30.072586+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-28T03:00:00+00:00 TriggerDagRunOperator 2021-05-28T04:10:26.456894+00:00 2021-05-28T04:10:27.154294+00:00 0:00:00.697400 33236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T04:10:24.007897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-28T03:00:00+00:00 TriggerDagRunOperator 2021-05-28T04:10:26.291381+00:00 2021-05-28T04:10:26.823996+00:00 0:00:00.532615 33235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T04:10:24.007930+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-28T03:05:00+00:00 EmrJobFlowSensor 2021-05-28T04:06:03.990320+00:00 2021-05-28T04:15:06.547229+00:00 0:09:02.556909 33234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T04:06:01.686997+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-28T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-28T04:05:41.797564+00:00 2021-05-28T04:05:43.400941+00:00 0:00:01.603377 33233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T04:05:39.662545+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-28T03:05:00+00:00 PythonOperator 2021-05-28T04:05:20.055289+00:00 2021-05-28T04:05:23.347133+00:00 0:00:03.291844 33232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T04:05:17.749853+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-28T03:00:00+00:00 EmrJobFlowSensor 2021-05-28T04:01:07.354837+00:00 2021-05-28T04:10:09.941572+00:00 0:09:02.586735 33231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T04:01:05.177126+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-28T03:00:00+00:00 EmrJobFlowSensor 2021-05-28T04:00:59.311251+00:00 2021-05-28T04:09:01.891000+00:00 0:08:02.579749 33230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T04:00:57.111989+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T04:00:43.335954+00:00 2021-05-28T04:00:45.076352+00:00 0:00:01.740398 33229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-28T04:00:41.089760+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T04:00:37.652973+00:00 2021-05-28T04:00:39.465380+00:00 0:00:01.812407 33228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T04:00:35.156420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-28T03:00:00+00:00 PythonOperator 2021-05-28T04:00:23.250867+00:00 2021-05-28T04:00:26.552809+00:00 0:00:03.301942 33227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-28T04:00:21.026163+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-28T03:00:00+00:00 PythonOperator 2021-05-28T04:00:17.344255+00:00 2021-05-28T04:00:20.566866+00:00 0:00:03.222611 33226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-28T04:00:15.024981+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-28T02:00:00+00:00 EmrJobFlowSensor 2021-05-28T03:10:12.132231+00:00 2021-05-28T03:19:14.915573+00:00 0:09:02.783342 33224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T03:10:09.818062+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-28T02:00:00+00:00 EmrJobFlowSensor 2021-05-28T03:10:11.996139+00:00 2021-05-28T03:18:14.593531+00:00 0:08:02.597392 33223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-28T03:10:09.818026+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T03:09:52.377784+00:00 2021-05-28T03:09:54.075810+00:00 0:00:01.698026 33222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T03:09:49.800098+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-28T03:09:50.050496+00:00 2021-05-28T03:09:52.113664+00:00 0:00:02.063168 33221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-28T03:09:47.797599+00:00 2 default_pool