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 vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T20:05:31.468404+00:00 2021-04-10T20:05:33.205384+00:00 0:00:01.736980 15755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T20:05:29.140650+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T19:05:00+00:00 PythonOperator 2021-04-10T20:05:05.257130+00:00 2021-04-10T20:05:08.066656+00:00 0:00:02.809526 15754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T20:05:03.015411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T19:00:00+00:00 EmrJobFlowSensor 2021-04-10T20:00:53.034307+00:00 2021-04-10T20:09:55.620004+00:00 0:09:02.585697 15753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T20:00:50.582452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T20:00:30.920618+00:00 2021-04-10T20:00:32.637704+00:00 0:00:01.717086 15752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T20:00:28.564723+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T19:00:00+00:00 PythonOperator 2021-04-10T20:00:10.702459+00:00 2021-04-10T20:00:13.639588+00:00 0:00:02.937129 15751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T20:00:08.445655+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T18:00:00+00:00 EmrJobFlowSensor 2021-04-10T19:11:20.252172+00:00 2021-04-10T19:19:22.794476+00:00 0:08:02.542304 15749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:11:17.059602+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T18:00:00+00:00 EmrJobFlowSensor 2021-04-10T19:11:18.317830+00:00 2021-04-10T19:20:21.482743+00:00 0:09:03.164913 15748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:11:15.082343+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:10:59.396291+00:00 2021-04-10T19:11:01.188918+00:00 0:00:01.792627 15747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T19:10:57.029968+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:10:55.591220+00:00 2021-04-10T19:10:57.424921+00:00 0:00:01.833701 15746 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T19:10:53.022773+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T18:00:00+00:00 PythonOperator 2021-04-10T19:10:37.908005+00:00 2021-04-10T19:10:40.613482+00:00 0:00:02.705477 15745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:10:35.009656+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T18:00:00+00:00 PythonOperator 2021-04-10T19:10:35.291804+00:00 2021-04-10T19:10:38.747190+00:00 0:00:03.455386 15744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:10:33.008298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T18:00:00+00:00 TriggerDagRunOperator 2021-04-10T19:10:29.334216+00:00 2021-04-10T19:10:29.885170+00:00 0:00:00.550954 15743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:10:27.002352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T18:00:00+00:00 TriggerDagRunOperator 2021-04-10T19:10:29.213565+00:00 2021-04-10T19:10:29.674239+00:00 0:00:00.460674 15742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:10:27.002320+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T18:05:00+00:00 EmrJobFlowSensor 2021-04-10T19:06:06.818516+00:00 2021-04-10T19:14:09.252847+00:00 0:08:02.434331 15741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:06:04.479201+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:05:46.484147+00:00 2021-04-10T19:05:48.169458+00:00 0:00:01.685311 15740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T19:05:44.398600+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T18:05:00+00:00 PythonOperator 2021-04-10T19:05:24.716364+00:00 2021-04-10T19:05:27.535856+00:00 0:00:02.819492 15739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:05:22.314050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T18:00:00+00:00 EmrJobFlowSensor 2021-04-10T19:01:10.356918+00:00 2021-04-10T19:10:13.056766+00:00 0:09:02.699848 15738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:01:07.770245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:00:47.843457+00:00 2021-04-10T19:00:49.531868+00:00 0:00:01.688411 15737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T19:00:45.702308+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T18:00:00+00:00 PythonOperator 2021-04-10T19:00:20.028506+00:00 2021-04-10T19:00:22.728018+00:00 0:00:02.699512 15736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T19:00:17.677956+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T17:00:00+00:00 EmrJobFlowSensor 2021-04-10T18:12:18.673168+00:00 2021-04-10T18:22:21.551631+00:00 0:10:02.878463 15734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:12:15.766227+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T17:00:00+00:00 EmrJobFlowSensor 2021-04-10T18:12:18.582349+00:00 2021-04-10T18:21:21.237358+00:00 0:09:02.655009 15733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:12:15.766268+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T18:11:58.599234+00:00 2021-04-10T18:12:00.270458+00:00 0:00:01.671224 15732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T18:11:55.770324+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T18:11:56.291398+00:00 2021-04-10T18:11:58.320442+00:00 0:00:02.029044 15731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T18:11:53.772918+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T17:00:00+00:00 PythonOperator 2021-04-10T18:11:36.145442+00:00 2021-04-10T18:11:39.286805+00:00 0:00:03.141363 15730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T18:11:33.692473+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T17:00:00+00:00 PythonOperator 2021-04-10T18:11:36.080159+00:00 2021-04-10T18:11:38.846382+00:00 0:00:02.766223 15729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T18:11:33.692445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T17:00:00+00:00 TriggerDagRunOperator 2021-04-10T18:11:16.098775+00:00 2021-04-10T18:11:16.544913+00:00 0:00:00.446138 15728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:11:13.647989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T17:00:00+00:00 TriggerDagRunOperator 2021-04-10T18:11:16.059945+00:00 2021-04-10T18:11:16.640575+00:00 0:00:00.580630 15727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:11:13.648022+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T17:05:00+00:00 EmrJobFlowSensor 2021-04-10T18:05:47.568954+00:00 2021-04-10T18:13:50.036330+00:00 0:08:02.467376 15726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:05:45.239199+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T18:05:25.640734+00:00 2021-04-10T18:05:27.355055+00:00 0:00:01.714321 15725 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T18:05:23.253003+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T17:05:00+00:00 PythonOperator 2021-04-10T18:05:05.635988+00:00 2021-04-10T18:05:08.357301+00:00 0:00:02.721313 15724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T18:05:03.253303+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T17:00:00+00:00 EmrJobFlowSensor 2021-04-10T18:00:59.026390+00:00 2021-04-10T18:11:01.835964+00:00 0:10:02.809574 15723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T18:00:56.717339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T18:00:37.027662+00:00 2021-04-10T18:00:38.793723+00:00 0:00:01.766061 15722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T18:00:34.747328+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T17:00:00+00:00 PythonOperator 2021-04-10T18:00:17.289501+00:00 2021-04-10T18:00:20.103527+00:00 0:00:02.814026 15721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T18:00:14.686877+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T16:00:00+00:00 EmrJobFlowSensor 2021-04-10T17:14:22.517817+00:00 2021-04-10T17:23:25.073095+00:00 0:09:02.555278 15720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:14:20.167687+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T16:00:00+00:00 EmrJobFlowSensor 2021-04-10T17:14:16.403936+00:00 2021-04-10T17:23:19.111611+00:00 0:09:02.707675 15719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:14:14.182460+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:14:00.662021+00:00 2021-04-10T17:14:02.433880+00:00 0:00:01.771859 15718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T17:13:58.160359+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:13:56.292572+00:00 2021-04-10T17:13:58.189341+00:00 0:00:01.896769 15717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T17:13:54.145347+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T16:00:00+00:00 PythonOperator 2021-04-10T17:13:40.373197+00:00 2021-04-10T17:13:43.543766+00:00 0:00:03.170569 15716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:13:38.080236+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T16:00:00+00:00 PythonOperator 2021-04-10T17:13:34.329081+00:00 2021-04-10T17:13:37.171778+00:00 0:00:02.842697 15715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:13:32.017134+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T16:00:00+00:00 TriggerDagRunOperator 2021-04-10T17:13:14.853194+00:00 2021-04-10T17:13:15.361525+00:00 0:00:00.508331 15714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:13:12.005688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T16:00:00+00:00 TriggerDagRunOperator 2021-04-10T17:13:14.618183+00:00 2021-04-10T17:13:15.060498+00:00 0:00:00.442315 15713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:13:12.005658+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T16:05:00+00:00 EmrJobFlowSensor 2021-04-10T17:06:17.406416+00:00 2021-04-10T17:14:19.896419+00:00 0:08:02.490003 15711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:06:15.085676+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:05:57.394892+00:00 2021-04-10T17:05:59.183504+00:00 0:00:01.788612 15710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T17:05:55.060255+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T16:05:00+00:00 PythonOperator 2021-04-10T17:05:27.166514+00:00 2021-04-10T17:05:29.829670+00:00 0:00:02.663156 15709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:05:25.035561+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T16:00:00+00:00 EmrJobFlowSensor 2021-04-10T17:00:48.748518+00:00 2021-04-10T17:10:51.491597+00:00 0:10:02.743079 15708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:00:46.503100+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:00:26.928107+00:00 2021-04-10T17:00:28.599832+00:00 0:00:01.671725 15707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T17:00:24.556319+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T16:00:00+00:00 PythonOperator 2021-04-10T17:00:04.643517+00:00 2021-04-10T17:00:07.347628+00:00 0:00:02.704111 15706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T17:00:02.455321+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T15:00:00+00:00 EmrJobFlowSensor 2021-04-10T16:12:16.019095+00:00 2021-04-10T16:21:18.839445+00:00 0:09:02.820350 15705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:12:13.745525+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T15:00:00+00:00 EmrJobFlowSensor 2021-04-10T16:11:56.067264+00:00 2021-04-10T16:21:59.013264+00:00 0:10:02.946000 15704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:11:53.447135+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:11:55.908865+00:00 2021-04-10T16:11:57.591355+00:00 0:00:01.682490 15703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T16:11:53.447164+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:11:35.960786+00:00 2021-04-10T16:11:37.621250+00:00 0:00:01.660464 15702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T16:11:33.334420+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T15:00:00+00:00 PythonOperator 2021-04-10T16:11:33.567847+00:00 2021-04-10T16:11:36.695423+00:00 0:00:03.127576 15701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:11:31.333522+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T15:00:00+00:00 PythonOperator 2021-04-10T16:11:13.595352+00:00 2021-04-10T16:11:16.549464+00:00 0:00:02.954112 15700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:11:11.318219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T15:00:00+00:00 TriggerDagRunOperator 2021-04-10T16:11:08.225174+00:00 2021-04-10T16:11:08.767249+00:00 0:00:00.542075 15699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:11:05.313336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T15:00:00+00:00 TriggerDagRunOperator 2021-04-10T16:11:07.740188+00:00 2021-04-10T16:11:08.189195+00:00 0:00:00.449007 15698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:11:05.313287+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T15:05:00+00:00 EmrJobFlowSensor 2021-04-10T16:07:29.395484+00:00 2021-04-10T16:16:31.986875+00:00 0:09:02.591391 15697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:07:27.101061+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:07:07.210032+00:00 2021-04-10T16:07:08.860389+00:00 0:00:01.650357 15696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T16:07:05.075762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T15:05:00+00:00 PythonOperator 2021-04-10T16:06:47.545830+00:00 2021-04-10T16:06:50.224754+00:00 0:00:02.678924 15695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:06:45.087127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T15:00:00+00:00 EmrJobFlowSensor 2021-04-10T16:00:53.549043+00:00 2021-04-10T16:10:56.870021+00:00 0:10:03.320978 15693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:00:51.099628+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:00:31.651412+00:00 2021-04-10T16:00:33.375290+00:00 0:00:01.723878 15692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T16:00:29.242502+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T15:00:00+00:00 PythonOperator 2021-04-10T16:00:11.164200+00:00 2021-04-10T16:00:13.946956+00:00 0:00:02.782756 15691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T16:00:08.970745+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T14:00:00+00:00 EmrJobFlowSensor 2021-04-10T15:22:10.029534+00:00 2021-04-10T15:32:12.808372+00:00 0:10:02.778838 15690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:22:07.560392+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T14:00:00+00:00 EmrJobFlowSensor 2021-04-10T15:22:08.177196+00:00 2021-04-10T15:31:10.998624+00:00 0:09:02.821428 15689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:22:05.486953+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:21:49.874688+00:00 2021-04-10T15:21:51.548906+00:00 0:00:01.674218 15688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T15:21:47.457340+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:21:45.763291+00:00 2021-04-10T15:21:47.711186+00:00 0:00:01.947895 15687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T15:21:43.377953+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T14:00:00+00:00 PythonOperator 2021-04-10T15:21:27.611149+00:00 2021-04-10T15:21:30.722741+00:00 0:00:03.111592 15686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:21:25.357360+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T14:00:00+00:00 PythonOperator 2021-04-10T15:21:25.792173+00:00 2021-04-10T15:21:28.508205+00:00 0:00:02.716032 15685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:21:23.357411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T14:00:00+00:00 TriggerDagRunOperator 2021-04-10T15:21:07.774786+00:00 2021-04-10T15:21:08.582422+00:00 0:00:00.807636 15684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:21:05.341938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T14:00:00+00:00 TriggerDagRunOperator 2021-04-10T15:21:07.597298+00:00 2021-04-10T15:21:07.998273+00:00 0:00:00.400975 15683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:21:05.341972+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T14:05:00+00:00 EmrJobFlowSensor 2021-04-10T15:06:11.744386+00:00 2021-04-10T15:15:14.352711+00:00 0:09:02.608325 15682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:06:09.572027+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:05:49.784397+00:00 2021-04-10T15:05:51.512642+00:00 0:00:01.728245 15681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T15:05:47.506559+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T14:05:00+00:00 PythonOperator 2021-04-10T15:05:30.094679+00:00 2021-04-10T15:05:32.869126+00:00 0:00:02.774447 15680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:05:27.558382+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T14:00:00+00:00 EmrJobFlowSensor 2021-04-10T15:00:56.134882+00:00 2021-04-10T15:21:00.301778+00:00 0:20:04.166896 15678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:00:53.622001+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:00:34.104440+00:00 2021-04-10T15:00:35.977618+00:00 0:00:01.873178 15677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T15:00:31.672151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T14:00:00+00:00 PythonOperator 2021-04-10T15:00:11.856400+00:00 2021-04-10T15:00:14.588193+00:00 0:00:02.731793 15676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T15:00:09.592707+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T13:00:00+00:00 EmrJobFlowSensor 2021-04-10T14:12:20.804524+00:00 2021-04-10T14:21:23.375986+00:00 0:09:02.571462 15675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:12:18.451533+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T13:00:00+00:00 EmrJobFlowSensor 2021-04-10T14:12:14.672559+00:00 2021-04-10T14:22:17.426650+00:00 0:10:02.754091 15674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:12:12.429866+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:11:54.956509+00:00 2021-04-10T14:11:56.657582+00:00 0:00:01.701073 15673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T14:11:52.479110+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:11:50.712144+00:00 2021-04-10T14:11:52.412562+00:00 0:00:01.700418 15672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T14:11:48.285798+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T13:00:00+00:00 PythonOperator 2021-04-10T14:11:32.995689+00:00 2021-04-10T14:11:36.164323+00:00 0:00:03.168634 15671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:11:30.269909+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T13:00:00+00:00 PythonOperator 2021-04-10T14:11:28.746150+00:00 2021-04-10T14:11:31.608794+00:00 0:00:02.862644 15670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:11:26.206604+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T13:00:00+00:00 TriggerDagRunOperator 2021-04-10T14:11:16.813621+00:00 2021-04-10T14:11:17.207227+00:00 0:00:00.393606 15669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:11:14.195419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T13:00:00+00:00 TriggerDagRunOperator 2021-04-10T14:11:16.481383+00:00 2021-04-10T14:11:17.005036+00:00 0:00:00.523653 15668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:11:14.195384+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T13:05:00+00:00 EmrJobFlowSensor 2021-04-10T14:06:13.789822+00:00 2021-04-10T14:15:16.354352+00:00 0:09:02.564530 15667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:06:11.602733+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:05:47.995970+00:00 2021-04-10T14:05:49.780397+00:00 0:00:01.784427 15666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T14:05:45.655297+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T13:05:00+00:00 PythonOperator 2021-04-10T14:05:25.974225+00:00 2021-04-10T14:05:28.660883+00:00 0:00:02.686658 15665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:05:23.641676+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T13:00:00+00:00 EmrJobFlowSensor 2021-04-10T14:00:55.232116+00:00 2021-04-10T14:10:57.969957+00:00 0:10:02.737841 15663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:00:52.827363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:00:33.210760+00:00 2021-04-10T14:00:35.424645+00:00 0:00:02.213885 15662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T14:00:30.810052+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T13:00:00+00:00 PythonOperator 2021-04-10T14:00:10.957620+00:00 2021-04-10T14:00:13.903831+00:00 0:00:02.946211 15661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T14:00:08.789265+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T12:00:00+00:00 EmrJobFlowSensor 2021-04-10T13:11:52.512739+00:00 2021-04-10T13:20:55.221010+00:00 0:09:02.708271 15660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:11:50.140173+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T12:00:00+00:00 EmrJobFlowSensor 2021-04-10T13:11:52.434557+00:00 2021-04-10T13:21:55.185871+00:00 0:10:02.751314 15659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:11:50.140209+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T13:11:30.749541+00:00 2021-04-10T13:11:32.518761+00:00 0:00:01.769220 15658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T13:11:28.140739+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T13:11:30.585994+00:00 2021-04-10T13:11:32.523340+00:00 0:00:01.937346 15657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T13:11:28.140785+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T12:00:00+00:00 PythonOperator 2021-04-10T13:11:09.001262+00:00 2021-04-10T13:11:11.797223+00:00 0:00:02.795961 15656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T13:11:06.167707+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T12:00:00+00:00 PythonOperator 2021-04-10T13:11:08.598089+00:00 2021-04-10T13:11:11.604169+00:00 0:00:03.006080 15655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T13:11:06.167655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T12:00:00+00:00 TriggerDagRunOperator 2021-04-10T13:10:46.692824+00:00 2021-04-10T13:10:47.193515+00:00 0:00:00.500691 15654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:10:44.163629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T12:00:00+00:00 TriggerDagRunOperator 2021-04-10T13:10:46.536448+00:00 2021-04-10T13:10:46.963731+00:00 0:00:00.427283 15653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:10:44.163594+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T12:05:00+00:00 EmrJobFlowSensor 2021-04-10T13:05:51.678974+00:00 2021-04-10T13:14:54.333131+00:00 0:09:02.654157 15652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:05:49.527181+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T13:05:29.850093+00:00 2021-04-10T13:05:31.584958+00:00 0:00:01.734865 15651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T13:05:27.506328+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T12:05:00+00:00 PythonOperator 2021-04-10T13:05:07.586956+00:00 2021-04-10T13:05:10.274959+00:00 0:00:02.688003 15650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T13:05:05.493851+00:00 2 default_pool