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 check_cluster_status 2021-05-04T07:00:00+00:00 EmrJobFlowSensor 2021-05-04T08:10:06.656707+00:00 2021-05-04T08:19:09.465078+00:00 0:09:02.808371 24312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:10:04.166965+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T07:00:00+00:00 EmrJobFlowSensor 2021-05-04T08:10:06.705886+00:00 2021-05-04T08:19:09.556713+00:00 0:09:02.850827 24311 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:10:04.167006+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:09:44.529518+00:00 2021-05-04T08:09:46.239471+00:00 0:00:01.709953 24310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T08:09:42.061802+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:09:44.559437+00:00 2021-05-04T08:09:46.412974+00:00 0:00:01.853537 24309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T08:09:42.061841+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T07:00:00+00:00 PythonOperator 2021-05-04T08:09:22.297636+00:00 2021-05-04T08:09:25.699228+00:00 0:00:03.401592 24308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:09:20.010955+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T07:00:00+00:00 PythonOperator 2021-05-04T08:09:22.310085+00:00 2021-05-04T08:09:25.431407+00:00 0:00:03.121322 24307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:09:20.010913+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T07:00:00+00:00 TriggerDagRunOperator 2021-05-04T08:09:12.346836+00:00 2021-05-04T08:09:12.911861+00:00 0:00:00.565025 24306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:09:10.059505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T07:00:00+00:00 TriggerDagRunOperator 2021-05-04T08:09:12.338956+00:00 2021-05-04T08:09:12.837359+00:00 0:00:00.498403 24305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:09:10.059534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T07:05:00+00:00 EmrJobFlowSensor 2021-05-04T08:05:59.981950+00:00 2021-05-04T08:15:02.641051+00:00 0:09:02.659101 24304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:05:57.688331+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:05:37.787423+00:00 2021-05-04T08:05:39.573891+00:00 0:00:01.786468 24303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T08:05:35.601615+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T07:05:00+00:00 PythonOperator 2021-05-04T08:05:17.795181+00:00 2021-05-04T08:05:20.775113+00:00 0:00:02.979932 24302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:05:15.567586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T07:00:00+00:00 EmrJobFlowSensor 2021-05-04T08:00:57.206283+00:00 2021-05-04T08:08:59.746461+00:00 0:08:02.540178 24301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:00:55.040580+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:00:35.334701+00:00 2021-05-04T08:00:37.028931+00:00 0:00:01.694230 24300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T08:00:33.012790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T07:00:00+00:00 PythonOperator 2021-05-04T08:00:07.235143+00:00 2021-05-04T08:00:10.526875+00:00 0:00:03.291732 24299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T08:00:04.999892+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T06:00:00+00:00 EmrJobFlowSensor 2021-05-04T07:14:43.512541+00:00 2021-05-04T07:24:46.231887+00:00 0:10:02.719346 24298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:14:41.065801+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T06:00:00+00:00 EmrJobFlowSensor 2021-05-04T07:14:39.351966+00:00 2021-05-04T07:24:42.093201+00:00 0:10:02.741235 24297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:14:37.051825+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:14:21.218995+00:00 2021-05-04T07:14:22.966560+00:00 0:00:01.747565 24296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T07:14:19.012284+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:14:19.707107+00:00 2021-05-04T07:14:21.533576+00:00 0:00:01.826469 24295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T07:14:17.141566+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T06:00:00+00:00 PythonOperator 2021-05-04T07:13:59.585762+00:00 2021-05-04T07:14:02.680392+00:00 0:00:03.094630 24294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:13:56.985043+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T06:00:00+00:00 PythonOperator 2021-05-04T07:13:57.163022+00:00 2021-05-04T07:14:00.817124+00:00 0:00:03.654102 24293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:13:54.979785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T06:00:00+00:00 TriggerDagRunOperator 2021-05-04T07:13:35.724740+00:00 2021-05-04T07:13:36.230611+00:00 0:00:00.505871 24292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:13:32.961071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T06:00:00+00:00 TriggerDagRunOperator 2021-05-04T07:13:35.609112+00:00 2021-05-04T07:13:36.036520+00:00 0:00:00.427408 24291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:13:32.961098+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T06:05:00+00:00 EmrJobFlowSensor 2021-05-04T07:06:02.909007+00:00 2021-05-04T07:15:05.587806+00:00 0:09:02.678799 24289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:06:00.634881+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:05:42.954606+00:00 2021-05-04T07:05:44.694084+00:00 0:00:01.739478 24288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T07:05:40.612224+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T06:05:00+00:00 PythonOperator 2021-05-04T07:05:20.858499+00:00 2021-05-04T07:05:23.906454+00:00 0:00:03.047955 24287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:05:18.587479+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T06:00:00+00:00 EmrJobFlowSensor 2021-05-04T07:00:58.231229+00:00 2021-05-04T07:10:00.872507+00:00 0:09:02.641278 24286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:00:56.095518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:00:36.393191+00:00 2021-05-04T07:00:38.075626+00:00 0:00:01.682435 24285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T07:00:34.149251+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T06:00:00+00:00 PythonOperator 2021-05-04T07:00:16.259498+00:00 2021-05-04T07:00:19.311483+00:00 0:00:03.051985 24284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T07:00:14.009746+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T05:00:00+00:00 EmrJobFlowSensor 2021-05-04T06:11:47.132811+00:00 2021-05-04T06:21:49.838767+00:00 0:10:02.705956 24283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:11:44.886827+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T05:00:00+00:00 EmrJobFlowSensor 2021-05-04T06:11:43.111888+00:00 2021-05-04T06:21:45.741573+00:00 0:10:02.629685 24282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:11:40.859231+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:11:27.008174+00:00 2021-05-04T06:11:28.796713+00:00 0:00:01.788539 24281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T06:11:24.814726+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:11:21.140459+00:00 2021-05-04T06:11:22.853772+00:00 0:00:01.713313 24280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T06:11:18.855830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T05:00:00+00:00 PythonOperator 2021-05-04T06:11:05.382204+00:00 2021-05-04T06:11:08.764859+00:00 0:00:03.382655 24279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:11:02.843890+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T05:00:00+00:00 PythonOperator 2021-05-04T06:10:59.220607+00:00 2021-05-04T06:11:02.260142+00:00 0:00:03.039535 24278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:10:56.858172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T05:00:00+00:00 TriggerDagRunOperator 2021-05-04T06:10:41.107039+00:00 2021-05-04T06:10:41.631599+00:00 0:00:00.524560 24277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:10:38.771100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T05:00:00+00:00 TriggerDagRunOperator 2021-05-04T06:10:40.997702+00:00 2021-05-04T06:10:41.405722+00:00 0:00:00.408020 24276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:10:38.771134+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T05:05:00+00:00 EmrJobFlowSensor 2021-05-04T06:08:06.880816+00:00 2021-05-04T06:17:09.623539+00:00 0:09:02.742723 24275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:08:04.714363+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:07:44.666516+00:00 2021-05-04T06:07:46.294417+00:00 0:00:01.627901 24274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T06:07:42.497149+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T05:00:00+00:00 EmrJobFlowSensor 2021-05-04T06:07:27.784581+00:00 2021-05-04T06:10:29.586710+00:00 0:03:01.802129 24273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:07:24.413314+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T05:05:00+00:00 PythonOperator 2021-05-04T06:07:25.453725+00:00 2021-05-04T06:07:29.027337+00:00 0:00:03.573612 24272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:07:22.469473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:00:30.655143+00:00 2021-05-04T06:00:32.492782+00:00 0:00:01.837639 24270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T06:00:27.657803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T05:00:00+00:00 PythonOperator 2021-05-04T06:00:10.105216+00:00 2021-05-04T06:00:13.124427+00:00 0:00:03.019211 24269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T06:00:07.585856+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T04:00:00+00:00 EmrJobFlowSensor 2021-05-04T05:11:46.639556+00:00 2021-05-04T05:20:49.281177+00:00 0:09:02.641621 24268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:11:44.455342+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T04:00:00+00:00 EmrJobFlowSensor 2021-05-04T05:11:40.601176+00:00 2021-05-04T05:20:43.298152+00:00 0:09:02.696976 24267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:11:38.399929+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:11:24.626011+00:00 2021-05-04T05:11:26.319750+00:00 0:00:01.693739 24266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T05:11:22.358498+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:11:20.539478+00:00 2021-05-04T05:11:22.272907+00:00 0:00:01.733429 24265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T05:11:18.355849+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T04:00:00+00:00 PythonOperator 2021-05-04T05:11:04.859645+00:00 2021-05-04T05:11:08.219290+00:00 0:00:03.359645 24264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:11:02.346500+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T04:00:00+00:00 PythonOperator 2021-05-04T05:10:58.601262+00:00 2021-05-04T05:11:01.691439+00:00 0:00:03.090177 24263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:10:56.339258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T04:00:00+00:00 TriggerDagRunOperator 2021-05-04T05:10:48.799210+00:00 2021-05-04T05:10:49.332611+00:00 0:00:00.533401 24262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:10:46.332990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T04:00:00+00:00 TriggerDagRunOperator 2021-05-04T05:10:48.571373+00:00 2021-05-04T05:10:49.018315+00:00 0:00:00.446942 24261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:10:46.333025+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T04:05:00+00:00 EmrJobFlowSensor 2021-05-04T05:06:04.491439+00:00 2021-05-04T05:14:07.279228+00:00 0:08:02.787789 24260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:06:02.053640+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:05:42.042140+00:00 2021-05-04T05:05:43.697268+00:00 0:00:01.655128 24259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T05:05:39.922815+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T04:05:00+00:00 PythonOperator 2021-05-04T05:05:22.145258+00:00 2021-05-04T05:05:25.197515+00:00 0:00:03.052257 24258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:05:19.908076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T04:00:00+00:00 EmrJobFlowSensor 2021-05-04T05:01:31.841568+00:00 2021-05-04T05:10:34.472972+00:00 0:09:02.631404 24257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:01:29.625797+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:01:09.827974+00:00 2021-05-04T05:01:11.541745+00:00 0:00:01.713771 24256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T05:01:07.597284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T04:00:00+00:00 PythonOperator 2021-05-04T05:00:50.385631+00:00 2021-05-04T05:00:53.516926+00:00 0:00:03.131295 24255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T05:00:47.641198+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T03:00:00+00:00 EmrJobFlowSensor 2021-05-04T04:11:12.941095+00:00 2021-05-04T04:21:15.703411+00:00 0:10:02.762316 24253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:11:10.676657+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T03:00:00+00:00 EmrJobFlowSensor 2021-05-04T04:11:12.934431+00:00 2021-05-04T04:21:15.920991+00:00 0:10:02.986560 24252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:11:10.676698+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:10:50.935642+00:00 2021-05-04T04:10:52.754188+00:00 0:00:01.818546 24251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T04:10:48.654462+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:10:50.860539+00:00 2021-05-04T04:10:52.574275+00:00 0:00:01.713736 24250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T04:10:48.654434+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T03:00:00+00:00 PythonOperator 2021-05-04T04:10:31.159360+00:00 2021-05-04T04:10:34.237604+00:00 0:00:03.078244 24249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:10:28.658711+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T03:00:00+00:00 PythonOperator 2021-05-04T04:10:29.185073+00:00 2021-05-04T04:10:32.505759+00:00 0:00:03.320686 24248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:10:26.653021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T03:00:00+00:00 TriggerDagRunOperator 2021-05-04T04:10:10.839361+00:00 2021-05-04T04:10:11.368048+00:00 0:00:00.528687 24247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:10:08.545452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T03:00:00+00:00 TriggerDagRunOperator 2021-05-04T04:10:10.791148+00:00 2021-05-04T04:10:11.227530+00:00 0:00:00.436382 24246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:10:08.545403+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T03:05:00+00:00 EmrJobFlowSensor 2021-05-04T04:05:50.202976+00:00 2021-05-04T04:14:52.703641+00:00 0:09:02.500665 24245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:05:48.033853+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:05:30.609419+00:00 2021-05-04T04:05:32.336080+00:00 0:00:01.726661 24244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T04:05:28.150763+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T03:05:00+00:00 PythonOperator 2021-05-04T04:05:08.548312+00:00 2021-05-04T04:05:11.646143+00:00 0:00:03.097831 24243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:05:06.061744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T03:00:00+00:00 EmrJobFlowSensor 2021-05-04T04:01:04.330586+00:00 2021-05-04T04:10:07.276865+00:00 0:09:02.946279 24242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:01:01.744145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:00:41.931320+00:00 2021-05-04T04:00:43.720385+00:00 0:00:01.789065 24241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T04:00:39.641938+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T03:00:00+00:00 PythonOperator 2021-05-04T04:00:20.106731+00:00 2021-05-04T04:00:23.267283+00:00 0:00:03.160552 24240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T04:00:17.622100+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T02:00:00+00:00 EmrJobFlowSensor 2021-05-04T03:11:34.471139+00:00 2021-05-04T03:20:37.319566+00:00 0:09:02.848427 24238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:11:32.066692+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T02:00:00+00:00 EmrJobFlowSensor 2021-05-04T03:11:22.244579+00:00 2021-05-04T03:20:25.016064+00:00 0:09:02.771485 24237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:11:19.994303+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T03:11:12.327388+00:00 2021-05-04T03:11:14.114328+00:00 0:00:01.786940 24236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T03:11:10.049944+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T03:11:02.211856+00:00 2021-05-04T03:11:04.137175+00:00 0:00:01.925319 24235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T03:10:59.959487+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T02:00:00+00:00 PythonOperator 2021-05-04T03:10:50.386321+00:00 2021-05-04T03:10:53.411672+00:00 0:00:03.025351 24234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T03:10:47.947186+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T02:00:00+00:00 PythonOperator 2021-05-04T03:10:40.234162+00:00 2021-05-04T03:10:43.495096+00:00 0:00:03.260934 24233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T03:10:37.940183+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T02:00:00+00:00 TriggerDagRunOperator 2021-05-04T03:10:20.318269+00:00 2021-05-04T03:10:20.852149+00:00 0:00:00.533880 24232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:10:17.922540+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T02:00:00+00:00 TriggerDagRunOperator 2021-05-04T03:10:20.250772+00:00 2021-05-04T03:10:20.678739+00:00 0:00:00.427967 24231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:10:17.922574+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T02:05:00+00:00 EmrJobFlowSensor 2021-05-04T03:06:03.578478+00:00 2021-05-04T03:15:06.321651+00:00 0:09:02.743173 24230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:06:01.424743+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T03:05:41.781014+00:00 2021-05-04T03:05:43.424004+00:00 0:00:01.642990 24229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T03:05:39.455683+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T02:05:00+00:00 PythonOperator 2021-05-04T03:05:19.791606+00:00 2021-05-04T03:05:22.801234+00:00 0:00:03.009628 24228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T03:05:17.464076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T02:00:00+00:00 EmrJobFlowSensor 2021-05-04T03:00:57.287819+00:00 2021-05-04T03:09:59.955789+00:00 0:09:02.667970 24227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T03:00:55.053871+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T03:00:35.391354+00:00 2021-05-04T03:00:37.187041+00:00 0:00:01.795687 24226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T03:00:32.985956+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T02:00:00+00:00 PythonOperator 2021-05-04T03:00:13.448654+00:00 2021-05-04T03:00:16.523736+00:00 0:00:03.075082 24225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T03:00:10.926942+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T01:00:00+00:00 EmrJobFlowSensor 2021-05-04T02:11:14.693649+00:00 2021-05-04T02:20:17.325508+00:00 0:09:02.631859 24223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T02:11:12.410342+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T01:00:00+00:00 EmrJobFlowSensor 2021-05-04T02:11:06.759006+00:00 2021-05-04T02:21:09.598010+00:00 0:10:02.839004 24222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T02:11:04.473094+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T02:10:54.712795+00:00 2021-05-04T02:10:56.490440+00:00 0:00:01.777645 24221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T02:10:52.391808+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T02:10:44.901736+00:00 2021-05-04T02:10:46.663138+00:00 0:00:01.761402 24220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T02:10:42.460352+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T01:00:00+00:00 PythonOperator 2021-05-04T02:10:32.581864+00:00 2021-05-04T02:10:35.639784+00:00 0:00:03.057920 24219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T02:10:30.309395+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T01:00:00+00:00 PythonOperator 2021-05-04T02:10:25.235087+00:00 2021-05-04T02:10:28.490193+00:00 0:00:03.255106 24218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T02:10:22.308756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T01:00:00+00:00 TriggerDagRunOperator 2021-05-04T02:10:16.761620+00:00 2021-05-04T02:10:17.280095+00:00 0:00:00.518475 24217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T02:10:14.295085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T01:00:00+00:00 TriggerDagRunOperator 2021-05-04T02:10:16.669758+00:00 2021-05-04T02:10:17.162235+00:00 0:00:00.492477 24216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T02:10:14.295053+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T01:05:00+00:00 EmrJobFlowSensor 2021-05-04T02:06:00.085132+00:00 2021-05-04T02:15:03.034536+00:00 0:09:02.949404 24215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T02:05:57.850694+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T02:05:40.088105+00:00 2021-05-04T02:05:41.789486+00:00 0:00:01.701381 24214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T02:05:37.811206+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T01:05:00+00:00 PythonOperator 2021-05-04T02:05:16.060472+00:00 2021-05-04T02:05:19.088164+00:00 0:00:03.027692 24213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T02:05:13.799226+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T01:00:00+00:00 EmrJobFlowSensor 2021-05-04T02:00:51.624988+00:00 2021-05-04T02:09:54.269779+00:00 0:09:02.644791 24212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T02:00:49.323269+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T02:00:29.914852+00:00 2021-05-04T02:00:31.650436+00:00 0:00:01.735584 24211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T02:00:27.373410+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T01:00:00+00:00 PythonOperator 2021-05-04T02:00:09.790504+00:00 2021-05-04T02:00:12.937226+00:00 0:00:03.146722 24210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T02:00:07.363868+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T00:00:00+00:00 EmrJobFlowSensor 2021-05-04T01:10:01.900793+00:00 2021-05-04T01:20:04.729752+00:00 0:10:02.828959 24208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T01:09:59.049036+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T00:00:00+00:00 EmrJobFlowSensor 2021-05-04T01:09:59.103517+00:00 2021-05-04T01:20:02.221919+00:00 0:10:03.118402 24207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T01:09:56.804093+00:00 2 default_pool