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-26T21:00:00+00:00 TriggerDagRunOperator 2021-04-26T22:11:17.732050+00:00 2021-04-26T22:11:18.138559+00:00 0:00:00.406509 21611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T22:11:15.010332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T21:00:00+00:00 TriggerDagRunOperator 2021-04-26T22:11:17.284802+00:00 2021-04-26T22:11:17.840917+00:00 0:00:00.556115 21610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T22:11:15.010364+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T21:05:00+00:00 EmrJobFlowSensor 2021-04-26T22:06:10.804785+00:00 2021-04-26T22:15:13.452664+00:00 0:09:02.647879 21609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T22:06:08.590526+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T22:05:46.797246+00:00 2021-04-26T22:05:48.531375+00:00 0:00:01.734129 21608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T22:05:44.525509+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T21:05:00+00:00 PythonOperator 2021-04-26T22:05:18.692714+00:00 2021-04-26T22:05:21.644783+00:00 0:00:02.952069 21607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T22:05:16.554079+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T21:00:00+00:00 EmrJobFlowSensor 2021-04-26T22:01:06.315305+00:00 2021-04-26T22:11:09.290245+00:00 0:10:02.974940 21606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T22:01:04.055152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T22:00:46.322245+00:00 2021-04-26T22:00:48.149918+00:00 0:00:01.827673 21605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T22:00:43.991006+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T21:00:00+00:00 PythonOperator 2021-04-26T22:00:24.195375+00:00 2021-04-26T22:00:27.196959+00:00 0:00:03.001584 21604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T22:00:21.915304+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T20:00:00+00:00 EmrJobFlowSensor 2021-04-26T21:10:11.261336+00:00 2021-04-26T21:20:14.084287+00:00 0:10:02.822951 21602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T21:10:08.946817+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T20:00:00+00:00 EmrJobFlowSensor 2021-04-26T21:10:05.403631+00:00 2021-04-26T21:20:08.269758+00:00 0:10:02.866127 21601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T21:10:02.946416+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T21:09:51.353647+00:00 2021-04-26T21:09:53.063547+00:00 0:00:01.709900 21600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T21:09:48.823766+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T21:09:42.988549+00:00 2021-04-26T21:09:44.668987+00:00 0:00:01.680438 21599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T21:09:40.816253+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T20:00:00+00:00 PythonOperator 2021-04-26T21:09:29.601802+00:00 2021-04-26T21:09:32.568775+00:00 0:00:02.966973 21598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T21:09:26.810235+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T20:00:00+00:00 PythonOperator 2021-04-26T21:09:20.883299+00:00 2021-04-26T21:09:24.087729+00:00 0:00:03.204430 21597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T21:09:18.772526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T20:00:00+00:00 TriggerDagRunOperator 2021-04-26T21:09:05.963924+00:00 2021-04-26T21:09:06.345680+00:00 0:00:00.381756 21596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T21:09:02.752990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T20:00:00+00:00 TriggerDagRunOperator 2021-04-26T21:09:05.395274+00:00 2021-04-26T21:09:05.931344+00:00 0:00:00.536070 21595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T21:09:02.753021+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T20:05:00+00:00 EmrJobFlowSensor 2021-04-26T21:05:54.770720+00:00 2021-04-26T21:15:57.516101+00:00 0:10:02.745381 21594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T21:05:52.543412+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T21:05:34.708441+00:00 2021-04-26T21:05:36.517047+00:00 0:00:01.808606 21593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T21:05:32.436598+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T20:05:00+00:00 PythonOperator 2021-04-26T21:05:10.780785+00:00 2021-04-26T21:05:13.726122+00:00 0:00:02.945337 21592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T21:05:08.475137+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T20:00:00+00:00 EmrJobFlowSensor 2021-04-26T21:00:54.585945+00:00 2021-04-26T21:08:57.196180+00:00 0:08:02.610235 21591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T21:00:52.102305+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T21:00:32.687592+00:00 2021-04-26T21:00:34.358621+00:00 0:00:01.671029 21590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T21:00:30.154507+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T20:00:00+00:00 PythonOperator 2021-04-26T21:00:12.280081+00:00 2021-04-26T21:00:15.302333+00:00 0:00:03.022252 21589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T21:00:10.024229+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T19:00:00+00:00 EmrJobFlowSensor 2021-04-26T20:11:15.070431+00:00 2021-04-26T20:20:17.847277+00:00 0:09:02.776846 21587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T20:11:12.602964+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T19:00:00+00:00 EmrJobFlowSensor 2021-04-26T20:11:14.885230+00:00 2021-04-26T20:21:17.753380+00:00 0:10:02.868150 21586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T20:11:12.602996+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T20:10:53.183449+00:00 2021-04-26T20:10:54.959308+00:00 0:00:01.775859 21585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T20:10:50.653839+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T20:10:53.006326+00:00 2021-04-26T20:10:54.722394+00:00 0:00:01.716068 21584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T20:10:50.653789+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T19:00:00+00:00 PythonOperator 2021-04-26T20:10:19.483326+00:00 2021-04-26T20:10:22.767064+00:00 0:00:03.283738 21583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T20:10:16.544171+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T19:00:00+00:00 PythonOperator 2021-04-26T20:10:19.081854+00:00 2021-04-26T20:10:22.032762+00:00 0:00:02.950908 21582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T20:10:16.544136+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T19:00:00+00:00 TriggerDagRunOperator 2021-04-26T20:10:10.829368+00:00 2021-04-26T20:10:11.398015+00:00 0:00:00.568647 21581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T20:10:08.540051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T19:00:00+00:00 TriggerDagRunOperator 2021-04-26T20:10:10.805811+00:00 2021-04-26T20:10:11.252821+00:00 0:00:00.447010 21580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T20:10:08.540014+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T19:05:00+00:00 EmrJobFlowSensor 2021-04-26T20:06:10.343425+00:00 2021-04-26T20:16:13.079915+00:00 0:10:02.736490 21579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T20:06:08.128523+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T20:05:38.449007+00:00 2021-04-26T20:05:40.218393+00:00 0:00:01.769386 21578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T20:05:36.092262+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T19:05:00+00:00 PythonOperator 2021-04-26T20:05:14.569784+00:00 2021-04-26T20:05:17.552640+00:00 0:00:02.982856 21577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T20:05:12.078555+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T19:00:00+00:00 EmrJobFlowSensor 2021-04-26T20:00:50.037554+00:00 2021-04-26T20:09:52.797523+00:00 0:09:02.759969 21576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T20:00:47.571977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T20:00:27.870512+00:00 2021-04-26T20:00:29.538083+00:00 0:00:01.667571 21575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T20:00:25.552615+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T19:00:00+00:00 PythonOperator 2021-04-26T20:00:07.866491+00:00 2021-04-26T20:00:10.891108+00:00 0:00:03.024617 21574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T20:00:05.445062+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T18:00:00+00:00 EmrJobFlowSensor 2021-04-26T19:10:04.363584+00:00 2021-04-26T19:19:08.219936+00:00 0:09:03.856352 21572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T19:10:01.944013+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T18:00:00+00:00 EmrJobFlowSensor 2021-04-26T19:10:02.018378+00:00 2021-04-26T19:19:04.736256+00:00 0:09:02.717878 21571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T19:09:59.885425+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T19:09:44.150077+00:00 2021-04-26T19:09:45.993720+00:00 0:00:01.843643 21570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T19:09:41.835082+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T19:09:40.128018+00:00 2021-04-26T19:09:41.906573+00:00 0:00:01.778555 21569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T19:09:37.833836+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T18:00:00+00:00 PythonOperator 2021-04-26T19:09:22.773326+00:00 2021-04-26T19:09:26.048248+00:00 0:00:03.274922 21568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T19:09:19.941069+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T18:00:00+00:00 PythonOperator 2021-04-26T19:09:18.167556+00:00 2021-04-26T19:09:21.544143+00:00 0:00:03.376587 21567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T19:09:15.796232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T18:00:00+00:00 TriggerDagRunOperator 2021-04-26T19:09:12.549587+00:00 2021-04-26T19:09:12.993182+00:00 0:00:00.443595 21566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T19:09:09.851180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T18:00:00+00:00 TriggerDagRunOperator 2021-04-26T19:09:12.197379+00:00 2021-04-26T19:09:12.809352+00:00 0:00:00.611973 21565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T19:09:09.851211+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T18:05:00+00:00 EmrJobFlowSensor 2021-04-26T19:05:57.715230+00:00 2021-04-26T19:14:00.094592+00:00 0:08:02.379362 21564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T19:05:55.609681+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T19:05:34.139416+00:00 2021-04-26T19:05:35.760422+00:00 0:00:01.621006 21563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T19:05:31.644148+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T18:05:00+00:00 PythonOperator 2021-04-26T19:05:11.738634+00:00 2021-04-26T19:05:14.691242+00:00 0:00:02.952608 21562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T19:05:09.500188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T18:00:00+00:00 EmrJobFlowSensor 2021-04-26T19:01:01.310910+00:00 2021-04-26T19:09:03.877255+00:00 0:08:02.566345 21561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T19:00:59.140263+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T19:00:35.477523+00:00 2021-04-26T19:00:37.127865+00:00 0:00:01.650342 21560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T19:00:33.118210+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T18:00:00+00:00 PythonOperator 2021-04-26T19:00:13.879185+00:00 2021-04-26T19:00:16.896449+00:00 0:00:03.017264 21559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T19:00:11.162455+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T17:00:00+00:00 EmrJobFlowSensor 2021-04-26T18:12:25.659799+00:00 2021-04-26T18:22:28.438290+00:00 0:10:02.778491 21557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T18:12:23.189427+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T17:00:00+00:00 EmrJobFlowSensor 2021-04-26T18:12:17.287157+00:00 2021-04-26T18:22:20.078258+00:00 0:10:02.791101 21556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T18:12:15.170858+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T18:12:03.366440+00:00 2021-04-26T18:12:05.236469+00:00 0:00:01.870029 21555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T18:12:01.108155+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T18:11:57.485774+00:00 2021-04-26T18:11:59.185799+00:00 0:00:01.700025 21554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T18:11:55.170625+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T17:00:00+00:00 PythonOperator 2021-04-26T18:11:43.808196+00:00 2021-04-26T18:11:46.803534+00:00 0:00:02.995338 21553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T18:11:41.090396+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T17:00:00+00:00 PythonOperator 2021-04-26T18:11:35.386292+00:00 2021-04-26T18:11:38.674954+00:00 0:00:03.288662 21552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T18:11:33.087462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T17:00:00+00:00 TriggerDagRunOperator 2021-04-26T18:11:21.306387+00:00 2021-04-26T18:11:21.878797+00:00 0:00:00.572410 21551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T18:11:19.019893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T17:00:00+00:00 TriggerDagRunOperator 2021-04-26T18:11:21.203189+00:00 2021-04-26T18:11:21.642946+00:00 0:00:00.439757 21550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T18:11:19.019921+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T17:05:00+00:00 EmrJobFlowSensor 2021-04-26T18:05:52.706288+00:00 2021-04-26T18:15:55.402777+00:00 0:10:02.696489 21549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T18:05:50.440215+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T18:05:28.762843+00:00 2021-04-26T18:05:30.498739+00:00 0:00:01.735896 21548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T18:05:26.393858+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T17:05:00+00:00 PythonOperator 2021-04-26T18:05:06.746388+00:00 2021-04-26T18:05:09.679745+00:00 0:00:02.933357 21547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T18:05:04.367656+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T17:00:00+00:00 EmrJobFlowSensor 2021-04-26T18:00:56.200139+00:00 2021-04-26T18:10:58.932592+00:00 0:10:02.732453 21546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T18:00:53.965997+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T18:00:36.209222+00:00 2021-04-26T18:00:37.872749+00:00 0:00:01.663527 21545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T18:00:33.953326+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T17:00:00+00:00 PythonOperator 2021-04-26T18:00:14.311151+00:00 2021-04-26T18:00:17.393650+00:00 0:00:03.082499 21544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T18:00:11.849162+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T16:00:00+00:00 EmrJobFlowSensor 2021-04-26T17:12:27.862318+00:00 2021-04-26T17:22:30.592893+00:00 0:10:02.730575 21542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T17:12:25.559272+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T16:00:00+00:00 EmrJobFlowSensor 2021-04-26T17:12:07.651636+00:00 2021-04-26T17:20:10.218080+00:00 0:08:02.566444 21541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T17:12:05.405635+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T17:12:07.657316+00:00 2021-04-26T17:12:09.577372+00:00 0:00:01.920056 21540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T17:12:05.405599+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T17:11:45.774713+00:00 2021-04-26T17:11:47.493640+00:00 0:00:01.718927 21539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T17:11:43.384839+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T16:00:00+00:00 PythonOperator 2021-04-26T17:11:45.692825+00:00 2021-04-26T17:11:48.938021+00:00 0:00:03.245196 21538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T17:11:43.384873+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T16:00:00+00:00 PythonOperator 2021-04-26T17:11:25.822063+00:00 2021-04-26T17:11:28.881235+00:00 0:00:03.059172 21537 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T17:11:23.365848+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T16:00:00+00:00 TriggerDagRunOperator 2021-04-26T17:11:19.979802+00:00 2021-04-26T17:11:20.524677+00:00 0:00:00.544875 21536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T17:11:17.366469+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T16:00:00+00:00 TriggerDagRunOperator 2021-04-26T17:11:19.939809+00:00 2021-04-26T17:11:20.370296+00:00 0:00:00.430487 21535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T17:11:17.366434+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T16:05:00+00:00 EmrJobFlowSensor 2021-04-26T17:06:03.063304+00:00 2021-04-26T17:15:05.679636+00:00 0:09:02.616332 21534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T17:06:00.883393+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T17:05:40.858131+00:00 2021-04-26T17:05:42.567090+00:00 0:00:01.708959 21533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T17:05:38.687960+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T16:05:00+00:00 PythonOperator 2021-04-26T17:05:20.787046+00:00 2021-04-26T17:05:23.744047+00:00 0:00:02.957001 21532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T17:05:18.628303+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T16:00:00+00:00 EmrJobFlowSensor 2021-04-26T17:01:00.509989+00:00 2021-04-26T17:11:03.422234+00:00 0:10:02.912245 21531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T17:00:58.285378+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T17:00:38.683682+00:00 2021-04-26T17:00:40.385483+00:00 0:00:01.701801 21530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T17:00:36.285986+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T16:00:00+00:00 PythonOperator 2021-04-26T17:00:18.620323+00:00 2021-04-26T17:00:21.683630+00:00 0:00:03.063307 21529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T17:00:16.244512+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T15:00:00+00:00 EmrJobFlowSensor 2021-04-26T16:11:28.963176+00:00 2021-04-26T16:20:31.643474+00:00 0:09:02.680298 21527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T16:11:26.609984+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T15:00:00+00:00 EmrJobFlowSensor 2021-04-26T16:11:12.886926+00:00 2021-04-26T16:19:15.539060+00:00 0:08:02.652134 21526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T16:11:10.514943+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T16:11:06.741231+00:00 2021-04-26T16:11:08.459821+00:00 0:00:01.718590 21525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T16:11:04.508310+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T16:10:50.656183+00:00 2021-04-26T16:10:52.351185+00:00 0:00:01.695002 21524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T16:10:48.492272+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T15:00:00+00:00 PythonOperator 2021-04-26T16:10:45.086702+00:00 2021-04-26T16:10:48.380666+00:00 0:00:03.293964 21523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T16:10:42.558267+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T15:00:00+00:00 PythonOperator 2021-04-26T16:10:30.658575+00:00 2021-04-26T16:10:33.603810+00:00 0:00:02.945235 21522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T16:10:28.450123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T15:00:00+00:00 TriggerDagRunOperator 2021-04-26T16:10:20.831431+00:00 2021-04-26T16:10:21.346212+00:00 0:00:00.514781 21521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T16:10:18.440902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T15:00:00+00:00 TriggerDagRunOperator 2021-04-26T16:10:20.706410+00:00 2021-04-26T16:10:21.135501+00:00 0:00:00.429091 21520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T16:10:18.440856+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T15:05:00+00:00 EmrJobFlowSensor 2021-04-26T16:05:48.281734+00:00 2021-04-26T16:15:51.073743+00:00 0:10:02.792009 21519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T16:05:45.967030+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T16:05:28.080393+00:00 2021-04-26T16:05:29.818010+00:00 0:00:01.737617 21518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T16:05:25.928699+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T15:05:00+00:00 PythonOperator 2021-04-26T16:05:06.341700+00:00 2021-04-26T16:05:09.311920+00:00 0:00:02.970220 21517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T16:05:03.983028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T15:00:00+00:00 EmrJobFlowSensor 2021-04-26T16:01:04.011898+00:00 2021-04-26T16:10:06.744246+00:00 0:09:02.732348 21516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T16:01:01.649666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T16:00:41.932008+00:00 2021-04-26T16:00:43.775985+00:00 0:00:01.843977 21515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T16:00:39.588337+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T15:00:00+00:00 PythonOperator 2021-04-26T16:00:21.797000+00:00 2021-04-26T16:00:24.846267+00:00 0:00:03.049267 21514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T16:00:19.486694+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T14:00:00+00:00 EmrJobFlowSensor 2021-04-26T15:12:18.928220+00:00 2021-04-26T15:21:21.499515+00:00 0:09:02.571295 21512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T15:12:16.603895+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T14:00:00+00:00 EmrJobFlowSensor 2021-04-26T15:12:14.917161+00:00 2021-04-26T15:21:17.743871+00:00 0:09:02.826710 21511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T15:12:12.599294+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T15:11:54.854090+00:00 2021-04-26T15:11:56.666450+00:00 0:00:01.812360 21510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T15:11:52.523521+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T15:11:52.803714+00:00 2021-04-26T15:11:54.486514+00:00 0:00:01.682800 21509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T15:11:50.526607+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T14:00:00+00:00 PythonOperator 2021-04-26T15:11:35.371776+00:00 2021-04-26T15:11:38.843278+00:00 0:00:03.471502 21508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T15:11:32.507695+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T14:00:00+00:00 PythonOperator 2021-04-26T15:11:31.110624+00:00 2021-04-26T15:11:34.908004+00:00 0:00:03.797380 21507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T15:11:28.553346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T14:00:00+00:00 TriggerDagRunOperator 2021-04-26T15:11:25.277249+00:00 2021-04-26T15:11:25.799998+00:00 0:00:00.522749 21506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T15:11:22.541688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T14:00:00+00:00 TriggerDagRunOperator 2021-04-26T15:11:25.121528+00:00 2021-04-26T15:11:25.642149+00:00 0:00:00.520621 21505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T15:11:22.541643+00:00 2 default_pool