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-history-job_v002 create_emr_steps 2021-04-26T05:00:00+00:00 PythonOperator 2021-04-26T06:10:52.880347+00:00 2021-04-26T06:10:55.965273+00:00 0:00:03.084926 21371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T06:10:49.424410+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T05:00:00+00:00 PythonOperator 2021-04-26T06:10:50.856914+00:00 2021-04-26T06:10:54.452758+00:00 0:00:03.595844 21370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T06:10:47.465471+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T05:00:00+00:00 TriggerDagRunOperator 2021-04-26T06:10:42.068512+00:00 2021-04-26T06:10:42.571706+00:00 0:00:00.503194 21369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T06:10:39.472277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T05:00:00+00:00 TriggerDagRunOperator 2021-04-26T06:10:41.922618+00:00 2021-04-26T06:10:42.349626+00:00 0:00:00.427008 21368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T06:10:39.472326+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T05:05:00+00:00 EmrJobFlowSensor 2021-04-26T06:05:53.173747+00:00 2021-04-26T06:14:55.817426+00:00 0:09:02.643679 21367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T06:05:50.924623+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T06:05:27.066507+00:00 2021-04-26T06:05:28.675591+00:00 0:00:01.609084 21366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T06:05:24.904941+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T05:05:00+00:00 PythonOperator 2021-04-26T06:05:05.329476+00:00 2021-04-26T06:05:08.266867+00:00 0:00:02.937391 21365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T06:05:02.952589+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T05:00:00+00:00 EmrJobFlowSensor 2021-04-26T06:01:14.870922+00:00 2021-04-26T06:10:17.483395+00:00 0:09:02.612473 21364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T06:01:12.385762+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T06:00:48.731981+00:00 2021-04-26T06:00:50.404471+00:00 0:00:01.672490 21363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T06:00:46.336487+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T05:00:00+00:00 PythonOperator 2021-04-26T06:00:20.649530+00:00 2021-04-26T06:00:23.668748+00:00 0:00:03.019218 21362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T06:00:18.309627+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T04:00:00+00:00 EmrJobFlowSensor 2021-04-26T05:11:24.678902+00:00 2021-04-26T05:20:27.242630+00:00 0:09:02.563728 21360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T05:11:22.402917+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T04:00:00+00:00 EmrJobFlowSensor 2021-04-26T05:11:18.849550+00:00 2021-04-26T05:20:21.535776+00:00 0:09:02.686226 21359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T05:11:16.447511+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T05:11:02.700387+00:00 2021-04-26T05:11:04.395363+00:00 0:00:01.694976 21358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T05:11:00.467114+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T05:10:56.791289+00:00 2021-04-26T05:10:58.683215+00:00 0:00:01.891926 21357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T05:10:54.382879+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T04:00:00+00:00 PythonOperator 2021-04-26T05:10:40.499264+00:00 2021-04-26T05:10:43.510909+00:00 0:00:03.011645 21356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T05:10:38.323153+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T04:00:00+00:00 PythonOperator 2021-04-26T05:10:36.684582+00:00 2021-04-26T05:10:39.929540+00:00 0:00:03.244958 21355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T05:10:34.315026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T04:00:00+00:00 TriggerDagRunOperator 2021-04-26T05:10:20.719168+00:00 2021-04-26T05:10:21.247891+00:00 0:00:00.528723 21354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T05:10:18.304689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T04:00:00+00:00 TriggerDagRunOperator 2021-04-26T05:10:20.537693+00:00 2021-04-26T05:10:20.959131+00:00 0:00:00.421438 21353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T05:10:18.304652+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T04:05:00+00:00 EmrJobFlowSensor 2021-04-26T05:05:58.259837+00:00 2021-04-26T05:14:00.795995+00:00 0:08:02.536158 21352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T05:05:55.927523+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T05:05:36.343612+00:00 2021-04-26T05:05:38.096972+00:00 0:00:01.753360 21351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T05:05:33.966028+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T04:05:00+00:00 PythonOperator 2021-04-26T05:05:16.330153+00:00 2021-04-26T05:05:19.278170+00:00 0:00:02.948017 21350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T05:05:13.963835+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T04:00:00+00:00 EmrJobFlowSensor 2021-04-26T05:00:56.127931+00:00 2021-04-26T05:09:58.892156+00:00 0:09:02.764225 21349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T05:00:53.487874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T05:00:33.908199+00:00 2021-04-26T05:00:35.688634+00:00 0:00:01.780435 21348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T05:00:31.424211+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T04:00:00+00:00 PythonOperator 2021-04-26T05:00:12.180664+00:00 2021-04-26T05:00:15.187550+00:00 0:00:03.006886 21347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T05:00:09.465851+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T03:00:00+00:00 EmrJobFlowSensor 2021-04-26T04:10:16.570992+00:00 2021-04-26T04:20:19.476222+00:00 0:10:02.905230 21345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T04:10:13.984644+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T03:00:00+00:00 EmrJobFlowSensor 2021-04-26T04:10:16.402222+00:00 2021-04-26T04:20:19.305171+00:00 0:10:02.902949 21344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T04:10:13.984690+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T04:09:54.322782+00:00 2021-04-26T04:09:56.195020+00:00 0:00:01.872238 21343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T04:09:51.907196+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T04:09:54.275307+00:00 2021-04-26T04:09:55.970905+00:00 0:00:01.695598 21342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T04:09:51.907246+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T03:00:00+00:00 PythonOperator 2021-04-26T04:09:34.452391+00:00 2021-04-26T04:09:37.438925+00:00 0:00:02.986534 21341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T04:09:31.953166+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T03:00:00+00:00 PythonOperator 2021-04-26T04:09:34.359558+00:00 2021-04-26T04:09:37.647469+00:00 0:00:03.287911 21340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T04:09:31.953134+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T03:00:00+00:00 TriggerDagRunOperator 2021-04-26T04:09:10.430945+00:00 2021-04-26T04:09:10.933329+00:00 0:00:00.502384 21339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T04:09:07.814063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T03:00:00+00:00 TriggerDagRunOperator 2021-04-26T04:09:10.274179+00:00 2021-04-26T04:09:10.716044+00:00 0:00:00.441865 21338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T04:09:07.814032+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T03:05:00+00:00 EmrJobFlowSensor 2021-04-26T04:05:53.983735+00:00 2021-04-26T04:13:56.478086+00:00 0:08:02.494351 21337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T04:05:51.577101+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T04:05:31.987260+00:00 2021-04-26T04:05:33.616229+00:00 0:00:01.628969 21336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T04:05:29.646246+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T03:05:00+00:00 PythonOperator 2021-04-26T04:05:09.748291+00:00 2021-04-26T04:05:12.762948+00:00 0:00:03.014657 21335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T04:05:07.484841+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T03:00:00+00:00 EmrJobFlowSensor 2021-04-26T04:01:01.555462+00:00 2021-04-26T04:09:04.169448+00:00 0:08:02.613986 21334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T04:00:59.252076+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T04:00:39.723228+00:00 2021-04-26T04:00:41.408549+00:00 0:00:01.685321 21333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T04:00:37.280281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T03:00:00+00:00 PythonOperator 2021-04-26T04:00:17.513597+00:00 2021-04-26T04:00:20.555846+00:00 0:00:03.042249 21332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T04:00:15.196805+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T02:00:00+00:00 EmrJobFlowSensor 2021-04-26T03:10:35.837779+00:00 2021-04-26T03:20:38.566692+00:00 0:10:02.728913 21330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T03:10:33.352836+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T02:00:00+00:00 EmrJobFlowSensor 2021-04-26T03:10:19.602851+00:00 2021-04-26T03:19:22.417838+00:00 0:09:02.814987 21329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T03:10:17.295618+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T03:10:13.450365+00:00 2021-04-26T03:10:15.230642+00:00 0:00:01.780277 21328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T03:10:11.286495+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T03:09:59.559990+00:00 2021-04-26T03:10:01.221616+00:00 0:00:01.661626 21327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T03:09:57.278017+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T02:00:00+00:00 PythonOperator 2021-04-26T03:09:51.521589+00:00 2021-04-26T03:09:54.976919+00:00 0:00:03.455330 21326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T03:09:49.266387+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T02:00:00+00:00 PythonOperator 2021-04-26T03:09:37.806673+00:00 2021-04-26T03:09:40.760012+00:00 0:00:02.953339 21325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T03:09:35.262470+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T02:00:00+00:00 TriggerDagRunOperator 2021-04-26T03:09:29.822085+00:00 2021-04-26T03:09:30.340705+00:00 0:00:00.518620 21324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T03:09:27.250727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T02:00:00+00:00 TriggerDagRunOperator 2021-04-26T03:09:29.544131+00:00 2021-04-26T03:09:29.966304+00:00 0:00:00.422173 21323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T03:09:27.250776+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T02:05:00+00:00 EmrJobFlowSensor 2021-04-26T03:05:49.097447+00:00 2021-04-26T03:14:51.661621+00:00 0:09:02.564174 21322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T03:05:46.865431+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T03:05:27.087629+00:00 2021-04-26T03:05:28.888791+00:00 0:00:01.801162 21321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T03:05:24.806782+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T02:05:00+00:00 PythonOperator 2021-04-26T03:05:04.920563+00:00 2021-04-26T03:05:07.961352+00:00 0:00:03.040789 21320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T03:05:02.784354+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T02:00:00+00:00 EmrJobFlowSensor 2021-04-26T03:01:02.578817+00:00 2021-04-26T03:09:05.191082+00:00 0:08:02.612265 21319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T03:01:00.394727+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T03:00:42.686210+00:00 2021-04-26T03:00:44.498823+00:00 0:00:01.812613 21318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T03:00:40.451005+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T02:00:00+00:00 PythonOperator 2021-04-26T03:00:20.642305+00:00 2021-04-26T03:00:23.675178+00:00 0:00:03.032873 21317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T03:00:18.304884+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T01:00:00+00:00 EmrJobFlowSensor 2021-04-26T02:10:00.492630+00:00 2021-04-26T02:20:03.451999+00:00 0:10:02.959369 21315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T02:09:57.944430+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T01:00:00+00:00 EmrJobFlowSensor 2021-04-26T02:10:00.302744+00:00 2021-04-26T02:18:02.862206+00:00 0:08:02.559462 21314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T02:09:57.944383+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T02:09:38.170217+00:00 2021-04-26T02:09:39.854651+00:00 0:00:01.684434 21313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T02:09:35.901619+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T02:09:38.167208+00:00 2021-04-26T02:09:40.026114+00:00 0:00:01.858906 21312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T02:09:35.901650+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T01:00:00+00:00 PythonOperator 2021-04-26T02:09:18.109386+00:00 2021-04-26T02:09:21.180935+00:00 0:00:03.071549 21311 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T02:09:15.886790+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T01:00:00+00:00 PythonOperator 2021-04-26T02:09:16.190864+00:00 2021-04-26T02:09:19.467362+00:00 0:00:03.276498 21310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T02:09:13.884066+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T01:00:00+00:00 TriggerDagRunOperator 2021-04-26T02:09:06.509632+00:00 2021-04-26T02:09:06.941682+00:00 0:00:00.432050 21309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T02:09:03.851669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T01:00:00+00:00 TriggerDagRunOperator 2021-04-26T02:09:06.093945+00:00 2021-04-26T02:09:06.653239+00:00 0:00:00.559294 21308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T02:09:03.851703+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T01:05:00+00:00 EmrJobFlowSensor 2021-04-26T02:05:58.070878+00:00 2021-04-26T02:14:00.438648+00:00 0:08:02.367770 21307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T02:05:55.647076+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T02:05:35.863005+00:00 2021-04-26T02:05:37.611621+00:00 0:00:01.748616 21306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T02:05:33.585837+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T01:05:00+00:00 PythonOperator 2021-04-26T02:05:13.678548+00:00 2021-04-26T02:05:16.730280+00:00 0:00:03.051732 21305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T02:05:11.520147+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T01:00:00+00:00 EmrJobFlowSensor 2021-04-26T02:00:55.335264+00:00 2021-04-26T02:08:57.879643+00:00 0:08:02.544379 21304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T02:00:53.105567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T02:00:33.314675+00:00 2021-04-26T02:00:35.345365+00:00 0:00:02.030690 21303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T02:00:31.086373+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T01:00:00+00:00 PythonOperator 2021-04-26T02:00:11.401338+00:00 2021-04-26T02:00:14.495115+00:00 0:00:03.093777 21302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T02:00:09.031972+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T00:00:00+00:00 EmrJobFlowSensor 2021-04-26T01:11:21.268718+00:00 2021-04-26T01:21:23.986795+00:00 0:10:02.718077 21300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T01:11:19.022739+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T00:00:00+00:00 EmrJobFlowSensor 2021-04-26T01:11:11.222911+00:00 2021-04-26T01:21:14.087261+00:00 0:10:02.864350 21299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T01:11:09.008643+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T01:10:59.625638+00:00 2021-04-26T01:11:01.413006+00:00 0:00:01.787368 21298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T01:10:57.087193+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T01:10:49.381228+00:00 2021-04-26T01:10:51.108469+00:00 0:00:01.727241 21297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T01:10:46.990976+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T00:00:00+00:00 PythonOperator 2021-04-26T01:10:37.327745+00:00 2021-04-26T01:10:40.346423+00:00 0:00:03.018678 21296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T01:10:34.961692+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T00:00:00+00:00 PythonOperator 2021-04-26T01:10:27.125808+00:00 2021-04-26T01:10:30.272430+00:00 0:00:03.146622 21295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T01:10:24.912397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T00:00:00+00:00 TriggerDagRunOperator 2021-04-26T01:10:17.318191+00:00 2021-04-26T01:10:17.781059+00:00 0:00:00.462868 21294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T01:10:14.963514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T00:00:00+00:00 TriggerDagRunOperator 2021-04-26T01:10:17.313064+00:00 2021-04-26T01:10:17.866870+00:00 0:00:00.553806 21293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T01:10:14.963477+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T00:05:00+00:00 EmrJobFlowSensor 2021-04-26T01:05:56.519830+00:00 2021-04-26T01:14:59.073193+00:00 0:09:02.553363 21292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T01:05:54.359068+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T01:05:34.714505+00:00 2021-04-26T01:05:36.440668+00:00 0:00:01.726163 21291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T01:05:32.340885+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T00:05:00+00:00 PythonOperator 2021-04-26T01:05:12.503233+00:00 2021-04-26T01:05:15.466796+00:00 0:00:02.963563 21290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T01:05:10.320577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T00:00:00+00:00 EmrJobFlowSensor 2021-04-26T01:01:00.530544+00:00 2021-04-26T01:10:03.235253+00:00 0:09:02.704709 21289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T01:00:57.964976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T01:00:38.126992+00:00 2021-04-26T01:00:39.850573+00:00 0:00:01.723581 21288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T01:00:35.879389+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T00:00:00+00:00 PythonOperator 2021-04-26T01:00:18.520096+00:00 2021-04-26T01:00:21.620379+00:00 0:00:03.100283 21287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T01:00:15.798572+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T23:00:00+00:00 EmrJobFlowSensor 2021-04-26T00:11:25.907611+00:00 2021-04-26T00:19:28.315412+00:00 0:08:02.407801 21285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T00:11:23.631950+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T23:00:00+00:00 EmrJobFlowSensor 2021-04-26T00:11:13.932698+00:00 2021-04-26T00:21:16.624386+00:00 0:10:02.691688 21284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T00:11:11.623507+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T00:11:03.798051+00:00 2021-04-26T00:11:05.505261+00:00 0:00:01.707210 21283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T00:11:01.616066+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T00:10:51.845209+00:00 2021-04-26T00:10:53.524790+00:00 0:00:01.679581 21282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T00:10:49.601190+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T23:00:00+00:00 PythonOperator 2021-04-26T00:10:41.899633+00:00 2021-04-26T00:10:44.873892+00:00 0:00:02.974259 21281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T00:10:39.594060+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T23:00:00+00:00 PythonOperator 2021-04-26T00:10:31.804265+00:00 2021-04-26T00:10:35.011600+00:00 0:00:03.207335 21280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T00:10:29.592606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T23:00:00+00:00 TriggerDagRunOperator 2021-04-26T00:10:16.332574+00:00 2021-04-26T00:10:16.884093+00:00 0:00:00.551519 21279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T00:10:13.467537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T23:00:00+00:00 TriggerDagRunOperator 2021-04-26T00:10:16.292654+00:00 2021-04-26T00:10:16.727447+00:00 0:00:00.434793 21278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T00:10:13.467588+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T23:05:00+00:00 EmrJobFlowSensor 2021-04-26T00:05:51.454341+00:00 2021-04-26T00:14:54.086292+00:00 0:09:02.631951 21277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T00:05:49.154895+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-26T00:05:29.650032+00:00 2021-04-26T00:05:31.408803+00:00 0:00:01.758771 21276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T00:05:27.052468+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T23:05:00+00:00 PythonOperator 2021-04-26T00:05:09.114683+00:00 2021-04-26T00:05:12.068852+00:00 0:00:02.954169 21275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T00:05:06.964249+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T23:00:00+00:00 EmrJobFlowSensor 2021-04-26T00:01:03.002854+00:00 2021-04-26T00:10:05.753807+00:00 0:09:02.750953 21274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T00:01:00.658809+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T00:00:40.846082+00:00 2021-04-26T00:00:42.639178+00:00 0:00:01.793096 21273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T00:00:38.592763+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T23:00:00+00:00 PythonOperator 2021-04-26T00:00:19.294134+00:00 2021-04-26T00:00:22.296116+00:00 0:00:03.001982 21272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T00:00:16.564541+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T22:00:00+00:00 EmrJobFlowSensor 2021-04-25T23:12:18.817639+00:00 2021-04-25T23:21:21.566532+00:00 0:09:02.748893 21270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T23:12:16.419295+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T22:00:00+00:00 EmrJobFlowSensor 2021-04-25T23:12:04.870535+00:00 2021-04-25T23:21:07.595703+00:00 0:09:02.725168 21269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T23:12:02.417464+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T23:11:56.890646+00:00 2021-04-25T23:11:58.724962+00:00 0:00:01.834316 21268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T23:11:54.464121+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T23:11:42.962719+00:00 2021-04-25T23:11:44.622194+00:00 0:00:01.659475 21267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T23:11:40.337027+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T22:00:00+00:00 PythonOperator 2021-04-25T23:11:34.660615+00:00 2021-04-25T23:11:37.694465+00:00 0:00:03.033850 21266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T23:11:32.366496+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T22:00:00+00:00 PythonOperator 2021-04-25T23:11:20.490857+00:00 2021-04-25T23:11:23.718634+00:00 0:00:03.227777 21265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T23:11:18.321703+00:00 2 default_pool