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 check_cluster_status 2021-05-23T14:05:00+00:00 EmrJobFlowSensor 2021-05-23T15:05:56.353135+00:00 2021-05-23T15:13:58.920680+00:00 0:08:02.567545 31309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T15:05:54.054305+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T15:05:34.490137+00:00 2021-05-23T15:05:36.191361+00:00 0:00:01.701224 31308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T15:05:32.034696+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T14:05:00+00:00 PythonOperator 2021-05-23T15:05:12.193316+00:00 2021-05-23T15:05:15.382720+00:00 0:00:03.189404 31307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T15:05:10.033345+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T14:00:00+00:00 EmrJobFlowSensor 2021-05-23T15:01:04.035469+00:00 2021-05-23T15:10:06.600991+00:00 0:09:02.565522 31306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T15:01:01.748225+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T15:00:41.841670+00:00 2021-05-23T15:00:43.710980+00:00 0:00:01.869310 31305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T15:00:39.643450+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T14:00:00+00:00 PythonOperator 2021-05-23T15:00:21.946834+00:00 2021-05-23T15:00:25.150008+00:00 0:00:03.203174 31304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T15:00:19.628455+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T13:00:00+00:00 EmrJobFlowSensor 2021-05-23T14:10:35.319144+00:00 2021-05-23T14:19:38.010907+00:00 0:09:02.691763 31302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T14:10:33.087942+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T13:00:00+00:00 EmrJobFlowSensor 2021-05-23T14:10:33.355483+00:00 2021-05-23T14:19:36.148856+00:00 0:09:02.793373 31301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T14:10:31.085435+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T14:10:13.181031+00:00 2021-05-23T14:10:14.974852+00:00 0:00:01.793821 31300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T14:10:10.950824+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T14:09:59.097738+00:00 2021-05-23T14:10:01.024423+00:00 0:00:01.926685 31299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T14:09:56.941829+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T13:00:00+00:00 PythonOperator 2021-05-23T14:09:47.134554+00:00 2021-05-23T14:09:50.231788+00:00 0:00:03.097234 31298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T14:09:44.927685+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T13:00:00+00:00 PythonOperator 2021-05-23T14:09:33.153982+00:00 2021-05-23T14:09:36.539619+00:00 0:00:03.385637 31297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T14:09:30.918427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T13:00:00+00:00 TriggerDagRunOperator 2021-05-23T14:09:27.496120+00:00 2021-05-23T14:09:28.040147+00:00 0:00:00.544027 31296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T14:09:24.979712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T13:00:00+00:00 TriggerDagRunOperator 2021-05-23T14:09:27.390247+00:00 2021-05-23T14:09:27.781485+00:00 0:00:00.391238 31295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T14:09:24.979666+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T13:05:00+00:00 EmrJobFlowSensor 2021-05-23T14:06:12.864643+00:00 2021-05-23T14:15:15.461469+00:00 0:09:02.596826 31294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T14:06:10.685000+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T14:05:52.803111+00:00 2021-05-23T14:05:54.414183+00:00 0:00:01.611072 31293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T14:05:50.627184+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T13:05:00+00:00 PythonOperator 2021-05-23T14:05:30.839316+00:00 2021-05-23T14:05:34.141922+00:00 0:00:03.302606 31292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T14:05:28.666084+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T13:00:00+00:00 EmrJobFlowSensor 2021-05-23T14:01:02.525247+00:00 2021-05-23T14:09:05.108409+00:00 0:08:02.583162 31291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T14:01:00.278765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T14:00:40.564588+00:00 2021-05-23T14:00:42.410803+00:00 0:00:01.846215 31290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T14:00:38.170572+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T13:00:00+00:00 PythonOperator 2021-05-23T14:00:20.376488+00:00 2021-05-23T14:00:23.566140+00:00 0:00:03.189652 31289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T14:00:18.101260+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T12:00:00+00:00 EmrJobFlowSensor 2021-05-23T13:12:32.739355+00:00 2021-05-23T13:21:35.267576+00:00 0:09:02.528221 31287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T13:12:30.588546+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T12:00:00+00:00 EmrJobFlowSensor 2021-05-23T13:12:28.920976+00:00 2021-05-23T13:22:31.674916+00:00 0:10:02.753940 31286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T13:12:26.591426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T13:12:10.851373+00:00 2021-05-23T13:12:12.556815+00:00 0:00:01.705442 31285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T13:12:08.519033+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T13:12:04.682511+00:00 2021-05-23T13:12:06.368498+00:00 0:00:01.685987 31284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T13:12:02.510572+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T12:00:00+00:00 PythonOperator 2021-05-23T13:11:41.033343+00:00 2021-05-23T13:11:44.383088+00:00 0:00:03.349745 31283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T13:11:38.562151+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T12:00:00+00:00 PythonOperator 2021-05-23T13:11:40.906968+00:00 2021-05-23T13:11:44.180181+00:00 0:00:03.273213 31282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T13:11:38.562102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T12:00:00+00:00 TriggerDagRunOperator 2021-05-23T13:11:26.827551+00:00 2021-05-23T13:11:27.394901+00:00 0:00:00.567350 31281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T13:11:24.460920+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T12:00:00+00:00 TriggerDagRunOperator 2021-05-23T13:11:26.735109+00:00 2021-05-23T13:11:27.136844+00:00 0:00:00.401735 31280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T13:11:24.460888+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T12:05:00+00:00 EmrJobFlowSensor 2021-05-23T13:05:50.082082+00:00 2021-05-23T13:14:52.670303+00:00 0:09:02.588221 31279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T13:05:47.922412+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T13:05:28.052692+00:00 2021-05-23T13:05:29.681911+00:00 0:00:01.629219 31278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T13:05:25.905244+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T12:05:00+00:00 PythonOperator 2021-05-23T13:05:06.309921+00:00 2021-05-23T13:05:09.378660+00:00 0:00:03.068739 31277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T13:05:03.955503+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T12:00:00+00:00 EmrJobFlowSensor 2021-05-23T13:01:05.868788+00:00 2021-05-23T13:11:08.933902+00:00 0:10:03.065114 31276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T13:01:03.444400+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T13:00:44.109954+00:00 2021-05-23T13:00:45.883619+00:00 0:00:01.773665 31275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T13:00:41.473178+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T12:00:00+00:00 PythonOperator 2021-05-23T13:00:11.721507+00:00 2021-05-23T13:00:14.876873+00:00 0:00:03.155366 31274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T13:00:09.389224+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T11:00:00+00:00 EmrJobFlowSensor 2021-05-23T12:12:00.342877+00:00 2021-05-23T12:22:03.244790+00:00 0:10:02.901913 31272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T12:11:57.850589+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T11:00:00+00:00 EmrJobFlowSensor 2021-05-23T12:11:50.152601+00:00 2021-05-23T12:21:52.983276+00:00 0:10:02.830675 31271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T12:11:47.880073+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T12:11:37.920865+00:00 2021-05-23T12:11:39.606693+00:00 0:00:01.685828 31270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T12:11:35.791824+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T12:11:30.649427+00:00 2021-05-23T12:11:32.470157+00:00 0:00:01.820730 31269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T12:11:27.944479+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T11:00:00+00:00 PythonOperator 2021-05-23T12:11:17.916197+00:00 2021-05-23T12:11:21.097109+00:00 0:00:03.180912 31268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T12:11:15.763921+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T11:00:00+00:00 PythonOperator 2021-05-23T12:11:08.429864+00:00 2021-05-23T12:11:11.815266+00:00 0:00:03.385402 31267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T12:11:05.756528+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T11:00:00+00:00 TriggerDagRunOperator 2021-05-23T12:10:58.452397+00:00 2021-05-23T12:10:58.999640+00:00 0:00:00.547243 31266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T12:10:55.751619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T11:00:00+00:00 TriggerDagRunOperator 2021-05-23T12:10:58.281333+00:00 2021-05-23T12:10:58.680834+00:00 0:00:00.399501 31265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T12:10:55.751662+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T11:05:00+00:00 EmrJobFlowSensor 2021-05-23T12:05:47.381189+00:00 2021-05-23T12:14:49.852383+00:00 0:09:02.471194 31264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T12:05:45.140295+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T12:05:27.473492+00:00 2021-05-23T12:05:29.190432+00:00 0:00:01.716940 31263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T12:05:25.065630+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T11:05:00+00:00 PythonOperator 2021-05-23T12:05:05.351958+00:00 2021-05-23T12:05:08.559019+00:00 0:00:03.207061 31262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T12:05:03.043820+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T11:00:00+00:00 EmrJobFlowSensor 2021-05-23T12:00:48.918316+00:00 2021-05-23T12:10:51.765649+00:00 0:10:02.847333 31261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T12:00:46.440833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T12:00:26.929225+00:00 2021-05-23T12:00:28.712651+00:00 0:00:01.783426 31260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T12:00:24.451293+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T11:00:00+00:00 PythonOperator 2021-05-23T12:00:07.094328+00:00 2021-05-23T12:00:10.221366+00:00 0:00:03.127038 31259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T12:00:04.355971+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T10:00:00+00:00 EmrJobFlowSensor 2021-05-23T11:12:05.296553+00:00 2021-05-23T11:21:07.882915+00:00 0:09:02.586362 31257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T11:12:02.983862+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T10:00:00+00:00 EmrJobFlowSensor 2021-05-23T11:12:03.340814+00:00 2021-05-23T11:21:06.073928+00:00 0:09:02.733114 31256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T11:12:00.985230+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T11:11:43.181897+00:00 2021-05-23T11:11:44.988585+00:00 0:00:01.806688 31255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T11:11:40.913506+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T11:11:41.102452+00:00 2021-05-23T11:11:42.811193+00:00 0:00:01.708741 31254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T11:11:38.915642+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T10:00:00+00:00 PythonOperator 2021-05-23T11:11:21.230156+00:00 2021-05-23T11:11:24.555749+00:00 0:00:03.325593 31253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T11:11:18.901876+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T10:00:00+00:00 PythonOperator 2021-05-23T11:11:19.316717+00:00 2021-05-23T11:11:22.858444+00:00 0:00:03.541727 31252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T11:11:16.905933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T10:00:00+00:00 TriggerDagRunOperator 2021-05-23T11:11:15.375002+00:00 2021-05-23T11:11:15.942931+00:00 0:00:00.567929 31251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T11:11:12.900208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T10:00:00+00:00 TriggerDagRunOperator 2021-05-23T11:11:15.316953+00:00 2021-05-23T11:11:15.699655+00:00 0:00:00.382702 31250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T11:11:12.900158+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T10:05:00+00:00 EmrJobFlowSensor 2021-05-23T11:05:56.858163+00:00 2021-05-23T11:14:59.376916+00:00 0:09:02.518753 31249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T11:05:54.579956+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T11:05:36.625691+00:00 2021-05-23T11:05:38.264395+00:00 0:00:01.638704 31248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T11:05:34.513266+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T10:05:00+00:00 PythonOperator 2021-05-23T11:05:14.817163+00:00 2021-05-23T11:05:18.038424+00:00 0:00:03.221261 31247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T11:05:12.496177+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T10:00:00+00:00 EmrJobFlowSensor 2021-05-23T11:01:06.335091+00:00 2021-05-23T11:11:09.343612+00:00 0:10:03.008521 31246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T11:01:04.088116+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T11:00:44.558948+00:00 2021-05-23T11:00:46.339645+00:00 0:00:01.780697 31245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T11:00:42.081204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T10:00:00+00:00 PythonOperator 2021-05-23T11:00:10.337150+00:00 2021-05-23T11:00:13.451771+00:00 0:00:03.114621 31244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T11:00:07.990115+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T09:00:00+00:00 EmrJobFlowSensor 2021-05-23T10:11:07.081838+00:00 2021-05-23T10:19:09.562279+00:00 0:08:02.480441 31242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T10:11:04.881844+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T09:00:00+00:00 EmrJobFlowSensor 2021-05-23T10:10:55.126897+00:00 2021-05-23T10:20:57.901364+00:00 0:10:02.774467 31241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T10:10:52.816509+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T10:10:46.890420+00:00 2021-05-23T10:10:48.554813+00:00 0:00:01.664393 31240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T10:10:44.809203+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T10:10:33.684700+00:00 2021-05-23T10:10:35.370860+00:00 0:00:01.686160 31239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T10:10:30.794536+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T09:00:00+00:00 PythonOperator 2021-05-23T10:10:25.187677+00:00 2021-05-23T10:10:28.348952+00:00 0:00:03.161275 31238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T10:10:22.866830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T09:00:00+00:00 PythonOperator 2021-05-23T10:10:13.087156+00:00 2021-05-23T10:10:16.470746+00:00 0:00:03.383590 31237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T10:10:10.751222+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T09:00:00+00:00 TriggerDagRunOperator 2021-05-23T10:10:07.027871+00:00 2021-05-23T10:10:07.545049+00:00 0:00:00.517178 31236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T10:10:04.763230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T09:00:00+00:00 TriggerDagRunOperator 2021-05-23T10:10:06.939360+00:00 2021-05-23T10:10:07.349512+00:00 0:00:00.410152 31235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T10:10:04.763278+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T09:05:00+00:00 EmrJobFlowSensor 2021-05-23T10:06:02.564513+00:00 2021-05-23T10:15:05.290713+00:00 0:09:02.726200 31234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T10:06:00.269120+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T10:05:40.486634+00:00 2021-05-23T10:05:42.155400+00:00 0:00:01.668766 31233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T10:05:38.266506+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T09:05:00+00:00 PythonOperator 2021-05-23T10:05:18.297780+00:00 2021-05-23T10:05:21.464948+00:00 0:00:03.167168 31232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T10:05:16.145766+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T09:00:00+00:00 EmrJobFlowSensor 2021-05-23T10:00:51.907521+00:00 2021-05-23T10:09:54.626091+00:00 0:09:02.718570 31231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T10:00:49.751393+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T10:00:31.992302+00:00 2021-05-23T10:00:33.812681+00:00 0:00:01.820379 31230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T10:00:29.739080+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T09:00:00+00:00 PythonOperator 2021-05-23T10:00:06.249110+00:00 2021-05-23T10:00:09.412715+00:00 0:00:03.163605 31229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T10:00:03.714511+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T08:00:00+00:00 EmrJobFlowSensor 2021-05-23T09:11:24.714189+00:00 2021-05-23T09:21:27.643997+00:00 0:10:02.929808 31227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T09:11:22.431060+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T08:00:00+00:00 EmrJobFlowSensor 2021-05-23T09:11:18.920555+00:00 2021-05-23T09:20:21.570981+00:00 0:09:02.650426 31226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T09:11:16.429184+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T09:10:58.824071+00:00 2021-05-23T09:11:00.635139+00:00 0:00:01.811068 31225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T09:10:56.430130+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T09:10:54.612450+00:00 2021-05-23T09:10:56.313057+00:00 0:00:01.700607 31224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T09:10:52.407529+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T08:00:00+00:00 PythonOperator 2021-05-23T09:10:38.713178+00:00 2021-05-23T09:10:42.080621+00:00 0:00:03.367443 31223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T09:10:36.402003+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T08:00:00+00:00 PythonOperator 2021-05-23T09:10:32.527726+00:00 2021-05-23T09:10:35.710469+00:00 0:00:03.182743 31222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T09:10:30.383868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T08:00:00+00:00 TriggerDagRunOperator 2021-05-23T09:10:18.830879+00:00 2021-05-23T09:10:19.356439+00:00 0:00:00.525560 31221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T09:10:16.329094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T08:00:00+00:00 TriggerDagRunOperator 2021-05-23T09:10:18.649049+00:00 2021-05-23T09:10:19.072000+00:00 0:00:00.422951 31220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T09:10:16.329129+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T08:05:00+00:00 EmrJobFlowSensor 2021-05-23T09:06:01.981533+00:00 2021-05-23T09:15:04.540470+00:00 0:09:02.558937 31219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T09:05:59.885735+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T09:05:40.238342+00:00 2021-05-23T09:05:41.975690+00:00 0:00:01.737348 31218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T09:05:37.876294+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-23T08:05:00+00:00 PythonOperator 2021-05-23T09:05:18.071673+00:00 2021-05-23T09:05:21.242785+00:00 0:00:03.171112 31217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T09:05:15.866734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-23T08:00:00+00:00 EmrJobFlowSensor 2021-05-23T09:00:55.820126+00:00 2021-05-23T09:09:58.849887+00:00 0:09:03.029761 31216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T09:00:53.376028+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T09:00:33.483362+00:00 2021-05-23T09:00:35.238138+00:00 0:00:01.754776 31215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-23T09:00:31.318215+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-23T08:00:00+00:00 PythonOperator 2021-05-23T09:00:12.139827+00:00 2021-05-23T09:00:15.366240+00:00 0:00:03.226413 31214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-23T09:00:09.301953+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-23T07:00:00+00:00 EmrJobFlowSensor 2021-05-23T08:12:34.464594+00:00 2021-05-23T08:22:37.213805+00:00 0:10:02.749211 31212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T08:12:31.886004+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-23T07:00:00+00:00 EmrJobFlowSensor 2021-05-23T08:12:32.155046+00:00 2021-05-23T08:21:35.089785+00:00 0:09:02.934739 31211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T08:12:29.887182+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T08:12:12.163776+00:00 2021-05-23T08:12:14.016946+00:00 0:00:01.853170 31210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T08:12:09.847456+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-23T08:12:12.042399+00:00 2021-05-23T08:12:13.889199+00:00 0:00:01.846800 31209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T08:12:09.847490+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-23T07:00:00+00:00 PythonOperator 2021-05-23T08:11:50.212621+00:00 2021-05-23T08:11:53.559867+00:00 0:00:03.347246 31208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T08:11:47.824689+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-23T07:00:00+00:00 PythonOperator 2021-05-23T08:11:45.972507+00:00 2021-05-23T08:11:49.372146+00:00 0:00:03.399639 31207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-23T08:11:43.826563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-23T07:00:00+00:00 TriggerDagRunOperator 2021-05-23T08:11:32.108646+00:00 2021-05-23T08:11:32.705747+00:00 0:00:00.597101 31206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T08:11:29.811879+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-23T07:00:00+00:00 TriggerDagRunOperator 2021-05-23T08:11:32.034340+00:00 2021-05-23T08:11:32.440030+00:00 0:00:00.405690 31205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T08:11:29.811925+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-23T07:05:00+00:00 EmrJobFlowSensor 2021-05-23T08:05:55.622724+00:00 2021-05-23T08:13:58.228261+00:00 0:08:02.605537 31204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-23T08:05:53.460427+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-23T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-23T08:05:35.482245+00:00 2021-05-23T08:05:37.119957+00:00 0:00:01.637712 31203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-23T08:05:33.377629+00:00 2 default_pool