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-04-07T05:00:00+00:00 TriggerDagRunOperator 2021-04-07T06:13:39.788061+00:00 2021-04-07T06:13:40.210419+00:00 0:00:00.422358 14470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:13:37.090153+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T05:05:00+00:00 EmrJobFlowSensor 2021-04-07T06:05:56.699764+00:00 2021-04-07T06:14:59.286694+00:00 0:09:02.586930 14468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:05:54.452139+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T06:05:34.602048+00:00 2021-04-07T06:05:36.263844+00:00 0:00:01.661796 14467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T06:05:32.432759+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T05:05:00+00:00 PythonOperator 2021-04-07T06:05:12.928153+00:00 2021-04-07T06:05:15.613118+00:00 0:00:02.684965 14466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T06:05:10.487597+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T05:00:00+00:00 EmrJobFlowSensor 2021-04-07T06:01:12.360461+00:00 2021-04-07T06:10:15.153125+00:00 0:09:02.792664 14465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T06:01:10.022996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T06:00:44.479813+00:00 2021-04-07T06:00:46.289402+00:00 0:00:01.809589 14464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T06:00:41.995372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T05:00:00+00:00 PythonOperator 2021-04-07T06:00:22.136366+00:00 2021-04-07T06:00:24.904330+00:00 0:00:02.767964 14463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T06:00:19.943916+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T04:00:00+00:00 EmrJobFlowSensor 2021-04-07T05:10:33.200304+00:00 2021-04-07T05:19:35.833779+00:00 0:09:02.633475 14462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:10:30.984218+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T04:00:00+00:00 EmrJobFlowSensor 2021-04-07T05:10:25.134395+00:00 2021-04-07T05:20:27.946732+00:00 0:10:02.812337 14461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:10:22.908512+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T05:10:11.230336+00:00 2021-04-07T05:10:13.043852+00:00 0:00:01.813516 14460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T05:10:08.896346+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T05:10:05.243608+00:00 2021-04-07T05:10:06.986302+00:00 0:00:01.742694 14459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T05:10:02.889116+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T04:00:00+00:00 PythonOperator 2021-04-07T05:09:51.128459+00:00 2021-04-07T05:09:54.239101+00:00 0:00:03.110642 14458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T05:09:48.874248+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T04:00:00+00:00 PythonOperator 2021-04-07T05:09:43.104578+00:00 2021-04-07T05:09:45.780942+00:00 0:00:02.676364 14457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T05:09:40.870945+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T04:00:00+00:00 TriggerDagRunOperator 2021-04-07T05:09:25.373078+00:00 2021-04-07T05:09:25.965227+00:00 0:00:00.592149 14456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:09:22.858225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T04:00:00+00:00 TriggerDagRunOperator 2021-04-07T05:09:25.293550+00:00 2021-04-07T05:09:25.754076+00:00 0:00:00.460526 14455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:09:22.858178+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T04:05:00+00:00 EmrJobFlowSensor 2021-04-07T05:08:35.082576+00:00 2021-04-07T05:17:37.774123+00:00 0:09:02.691547 14454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:08:32.766817+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T05:08:14.881781+00:00 2021-04-07T05:08:16.530800+00:00 0:00:01.649019 14453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T05:08:12.693607+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T04:05:00+00:00 PythonOperator 2021-04-07T05:07:53.485916+00:00 2021-04-07T05:07:56.330933+00:00 0:00:02.845017 14452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T05:07:50.669017+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T04:00:00+00:00 EmrJobFlowSensor 2021-04-07T05:01:00.830257+00:00 2021-04-07T05:09:03.523447+00:00 0:08:02.693190 14450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T05:00:58.269532+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T05:00:38.297702+00:00 2021-04-07T05:00:40.038036+00:00 0:00:01.740334 14449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T05:00:36.062097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T04:00:00+00:00 PythonOperator 2021-04-07T05:00:16.541401+00:00 2021-04-07T05:00:19.336471+00:00 0:00:02.795070 14448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T05:00:14.065589+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T03:00:00+00:00 EmrJobFlowSensor 2021-04-07T04:14:01.784813+00:00 2021-04-07T04:23:04.538223+00:00 0:09:02.753410 14447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T04:13:59.040944+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T03:00:00+00:00 EmrJobFlowSensor 2021-04-07T04:13:59.228813+00:00 2021-04-07T04:24:02.559353+00:00 0:10:03.330540 14446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T04:13:56.871698+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T04:13:38.980865+00:00 2021-04-07T04:13:40.647219+00:00 0:00:01.666354 14445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T04:13:36.752982+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T04:13:36.951769+00:00 2021-04-07T04:13:38.760355+00:00 0:00:01.808586 14444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T04:13:34.698425+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T03:00:00+00:00 PythonOperator 2021-04-07T04:13:19.292848+00:00 2021-04-07T04:13:21.974604+00:00 0:00:02.681756 14443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T04:13:16.545530+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T03:00:00+00:00 PythonOperator 2021-04-07T04:13:16.750371+00:00 2021-04-07T04:13:20.076332+00:00 0:00:03.325961 14442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T04:13:14.573163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T03:00:00+00:00 TriggerDagRunOperator 2021-04-07T04:12:56.808488+00:00 2021-04-07T04:12:57.219945+00:00 0:00:00.411457 14441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T04:12:54.529821+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T03:00:00+00:00 TriggerDagRunOperator 2021-04-07T04:12:56.797770+00:00 2021-04-07T04:12:57.328101+00:00 0:00:00.530331 14440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T04:12:54.529785+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T03:05:00+00:00 EmrJobFlowSensor 2021-04-07T04:05:56.272301+00:00 2021-04-07T04:13:58.847006+00:00 0:08:02.574705 14439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T04:05:54.144573+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T04:05:34.713590+00:00 2021-04-07T04:05:36.477906+00:00 0:00:01.764316 14438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T04:05:32.176550+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T03:05:00+00:00 PythonOperator 2021-04-07T04:05:12.387586+00:00 2021-04-07T04:05:15.149885+00:00 0:00:02.762299 14437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T04:05:10.148631+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T03:00:00+00:00 EmrJobFlowSensor 2021-04-07T04:03:28.350722+00:00 2021-04-07T04:12:31.096640+00:00 0:09:02.745918 14436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T04:03:25.988742+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T04:03:06.114639+00:00 2021-04-07T04:03:07.822804+00:00 0:00:01.708165 14435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T04:03:03.918735+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T03:00:00+00:00 PythonOperator 2021-04-07T04:02:46.224204+00:00 2021-04-07T04:02:48.972487+00:00 0:00:02.748283 14434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T04:02:43.899629+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T02:00:00+00:00 EmrJobFlowSensor 2021-04-07T03:12:19.726303+00:00 2021-04-07T03:23:22.756632+00:00 0:11:03.030329 14432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T03:12:17.303587+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T02:00:00+00:00 EmrJobFlowSensor 2021-04-07T03:12:13.519541+00:00 2021-04-07T03:22:16.330288+00:00 0:10:02.810747 14431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T03:12:11.295000+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T03:11:57.748564+00:00 2021-04-07T03:11:59.408153+00:00 0:00:01.659589 14430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T03:11:55.287473+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T03:11:51.437609+00:00 2021-04-07T03:11:53.171143+00:00 0:00:01.733534 14429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T03:11:49.234779+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T02:00:00+00:00 PythonOperator 2021-04-07T03:11:37.669797+00:00 2021-04-07T03:11:40.660018+00:00 0:00:02.990221 14428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T03:11:35.257926+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T02:00:00+00:00 PythonOperator 2021-04-07T03:11:29.584549+00:00 2021-04-07T03:11:32.419144+00:00 0:00:02.834595 14427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T03:11:27.201533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T02:00:00+00:00 TriggerDagRunOperator 2021-04-07T03:11:13.891901+00:00 2021-04-07T03:11:14.420647+00:00 0:00:00.528746 14426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T03:11:11.248065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T02:00:00+00:00 TriggerDagRunOperator 2021-04-07T03:11:13.548785+00:00 2021-04-07T03:11:13.965330+00:00 0:00:00.416545 14425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T03:11:11.248112+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T02:05:00+00:00 EmrJobFlowSensor 2021-04-07T03:05:56.951441+00:00 2021-04-07T03:13:59.543433+00:00 0:08:02.591992 14424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T03:05:54.561018+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T03:05:36.671978+00:00 2021-04-07T03:05:38.392802+00:00 0:00:01.720824 14423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T03:05:34.491624+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T02:05:00+00:00 PythonOperator 2021-04-07T03:05:14.753424+00:00 2021-04-07T03:05:17.499834+00:00 0:00:02.746410 14422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T03:05:12.479507+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T02:00:00+00:00 EmrJobFlowSensor 2021-04-07T03:00:54.386881+00:00 2021-04-07T03:10:57.296112+00:00 0:10:02.909231 14421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T03:00:52.041205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T03:00:34.435619+00:00 2021-04-07T03:00:36.258462+00:00 0:00:01.822843 14420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T03:00:32.025024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T02:00:00+00:00 PythonOperator 2021-04-07T03:00:12.889991+00:00 2021-04-07T03:00:15.718642+00:00 0:00:02.828651 14419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T03:00:10.066211+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T01:00:00+00:00 EmrJobFlowSensor 2021-04-07T02:35:10.485227+00:00 2021-04-07T02:35:11.960727+00:00 0:00:01.475500 14417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T02:35:08.174795+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T01:00:00+00:00 EmrJobFlowSensor 2021-04-07T02:22:15.219147+00:00 2021-04-07T02:40:19.287555+00:00 0:18:04.068408 14415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T02:22:12.884152+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T02:22:07.303251+00:00 2021-04-07T02:22:09.018389+00:00 0:00:01.715138 14414 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T02:22:04.835115+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T02:21:55.190123+00:00 2021-04-07T02:21:56.914354+00:00 0:00:01.724231 14413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T02:21:52.797268+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T01:00:00+00:00 PythonOperator 2021-04-07T02:21:45.421683+00:00 2021-04-07T02:21:48.427282+00:00 0:00:03.005599 14412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T02:21:42.853284+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T01:00:00+00:00 PythonOperator 2021-04-07T02:21:33.391745+00:00 2021-04-07T02:21:36.159084+00:00 0:00:02.767339 14411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T02:21:30.786616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T01:00:00+00:00 TriggerDagRunOperator 2021-04-07T02:21:25.535791+00:00 2021-04-07T02:21:25.946149+00:00 0:00:00.410358 14410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T02:21:22.758993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T01:00:00+00:00 TriggerDagRunOperator 2021-04-07T02:21:25.536545+00:00 2021-04-07T02:21:26.102239+00:00 0:00:00.565694 14409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T02:21:22.759035+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T01:05:00+00:00 EmrJobFlowSensor 2021-04-07T02:06:07.656972+00:00 2021-04-07T02:15:10.437894+00:00 0:09:02.780922 14408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T02:06:05.459927+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T02:05:45.786940+00:00 2021-04-07T02:05:47.534847+00:00 0:00:01.747907 14407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T02:05:43.435866+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T01:05:00+00:00 PythonOperator 2021-04-07T02:05:23.748812+00:00 2021-04-07T02:05:26.623357+00:00 0:00:02.874545 14406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T02:05:21.388248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T01:00:00+00:00 EmrJobFlowSensor 2021-04-07T02:01:05.504262+00:00 2021-04-07T02:21:09.814001+00:00 0:20:04.309739 14405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T02:01:02.866839+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T02:00:43.244637+00:00 2021-04-07T02:00:44.939789+00:00 0:00:01.695152 14404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T02:00:40.861729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T01:00:00+00:00 PythonOperator 2021-04-07T02:00:23.281330+00:00 2021-04-07T02:00:26.174917+00:00 0:00:02.893587 14403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T02:00:20.751910+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T00:00:00+00:00 EmrJobFlowSensor 2021-04-07T01:12:04.162183+00:00 2021-04-07T01:21:06.797802+00:00 0:09:02.635619 14401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:12:01.834788+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T00:00:00+00:00 EmrJobFlowSensor 2021-04-07T01:11:54.340106+00:00 2021-04-07T01:21:57.196954+00:00 0:10:02.856848 14400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:11:51.826110+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:11:41.948780+00:00 2021-04-07T01:11:43.616991+00:00 0:00:01.668211 14399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T01:11:39.816669+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:11:34.529546+00:00 2021-04-07T01:11:36.314698+00:00 0:00:01.785152 14398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T01:11:31.809104+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T00:00:00+00:00 PythonOperator 2021-04-07T01:11:22.048572+00:00 2021-04-07T01:11:24.878897+00:00 0:00:02.830325 14397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:11:19.799889+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T00:00:00+00:00 PythonOperator 2021-04-07T01:11:10.340380+00:00 2021-04-07T01:11:13.269814+00:00 0:00:02.929434 14396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:11:07.857703+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T00:00:00+00:00 TriggerDagRunOperator 2021-04-07T01:11:00.841463+00:00 2021-04-07T01:11:01.349191+00:00 0:00:00.507728 14395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:10:57.865665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T00:00:00+00:00 TriggerDagRunOperator 2021-04-07T01:11:00.414675+00:00 2021-04-07T01:11:00.895462+00:00 0:00:00.480787 14394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:10:57.865617+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T00:05:00+00:00 EmrJobFlowSensor 2021-04-07T01:05:47.348938+00:00 2021-04-07T01:14:49.959470+00:00 0:09:02.610532 14393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:05:45.128328+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:05:27.415900+00:00 2021-04-07T01:05:29.147829+00:00 0:00:01.731929 14392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T01:05:25.104754+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T00:05:00+00:00 PythonOperator 2021-04-07T01:05:05.386668+00:00 2021-04-07T01:05:08.069305+00:00 0:00:02.682637 14391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:05:03.155407+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T00:00:00+00:00 EmrJobFlowSensor 2021-04-07T01:00:51.019454+00:00 2021-04-07T01:10:53.954185+00:00 0:10:02.934731 14390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:00:48.605201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:00:29.026822+00:00 2021-04-07T01:00:30.708903+00:00 0:00:01.682081 14389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T01:00:26.578250+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T00:00:00+00:00 PythonOperator 2021-04-07T01:00:09.146184+00:00 2021-04-07T01:00:11.991896+00:00 0:00:02.845712 14388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T01:00:06.579285+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T23:00:00+00:00 EmrJobFlowSensor 2021-04-07T00:11:22.020505+00:00 2021-04-07T00:19:24.555889+00:00 0:08:02.535384 14386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:11:19.799410+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T23:00:00+00:00 EmrJobFlowSensor 2021-04-07T00:11:16.136355+00:00 2021-04-07T00:21:18.985348+00:00 0:10:02.848993 14385 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:11:13.807870+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:11:00.187899+00:00 2021-04-07T00:11:01.943730+00:00 0:00:01.755831 14384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T00:10:57.844127+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:10:54.245792+00:00 2021-04-07T00:10:56.044421+00:00 0:00:01.798629 14383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T00:10:51.775828+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T23:00:00+00:00 PythonOperator 2021-04-07T00:10:40.109230+00:00 2021-04-07T00:10:42.925187+00:00 0:00:02.815957 14382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:10:37.764214+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T23:00:00+00:00 PythonOperator 2021-04-07T00:10:34.036865+00:00 2021-04-07T00:10:37.157057+00:00 0:00:03.120192 14381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:10:31.758551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T23:00:00+00:00 TriggerDagRunOperator 2021-04-07T00:10:24.393230+00:00 2021-04-07T00:10:24.970999+00:00 0:00:00.577769 14380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:10:21.757638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T23:00:00+00:00 TriggerDagRunOperator 2021-04-07T00:10:24.205991+00:00 2021-04-07T00:10:24.718727+00:00 0:00:00.512736 14379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:10:21.757667+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T23:05:00+00:00 EmrJobFlowSensor 2021-04-07T00:06:03.602312+00:00 2021-04-07T00:15:06.420687+00:00 0:09:02.818375 14378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:06:01.308907+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:05:41.444680+00:00 2021-04-07T00:05:43.073871+00:00 0:00:01.629191 14377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T00:05:39.289068+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T23:05:00+00:00 PythonOperator 2021-04-07T00:05:21.393959+00:00 2021-04-07T00:05:24.213762+00:00 0:00:02.819803 14376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:05:19.226813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T23:00:00+00:00 EmrJobFlowSensor 2021-04-07T00:01:05.264674+00:00 2021-04-07T00:10:07.938612+00:00 0:09:02.673938 14375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:01:02.910477+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:00:45.129125+00:00 2021-04-07T00:00:46.878677+00:00 0:00:01.749552 14374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T00:00:42.891691+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T23:00:00+00:00 PythonOperator 2021-04-07T00:00:23.263202+00:00 2021-04-07T00:00:26.221567+00:00 0:00:02.958365 14373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T00:00:20.817701+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T22:00:00+00:00 EmrJobFlowSensor 2021-04-06T23:12:27.329230+00:00 2021-04-06T23:20:29.833127+00:00 0:08:02.503897 14371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:12:25.149561+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T22:00:00+00:00 EmrJobFlowSensor 2021-04-06T23:11:29.464833+00:00 2021-04-06T23:29:33.385948+00:00 0:18:03.921115 14370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:11:27.108635+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T23:11:09.436650+00:00 2021-04-06T23:11:11.230909+00:00 0:00:01.794259 14369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T23:11:07.095643+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T23:11:07.221866+00:00 2021-04-06T23:11:08.928467+00:00 0:00:01.706601 14368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T23:11:05.061658+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T22:00:00+00:00 PythonOperator 2021-04-06T23:10:49.337008+00:00 2021-04-06T23:10:52.250826+00:00 0:00:02.913818 14367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T23:10:47.024344+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T22:00:00+00:00 PythonOperator 2021-04-06T23:10:45.538519+00:00 2021-04-06T23:10:48.308302+00:00 0:00:02.769783 14366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T23:10:43.022657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T22:00:00+00:00 TriggerDagRunOperator 2021-04-06T23:10:33.441296+00:00 2021-04-06T23:10:34.004279+00:00 0:00:00.562983 14365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:10:31.016177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T22:00:00+00:00 TriggerDagRunOperator 2021-04-06T23:10:33.278624+00:00 2021-04-06T23:10:33.720065+00:00 0:00:00.441441 14364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:10:31.016213+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T22:05:00+00:00 EmrJobFlowSensor 2021-04-06T23:05:58.884281+00:00 2021-04-06T23:15:01.545061+00:00 0:09:02.660780 14363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:05:56.537682+00:00 2 default_pool