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_cluster_and_add_emr_steps 2021-07-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T23:11:47.796091+00:00 2021-07-09T23:11:49.472343+00:00 0:00:01.676252 52030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T23:11:45.146523+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T22:00:00+00:00 PythonOperator 2021-07-09T23:11:35.391083+00:00 2021-07-09T23:11:39.308077+00:00 0:00:03.916994 52029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T23:11:33.084829+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T22:00:00+00:00 PythonOperator 2021-07-09T23:11:25.777993+00:00 2021-07-09T23:11:29.404448+00:00 0:00:03.626455 52028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T23:11:23.009812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T22:00:00+00:00 TriggerDagRunOperator 2021-07-09T23:11:17.310660+00:00 2021-07-09T23:11:17.805948+00:00 0:00:00.495288 52027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T23:11:14.996775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T22:00:00+00:00 TriggerDagRunOperator 2021-07-09T23:11:17.330313+00:00 2021-07-09T23:11:17.833686+00:00 0:00:00.503373 52026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T23:11:14.996803+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T22:05:00+00:00 EmrJobFlowSensor 2021-07-09T23:06:06.726077+00:00 2021-07-09T23:15:09.428212+00:00 0:09:02.702135 52025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T23:06:04.587291+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T22:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T23:05:44.714489+00:00 2021-07-09T23:05:46.378016+00:00 0:00:01.663527 52024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T23:05:42.548994+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T22:05:00+00:00 PythonOperator 2021-07-09T23:05:12.664147+00:00 2021-07-09T23:05:16.320694+00:00 0:00:03.656547 52023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T23:05:10.518861+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-08T23:00:00+00:00 EmrJobFlowSensor 2021-07-09T23:00:58.275874+00:00 2021-07-09T23:10:00.939212+00:00 0:09:02.663338 52022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T23:00:56.009093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T22:00:00+00:00 EmrJobFlowSensor 2021-07-09T23:00:50.535323+00:00 2021-07-09T23:10:53.506693+00:00 0:10:02.971370 52021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T23:00:48.060644+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T23:00:38.471402+00:00 2021-07-09T23:00:40.151258+00:00 0:00:01.679856 52020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T23:00:36.043515+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T23:00:28.590413+00:00 2021-07-09T23:00:30.379035+00:00 0:00:01.788622 52019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T23:00:26.058247+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-08T23:00:00+00:00 PythonOperator 2021-07-09T23:00:16.648730+00:00 2021-07-09T23:00:20.460507+00:00 0:00:03.811777 52018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T23:00:13.950341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T22:00:00+00:00 PythonOperator 2021-07-09T23:00:08.384293+00:00 2021-07-09T23:00:12.248328+00:00 0:00:03.864035 52017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T23:00:05.943044+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T21:00:00+00:00 EmrJobFlowSensor 2021-07-09T22:10:28.942409+00:00 2021-07-09T22:20:31.780091+00:00 0:10:02.837682 52015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T22:10:26.392690+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T21:00:00+00:00 EmrJobFlowSensor 2021-07-09T22:10:10.690092+00:00 2021-07-09T22:20:13.754396+00:00 0:10:03.064304 52014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T22:10:08.375804+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T22:10:06.962926+00:00 2021-07-09T22:10:08.735126+00:00 0:00:01.772200 52013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T22:10:04.375102+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T22:09:46.618391+00:00 2021-07-09T22:09:48.394385+00:00 0:00:01.775994 52012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T22:09:44.306653+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T21:00:00+00:00 PythonOperator 2021-07-09T22:09:44.630087+00:00 2021-07-09T22:09:48.572993+00:00 0:00:03.942906 52011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T22:09:42.358837+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T21:00:00+00:00 PythonOperator 2021-07-09T22:09:26.751016+00:00 2021-07-09T22:09:30.593369+00:00 0:00:03.842353 52010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T22:09:24.263111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T21:00:00+00:00 TriggerDagRunOperator 2021-07-09T22:09:20.611338+00:00 2021-07-09T22:09:21.155409+00:00 0:00:00.544071 52009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T22:09:18.260594+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T21:00:00+00:00 TriggerDagRunOperator 2021-07-09T22:09:20.404492+00:00 2021-07-09T22:09:20.785916+00:00 0:00:00.381424 52008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T22:09:18.260627+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T21:05:00+00:00 EmrJobFlowSensor 2021-07-09T22:06:00.380160+00:00 2021-07-09T22:15:03.074089+00:00 0:09:02.693929 52007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T22:05:58.050588+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T21:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T22:05:39.995608+00:00 2021-07-09T22:05:41.765472+00:00 0:00:01.769864 52006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T22:05:37.893923+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T21:05:00+00:00 PythonOperator 2021-07-09T22:05:17.993154+00:00 2021-07-09T22:05:21.418835+00:00 0:00:03.425681 52005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T22:05:15.808025+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T21:00:00+00:00 EmrJobFlowSensor 2021-07-09T22:01:05.508558+00:00 2021-07-09T22:09:08.195092+00:00 0:08:02.686534 52004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T22:01:03.347445+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T22:00:41.877494+00:00 2021-07-09T22:00:43.785963+00:00 0:00:01.908469 52003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T22:00:39.365762+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T21:00:00+00:00 PythonOperator 2021-07-09T22:00:20.001351+00:00 2021-07-09T22:00:23.802078+00:00 0:00:03.800727 52002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T22:00:17.346119+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T20:00:00+00:00 EmrJobFlowSensor 2021-07-09T21:12:28.686356+00:00 2021-07-09T21:22:31.498875+00:00 0:10:02.812519 52000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T21:12:25.964993+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T20:00:00+00:00 EmrJobFlowSensor 2021-07-09T21:12:26.161227+00:00 2021-07-09T21:22:29.460080+00:00 0:10:03.298853 51999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T21:12:23.907178+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T21:12:06.793889+00:00 2021-07-09T21:12:08.526955+00:00 0:00:01.733066 51998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T21:12:03.854028+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T21:12:04.351539+00:00 2021-07-09T21:12:06.421486+00:00 0:00:02.069947 51997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T21:12:01.851478+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T20:00:00+00:00 PythonOperator 2021-07-09T21:11:42.026506+00:00 2021-07-09T21:11:46.221042+00:00 0:00:04.194536 51996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T21:11:39.713799+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T20:00:00+00:00 PythonOperator 2021-07-09T21:11:42.066828+00:00 2021-07-09T21:11:45.747879+00:00 0:00:03.681051 51995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T21:11:39.713835+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T20:00:00+00:00 TriggerDagRunOperator 2021-07-09T21:11:17.967584+00:00 2021-07-09T21:11:18.526011+00:00 0:00:00.558427 51994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T21:11:15.694691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T20:00:00+00:00 TriggerDagRunOperator 2021-07-09T21:11:17.922682+00:00 2021-07-09T21:11:18.303719+00:00 0:00:00.381037 51993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T21:11:15.694741+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T20:05:00+00:00 EmrJobFlowSensor 2021-07-09T21:05:57.661617+00:00 2021-07-09T21:14:00.231725+00:00 0:08:02.570108 51992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T21:05:55.366026+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T20:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T21:05:35.504973+00:00 2021-07-09T21:05:37.242860+00:00 0:00:01.737887 51991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T21:05:33.185396+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T20:05:00+00:00 PythonOperator 2021-07-09T21:05:11.294670+00:00 2021-07-09T21:05:14.969704+00:00 0:00:03.675034 51990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T21:05:09.073527+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T20:00:00+00:00 EmrJobFlowSensor 2021-07-09T21:00:52.677296+00:00 2021-07-09T21:10:55.512107+00:00 0:10:02.834811 51989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T21:00:50.460320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T21:00:31.151007+00:00 2021-07-09T21:00:32.966074+00:00 0:00:01.815067 51988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T21:00:28.564572+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T20:00:00+00:00 PythonOperator 2021-07-09T21:00:10.692629+00:00 2021-07-09T21:00:14.444260+00:00 0:00:03.751631 51987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T21:00:08.416704+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T19:00:00+00:00 EmrJobFlowSensor 2021-07-09T20:12:01.540217+00:00 2021-07-09T20:22:04.712077+00:00 0:10:03.171860 51985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T20:11:59.041689+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T19:00:00+00:00 EmrJobFlowSensor 2021-07-09T20:11:49.326099+00:00 2021-07-09T20:21:52.252844+00:00 0:10:02.926745 51984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T20:11:46.853465+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T20:11:39.192728+00:00 2021-07-09T20:11:40.900959+00:00 0:00:01.708231 51983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T20:11:36.875102+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T20:11:27.294104+00:00 2021-07-09T20:11:29.086168+00:00 0:00:01.792064 51982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T20:11:24.872928+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T19:00:00+00:00 PythonOperator 2021-07-09T20:11:17.011546+00:00 2021-07-09T20:11:20.379559+00:00 0:00:03.368013 51981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T20:11:14.801771+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T19:00:00+00:00 PythonOperator 2021-07-09T20:11:05.152666+00:00 2021-07-09T20:11:09.370007+00:00 0:00:04.217341 51980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T20:11:02.862297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T19:00:00+00:00 TriggerDagRunOperator 2021-07-09T20:11:01.584056+00:00 2021-07-09T20:11:02.036361+00:00 0:00:00.452305 51979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T20:10:58.741034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T19:00:00+00:00 TriggerDagRunOperator 2021-07-09T20:11:01.368125+00:00 2021-07-09T20:11:01.931880+00:00 0:00:00.563755 51978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T20:10:58.741090+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T19:05:00+00:00 EmrJobFlowSensor 2021-07-09T20:05:54.413466+00:00 2021-07-09T20:14:57.063633+00:00 0:09:02.650167 51977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T20:05:52.052873+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T19:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T20:05:30.342162+00:00 2021-07-09T20:05:32.037083+00:00 0:00:01.694921 51976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T20:05:28.060218+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T19:05:00+00:00 PythonOperator 2021-07-09T20:05:10.414392+00:00 2021-07-09T20:05:13.897022+00:00 0:00:03.482630 51975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T20:05:07.986420+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T19:00:00+00:00 EmrJobFlowSensor 2021-07-09T20:00:49.719701+00:00 2021-07-09T20:10:52.587994+00:00 0:10:02.868293 51974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T20:00:47.520579+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T20:00:27.904715+00:00 2021-07-09T20:00:29.730678+00:00 0:00:01.825963 51973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T20:00:25.502721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T19:00:00+00:00 PythonOperator 2021-07-09T20:00:08.400155+00:00 2021-07-09T20:00:12.310221+00:00 0:00:03.910066 51972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T20:00:05.547384+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T18:00:00+00:00 EmrJobFlowSensor 2021-07-09T19:11:19.496533+00:00 2021-07-09T19:20:22.119856+00:00 0:09:02.623323 51970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T19:11:17.257440+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T18:00:00+00:00 EmrJobFlowSensor 2021-07-09T19:11:09.338292+00:00 2021-07-09T19:21:12.264877+00:00 0:10:02.926585 51969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T19:11:07.135146+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T19:10:57.435484+00:00 2021-07-09T19:10:59.146607+00:00 0:00:01.711123 51968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T19:10:55.130189+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T19:10:47.322842+00:00 2021-07-09T19:10:49.188876+00:00 0:00:01.866034 51967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T19:10:45.126992+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T18:00:00+00:00 PythonOperator 2021-07-09T19:10:37.305788+00:00 2021-07-09T19:10:41.081444+00:00 0:00:03.775656 51966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T19:10:35.110938+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T18:00:00+00:00 PythonOperator 2021-07-09T19:10:27.499955+00:00 2021-07-09T19:10:31.232749+00:00 0:00:03.732794 51965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T19:10:25.147409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T18:00:00+00:00 TriggerDagRunOperator 2021-07-09T19:10:11.581812+00:00 2021-07-09T19:10:12.165146+00:00 0:00:00.583334 51964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T19:10:09.143363+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T18:00:00+00:00 TriggerDagRunOperator 2021-07-09T19:10:11.502813+00:00 2021-07-09T19:10:11.931197+00:00 0:00:00.428384 51963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T19:10:09.143309+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T18:05:00+00:00 EmrJobFlowSensor 2021-07-09T19:06:06.721708+00:00 2021-07-09T19:15:09.610800+00:00 0:09:02.889092 51962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T19:06:04.500250+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T18:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T19:05:45.234326+00:00 2021-07-09T19:05:46.955382+00:00 0:00:01.721056 51961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T19:05:42.565995+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T18:05:00+00:00 PythonOperator 2021-07-09T19:05:24.932494+00:00 2021-07-09T19:05:28.572528+00:00 0:00:03.640034 51960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T19:05:22.458693+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T18:00:00+00:00 EmrJobFlowSensor 2021-07-09T19:00:48.325780+00:00 2021-07-09T19:09:51.158840+00:00 0:09:02.833060 51959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T19:00:46.049799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T19:00:28.319166+00:00 2021-07-09T19:00:30.084740+00:00 0:00:01.765574 51958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T19:00:26.031588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T18:00:00+00:00 PythonOperator 2021-07-09T19:00:06.511193+00:00 2021-07-09T19:00:10.362554+00:00 0:00:03.851361 51957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T19:00:04.019159+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T17:00:00+00:00 EmrJobFlowSensor 2021-07-09T18:12:13.046770+00:00 2021-07-09T18:22:15.963608+00:00 0:10:02.916838 51955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T18:12:10.560695+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T17:00:00+00:00 EmrJobFlowSensor 2021-07-09T18:12:12.938031+00:00 2021-07-09T18:22:16.022009+00:00 0:10:03.083978 51954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T18:12:10.560741+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T18:11:50.823729+00:00 2021-07-09T18:11:52.619622+00:00 0:00:01.795893 51953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T18:11:48.457683+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T18:11:50.718337+00:00 2021-07-09T18:11:52.598210+00:00 0:00:01.879873 51952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T18:11:48.457648+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T17:00:00+00:00 PythonOperator 2021-07-09T18:11:28.753523+00:00 2021-07-09T18:11:32.738144+00:00 0:00:03.984621 51951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T18:11:26.412734+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T17:00:00+00:00 PythonOperator 2021-07-09T18:11:28.753824+00:00 2021-07-09T18:11:32.513637+00:00 0:00:03.759813 51950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T18:11:26.412773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T17:00:00+00:00 TriggerDagRunOperator 2021-07-09T18:11:16.710731+00:00 2021-07-09T18:11:17.255585+00:00 0:00:00.544854 51949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T18:11:14.404755+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T17:00:00+00:00 TriggerDagRunOperator 2021-07-09T18:11:16.600126+00:00 2021-07-09T18:11:17.162805+00:00 0:00:00.562679 51948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T18:11:14.404796+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T17:05:00+00:00 EmrJobFlowSensor 2021-07-09T18:05:51.913116+00:00 2021-07-09T18:14:54.715792+00:00 0:09:02.802676 51947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T18:05:49.789298+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T17:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T18:05:30.293979+00:00 2021-07-09T18:05:32.042290+00:00 0:00:01.748311 51946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T18:05:27.788417+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T17:05:00+00:00 PythonOperator 2021-07-09T18:05:08.234065+00:00 2021-07-09T18:05:12.039434+00:00 0:00:03.805369 51945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T18:05:05.757378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T17:00:00+00:00 EmrJobFlowSensor 2021-07-09T18:00:55.936519+00:00 2021-07-09T18:10:58.970385+00:00 0:10:03.033866 51944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T18:00:53.303256+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T18:00:33.882180+00:00 2021-07-09T18:00:35.659003+00:00 0:00:01.776823 51943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T18:00:31.283340+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T17:00:00+00:00 PythonOperator 2021-07-09T18:00:11.480774+00:00 2021-07-09T18:00:15.191586+00:00 0:00:03.710812 51942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T18:00:09.183555+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T16:00:00+00:00 EmrJobFlowSensor 2021-07-09T17:12:17.463590+00:00 2021-07-09T17:22:20.610916+00:00 0:10:03.147326 51940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T17:12:15.010414+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T16:00:00+00:00 EmrJobFlowSensor 2021-07-09T17:12:07.533115+00:00 2021-07-09T17:22:10.323880+00:00 0:10:02.790765 51939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T17:12:05.072436+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T17:11:55.292450+00:00 2021-07-09T17:11:56.998361+00:00 0:00:01.705911 51938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T17:11:52.952747+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T17:11:43.125559+00:00 2021-07-09T17:11:44.822067+00:00 0:00:01.696508 51937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T17:11:40.943457+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T16:00:00+00:00 PythonOperator 2021-07-09T17:11:35.297266+00:00 2021-07-09T17:11:38.764316+00:00 0:00:03.467050 51936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T17:11:32.934344+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T16:00:00+00:00 PythonOperator 2021-07-09T17:11:23.624355+00:00 2021-07-09T17:11:27.753085+00:00 0:00:04.128730 51935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T17:11:20.926193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T16:00:00+00:00 TriggerDagRunOperator 2021-07-09T17:11:15.393535+00:00 2021-07-09T17:11:15.791111+00:00 0:00:00.397576 51934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T17:11:12.923556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T16:00:00+00:00 TriggerDagRunOperator 2021-07-09T17:11:15.271288+00:00 2021-07-09T17:11:15.788681+00:00 0:00:00.517393 51933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T17:11:12.923594+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T16:05:00+00:00 EmrJobFlowSensor 2021-07-09T17:05:54.535116+00:00 2021-07-09T17:14:57.284857+00:00 0:09:02.749741 51932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T17:05:52.349143+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T16:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T17:05:32.927396+00:00 2021-07-09T17:05:34.608796+00:00 0:00:01.681400 51931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T17:05:30.363640+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T16:05:00+00:00 PythonOperator 2021-07-09T17:05:10.880812+00:00 2021-07-09T17:05:14.328716+00:00 0:00:03.447904 51930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T17:05:08.346521+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T16:00:00+00:00 EmrJobFlowSensor 2021-07-09T17:00:48.207128+00:00 2021-07-09T17:10:51.273630+00:00 0:10:03.066502 51929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T17:00:45.856861+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T17:00:28.093697+00:00 2021-07-09T17:00:29.786898+00:00 0:00:01.693201 51928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T17:00:25.823006+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T16:00:00+00:00 PythonOperator 2021-07-09T17:00:06.540704+00:00 2021-07-09T17:00:09.991921+00:00 0:00:03.451217 51927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T17:00:03.805016+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T15:00:00+00:00 EmrJobFlowSensor 2021-07-09T16:12:16.113913+00:00 2021-07-09T16:22:19.063872+00:00 0:10:02.949959 51925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T16:12:13.491405+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T15:00:00+00:00 EmrJobFlowSensor 2021-07-09T16:12:11.821609+00:00 2021-07-09T16:22:14.847061+00:00 0:10:03.025452 51924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T16:12:09.542202+00:00 2 default_pool