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 create_emr_steps 2021-05-12T03:00:00+00:00 PythonOperator 2021-05-12T04:00:08.898891+00:00 2021-05-12T04:00:12.026139+00:00 0:00:03.127248 27142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T04:00:06.417313+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T02:00:00+00:00 EmrJobFlowSensor 2021-05-12T03:23:23.021390+00:00 2021-05-12T03:32:25.733184+00:00 0:09:02.711794 27140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T03:23:20.251614+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T02:00:00+00:00 EmrJobFlowSensor 2021-05-12T03:23:20.658827+00:00 2021-05-12T03:32:23.803027+00:00 0:09:03.144200 27139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T03:23:18.360909+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T03:23:00.728807+00:00 2021-05-12T03:23:02.542120+00:00 0:00:01.813313 27138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T03:22:58.253183+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T03:23:00.531769+00:00 2021-05-12T03:23:02.286748+00:00 0:00:01.754979 27137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T03:22:58.253220+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T02:00:00+00:00 PythonOperator 2021-05-12T03:22:38.665537+00:00 2021-05-12T03:22:41.938317+00:00 0:00:03.272780 27136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T03:22:36.207127+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T02:00:00+00:00 PythonOperator 2021-05-12T03:22:38.433308+00:00 2021-05-12T03:22:41.655215+00:00 0:00:03.221907 27135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T03:22:36.207083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T02:00:00+00:00 TriggerDagRunOperator 2021-05-12T03:22:28.749524+00:00 2021-05-12T03:22:29.267244+00:00 0:00:00.517720 27134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T03:22:26.272784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T02:00:00+00:00 TriggerDagRunOperator 2021-05-12T03:22:28.558763+00:00 2021-05-12T03:22:28.984963+00:00 0:00:00.426200 27133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T03:22:26.272748+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T02:05:00+00:00 EmrJobFlowSensor 2021-05-12T03:06:02.293519+00:00 2021-05-12T03:15:05.193743+00:00 0:09:02.900224 27132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T03:05:59.990839+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T03:05:34.277640+00:00 2021-05-12T03:05:35.907508+00:00 0:00:01.629868 27131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T03:05:31.918174+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T02:05:00+00:00 PythonOperator 2021-05-12T03:05:10.138608+00:00 2021-05-12T03:05:13.284517+00:00 0:00:03.145909 27130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T03:05:07.960029+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T02:00:00+00:00 EmrJobFlowSensor 2021-05-12T03:01:05.566639+00:00 2021-05-12T03:22:09.977276+00:00 0:21:04.410637 27129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T03:01:03.365468+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T03:00:35.628796+00:00 2021-05-12T03:00:37.440147+00:00 0:00:01.811351 27128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T03:00:33.270756+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T02:00:00+00:00 PythonOperator 2021-05-12T03:00:07.825124+00:00 2021-05-12T03:00:10.906986+00:00 0:00:03.081862 27127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T03:00:05.284402+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T01:00:00+00:00 EmrJobFlowSensor 2021-05-12T02:10:06.416499+00:00 2021-05-12T02:19:08.986562+00:00 0:09:02.570063 27125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T02:10:03.790349+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T01:00:00+00:00 EmrJobFlowSensor 2021-05-12T02:10:03.908454+00:00 2021-05-12T02:19:07.005289+00:00 0:09:03.096835 27124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T02:10:01.787001+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T02:09:43.996786+00:00 2021-05-12T02:09:45.704735+00:00 0:00:01.707949 27123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T02:09:41.748887+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T02:09:39.849971+00:00 2021-05-12T02:09:41.535281+00:00 0:00:01.685310 27122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T02:09:37.690906+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T01:00:00+00:00 PythonOperator 2021-05-12T02:09:21.802171+00:00 2021-05-12T02:09:25.112962+00:00 0:00:03.310791 27121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T02:09:19.598687+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T01:00:00+00:00 PythonOperator 2021-05-12T02:09:19.792859+00:00 2021-05-12T02:09:22.895369+00:00 0:00:03.102510 27120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T02:09:17.604057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T01:00:00+00:00 TriggerDagRunOperator 2021-05-12T02:09:10.291363+00:00 2021-05-12T02:09:10.791285+00:00 0:00:00.499922 27119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T02:09:07.666715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T01:00:00+00:00 TriggerDagRunOperator 2021-05-12T02:09:09.962354+00:00 2021-05-12T02:09:10.387255+00:00 0:00:00.424901 27118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T02:09:07.666656+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T01:05:00+00:00 EmrJobFlowSensor 2021-05-12T02:05:55.119240+00:00 2021-05-12T02:13:57.587288+00:00 0:08:02.468048 27117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T02:05:52.994111+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T02:05:33.274597+00:00 2021-05-12T02:05:35.040763+00:00 0:00:01.766166 27116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T02:05:30.933895+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T01:05:00+00:00 PythonOperator 2021-05-12T02:05:10.959314+00:00 2021-05-12T02:05:14.334297+00:00 0:00:03.374983 27115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T02:05:08.790846+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T01:00:00+00:00 EmrJobFlowSensor 2021-05-12T02:00:50.551103+00:00 2021-05-12T02:08:53.230600+00:00 0:08:02.679497 27114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T02:00:48.167734+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T02:00:28.327350+00:00 2021-05-12T02:00:30.071163+00:00 0:00:01.743813 27113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T02:00:26.044392+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T01:00:00+00:00 PythonOperator 2021-05-12T02:00:06.879065+00:00 2021-05-12T02:00:09.964986+00:00 0:00:03.085921 27112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T02:00:04.085646+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T00:00:00+00:00 EmrJobFlowSensor 2021-05-12T01:11:08.933717+00:00 2021-05-12T01:19:11.595440+00:00 0:08:02.661723 27110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T01:11:06.414621+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T00:00:00+00:00 EmrJobFlowSensor 2021-05-12T01:11:04.891313+00:00 2021-05-12T01:21:07.977022+00:00 0:10:03.085709 27109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T01:11:02.414503+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T01:10:46.648654+00:00 2021-05-12T01:10:48.467421+00:00 0:00:01.818767 27108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T01:10:44.399047+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T01:10:42.635088+00:00 2021-05-12T01:10:44.445744+00:00 0:00:01.810656 27107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T01:10:40.341263+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T00:00:00+00:00 PythonOperator 2021-05-12T01:10:24.881142+00:00 2021-05-12T01:10:27.942871+00:00 0:00:03.061729 27106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T01:10:22.329918+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T00:00:00+00:00 PythonOperator 2021-05-12T01:10:20.863445+00:00 2021-05-12T01:10:24.780335+00:00 0:00:03.916890 27105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T01:10:18.440910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T00:00:00+00:00 TriggerDagRunOperator 2021-05-12T01:10:16.754444+00:00 2021-05-12T01:10:17.298727+00:00 0:00:00.544283 27104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T01:10:14.344493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T00:00:00+00:00 TriggerDagRunOperator 2021-05-12T01:10:16.549993+00:00 2021-05-12T01:10:16.974751+00:00 0:00:00.424758 27103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T01:10:14.344540+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T00:05:00+00:00 EmrJobFlowSensor 2021-05-12T01:06:06.340803+00:00 2021-05-12T01:15:08.894236+00:00 0:09:02.553433 27102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T01:06:03.803198+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T01:05:45.970730+00:00 2021-05-12T01:05:47.618085+00:00 0:00:01.647355 27101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T01:05:43.738754+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T00:05:00+00:00 PythonOperator 2021-05-12T01:05:23.787873+00:00 2021-05-12T01:05:26.897734+00:00 0:00:03.109861 27100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T01:05:21.666743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T00:00:00+00:00 EmrJobFlowSensor 2021-05-12T01:00:59.606406+00:00 2021-05-12T01:10:02.547239+00:00 0:09:02.940833 27099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T01:00:57.098278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T01:00:37.202446+00:00 2021-05-12T01:00:38.948784+00:00 0:00:01.746338 27098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T01:00:35.064084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T00:00:00+00:00 PythonOperator 2021-05-12T01:00:17.511219+00:00 2021-05-12T01:00:20.603050+00:00 0:00:03.091831 27097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T01:00:15.056253+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T23:00:00+00:00 EmrJobFlowSensor 2021-05-12T00:10:10.072049+00:00 2021-05-12T00:19:12.738185+00:00 0:09:02.666136 27095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T00:10:07.922702+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T23:00:00+00:00 EmrJobFlowSensor 2021-05-12T00:10:04.257551+00:00 2021-05-12T00:19:07.062285+00:00 0:09:02.804734 27094 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T00:10:01.925580+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T00:09:50.684309+00:00 2021-05-12T00:09:52.487230+00:00 0:00:01.802921 27093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T00:09:47.907773+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T00:09:42.103949+00:00 2021-05-12T00:09:43.967913+00:00 0:00:01.863964 27092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T00:09:39.902732+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T23:00:00+00:00 PythonOperator 2021-05-12T00:09:28.209703+00:00 2021-05-12T00:09:31.281432+00:00 0:00:03.071729 27091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T00:09:25.889322+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T23:00:00+00:00 PythonOperator 2021-05-12T00:09:20.382485+00:00 2021-05-12T00:09:24.016633+00:00 0:00:03.634148 27090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T00:09:17.944751+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T23:00:00+00:00 TriggerDagRunOperator 2021-05-12T00:09:16.429906+00:00 2021-05-12T00:09:16.940716+00:00 0:00:00.510810 27089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T00:09:13.857986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T23:00:00+00:00 TriggerDagRunOperator 2021-05-12T00:09:16.266559+00:00 2021-05-12T00:09:16.674045+00:00 0:00:00.407486 27088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T00:09:13.857938+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T23:05:00+00:00 EmrJobFlowSensor 2021-05-12T00:05:51.576783+00:00 2021-05-12T00:13:54.165871+00:00 0:08:02.589088 27087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T00:05:49.404599+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T00:05:29.871032+00:00 2021-05-12T00:05:31.599085+00:00 0:00:01.728053 27086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T00:05:27.456057+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T23:05:00+00:00 PythonOperator 2021-05-12T00:05:07.828884+00:00 2021-05-12T00:05:10.894594+00:00 0:00:03.065710 27085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T00:05:05.455268+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T23:00:00+00:00 EmrJobFlowSensor 2021-05-12T00:01:03.457747+00:00 2021-05-12T00:09:06.108032+00:00 0:08:02.650285 27084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T00:01:00.883725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T00:00:41.037641+00:00 2021-05-12T00:00:42.842533+00:00 0:00:01.804892 27083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T00:00:38.838776+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T23:00:00+00:00 PythonOperator 2021-05-12T00:00:21.848867+00:00 2021-05-12T00:00:24.950385+00:00 0:00:03.101518 27082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T00:00:18.643613+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T22:00:00+00:00 EmrJobFlowSensor 2021-05-11T23:12:16.500733+00:00 2021-05-11T23:22:19.536014+00:00 0:10:03.035281 27080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T23:12:14.144767+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T22:00:00+00:00 EmrJobFlowSensor 2021-05-11T23:12:10.147684+00:00 2021-05-11T23:21:12.818434+00:00 0:09:02.670750 27079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T23:12:08.017150+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T23:11:56.149779+00:00 2021-05-11T23:11:57.942501+00:00 0:00:01.792722 27078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T23:11:54.007891+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T23:11:48.432730+00:00 2021-05-11T23:11:50.215944+00:00 0:00:01.783214 27077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T23:11:46.002832+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T22:00:00+00:00 PythonOperator 2021-05-11T23:11:34.491212+00:00 2021-05-11T23:11:37.803071+00:00 0:00:03.311859 27076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T23:11:31.987672+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T22:00:00+00:00 PythonOperator 2021-05-11T23:11:26.495971+00:00 2021-05-11T23:11:29.670508+00:00 0:00:03.174537 27075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T23:11:24.084828+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T22:00:00+00:00 TriggerDagRunOperator 2021-05-11T23:11:16.523930+00:00 2021-05-11T23:11:17.086631+00:00 0:00:00.562701 27074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T23:11:13.949881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T22:00:00+00:00 TriggerDagRunOperator 2021-05-11T23:11:16.286498+00:00 2021-05-11T23:11:16.695920+00:00 0:00:00.409422 27073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T23:11:13.949937+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T22:05:00+00:00 EmrJobFlowSensor 2021-05-11T23:06:05.537671+00:00 2021-05-11T23:15:08.256767+00:00 0:09:02.719096 27072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T23:06:03.138847+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T23:05:43.245678+00:00 2021-05-11T23:05:44.836465+00:00 0:00:01.590787 27071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T23:05:41.121256+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T22:05:00+00:00 PythonOperator 2021-05-11T23:05:23.273035+00:00 2021-05-11T23:05:26.410933+00:00 0:00:03.137898 27070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T23:05:21.102727+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-10T23:00:00+00:00 EmrJobFlowSensor 2021-05-11T23:00:58.804139+00:00 2021-05-11T23:09:01.274158+00:00 0:08:02.470019 27069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T23:00:56.414539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T22:00:00+00:00 EmrJobFlowSensor 2021-05-11T23:00:54.718818+00:00 2021-05-11T23:10:57.461648+00:00 0:10:02.742830 27068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T23:00:52.473736+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T23:00:36.674101+00:00 2021-05-11T23:00:38.448146+00:00 0:00:01.774045 27067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T23:00:34.397107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T23:00:34.748509+00:00 2021-05-11T23:00:36.519433+00:00 0:00:01.770924 27066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T23:00:32.449918+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-10T23:00:00+00:00 PythonOperator 2021-05-11T23:00:10.620244+00:00 2021-05-11T23:00:13.969276+00:00 0:00:03.349032 27065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T23:00:08.325631+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T22:00:00+00:00 PythonOperator 2021-05-11T23:00:04.621154+00:00 2021-05-11T23:00:07.686500+00:00 0:00:03.065346 27064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T23:00:02.318272+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T21:00:00+00:00 EmrJobFlowSensor 2021-05-11T22:23:28.238036+00:00 2021-05-11T22:32:30.903008+00:00 0:09:02.664972 27063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T22:23:25.840801+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T21:00:00+00:00 EmrJobFlowSensor 2021-05-11T22:23:24.132646+00:00 2021-05-11T22:31:26.699809+00:00 0:08:02.567163 27062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T22:23:21.870207+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T22:22:57.892509+00:00 2021-05-11T22:22:59.613962+00:00 0:00:01.721453 27061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T22:22:55.738481+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T22:22:51.853929+00:00 2021-05-11T22:22:53.521581+00:00 0:00:01.667652 27060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T22:22:49.728776+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T21:00:00+00:00 PythonOperator 2021-05-11T22:22:36.235212+00:00 2021-05-11T22:22:39.518245+00:00 0:00:03.283033 27059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T22:22:33.724223+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T21:00:00+00:00 PythonOperator 2021-05-11T22:22:27.873651+00:00 2021-05-11T22:22:30.986035+00:00 0:00:03.112384 27058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T22:22:25.707717+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T21:00:00+00:00 TriggerDagRunOperator 2021-05-11T22:22:18.475424+00:00 2021-05-11T22:22:18.989807+00:00 0:00:00.514383 27057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T22:22:15.506034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T21:00:00+00:00 TriggerDagRunOperator 2021-05-11T22:22:18.190730+00:00 2021-05-11T22:22:18.643882+00:00 0:00:00.453152 27056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T22:22:15.506074+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T21:05:00+00:00 EmrJobFlowSensor 2021-05-11T22:05:53.951731+00:00 2021-05-11T22:13:56.404389+00:00 0:08:02.452658 27054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T22:05:51.786142+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T22:05:33.857970+00:00 2021-05-11T22:05:35.550666+00:00 0:00:01.692696 27053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T22:05:31.765540+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T21:05:00+00:00 PythonOperator 2021-05-11T22:05:11.974344+00:00 2021-05-11T22:05:15.008528+00:00 0:00:03.034184 27052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T22:05:09.751321+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T21:00:00+00:00 EmrJobFlowSensor 2021-05-11T22:01:05.200689+00:00 2021-05-11T22:22:09.652613+00:00 0:21:04.451924 27051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T22:01:02.996167+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T22:00:41.450419+00:00 2021-05-11T22:00:43.259599+00:00 0:00:01.809180 27050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T22:00:38.978883+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T21:00:00+00:00 PythonOperator 2021-05-11T22:00:21.166659+00:00 2021-05-11T22:00:24.272183+00:00 0:00:03.105524 27049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T22:00:18.899063+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T20:00:00+00:00 EmrJobFlowSensor 2021-05-11T21:11:25.577517+00:00 2021-05-11T21:20:28.195575+00:00 0:09:02.618058 27047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T21:11:23.432629+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T20:00:00+00:00 EmrJobFlowSensor 2021-05-11T21:11:09.876455+00:00 2021-05-11T21:21:12.800379+00:00 0:10:02.923924 27046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T21:11:07.428780+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T21:10:59.738801+00:00 2021-05-11T21:11:01.416259+00:00 0:00:01.677458 27045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T21:10:57.457508+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T21:10:43.719850+00:00 2021-05-11T21:10:45.684151+00:00 0:00:01.964301 27044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T21:10:41.394582+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T20:00:00+00:00 PythonOperator 2021-05-11T21:10:37.793568+00:00 2021-05-11T21:10:40.918420+00:00 0:00:03.124852 27043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T21:10:35.456877+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T20:00:00+00:00 PythonOperator 2021-05-11T21:10:21.856989+00:00 2021-05-11T21:10:25.192165+00:00 0:00:03.335176 27042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T21:10:19.297106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T20:00:00+00:00 TriggerDagRunOperator 2021-05-11T21:10:13.687541+00:00 2021-05-11T21:10:14.212091+00:00 0:00:00.524550 27041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T21:10:11.293237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T20:00:00+00:00 TriggerDagRunOperator 2021-05-11T21:10:13.478412+00:00 2021-05-11T21:10:13.889380+00:00 0:00:00.410968 27040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T21:10:11.293280+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T20:05:00+00:00 EmrJobFlowSensor 2021-05-11T21:06:04.871741+00:00 2021-05-11T21:15:07.570093+00:00 0:09:02.698352 27039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T21:06:02.589935+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T21:05:40.861377+00:00 2021-05-11T21:05:42.597443+00:00 0:00:01.736066 27038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T21:05:38.575716+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T20:05:00+00:00 PythonOperator 2021-05-11T21:05:08.774572+00:00 2021-05-11T21:05:11.821476+00:00 0:00:03.046904 27037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T21:05:06.477508+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T20:00:00+00:00 EmrJobFlowSensor 2021-05-11T21:00:54.113607+00:00 2021-05-11T21:09:56.748392+00:00 0:09:02.634785 27036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T21:00:52.010638+00:00 2 default_pool