Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_emr_steps 2021-04-20T18:05:00+00:00 PythonOperator 2021-04-20T19:05:08.305930+00:00 2021-04-20T19:05:11.291128+00:00 0:00:02.985198 19363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T19:05:05.993146+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T18:00:00+00:00 EmrJobFlowSensor 2021-04-20T19:00:47.818160+00:00 2021-04-20T19:10:50.459140+00:00 0:10:02.640980 19362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T19:00:45.559507+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T19:00:25.952359+00:00 2021-04-20T19:00:27.668862+00:00 0:00:01.716503 19361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T19:00:23.450264+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T18:00:00+00:00 PythonOperator 2021-04-20T19:00:05.872805+00:00 2021-04-20T19:00:08.839788+00:00 0:00:02.966983 19360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T19:00:03.434802+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T17:00:00+00:00 EmrJobFlowSensor 2021-04-20T18:11:33.586760+00:00 2021-04-20T18:21:36.396764+00:00 0:10:02.810004 19358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T18:11:30.922513+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T17:00:00+00:00 EmrJobFlowSensor 2021-04-20T18:11:31.004911+00:00 2021-04-20T18:21:34.548129+00:00 0:10:03.543218 19357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T18:11:28.685224+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T18:11:11.436874+00:00 2021-04-20T18:11:13.164071+00:00 0:00:01.727197 19356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T18:11:08.674488+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T18:11:09.139139+00:00 2021-04-20T18:11:11.154705+00:00 0:00:02.015566 19355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T18:11:06.590774+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T17:00:00+00:00 PythonOperator 2021-04-20T18:10:49.105765+00:00 2021-04-20T18:10:52.039616+00:00 0:00:02.933851 19354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T18:10:46.360423+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T17:00:00+00:00 PythonOperator 2021-04-20T18:10:49.116345+00:00 2021-04-20T18:10:52.278848+00:00 0:00:03.162503 19353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T18:10:46.360451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T17:00:00+00:00 TriggerDagRunOperator 2021-04-20T18:10:24.771466+00:00 2021-04-20T18:10:25.298814+00:00 0:00:00.527348 19352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T18:10:22.310477+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T17:00:00+00:00 TriggerDagRunOperator 2021-04-20T18:10:24.713604+00:00 2021-04-20T18:10:25.137050+00:00 0:00:00.423446 19351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T18:10:22.310506+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T17:05:00+00:00 EmrJobFlowSensor 2021-04-20T18:05:46.109292+00:00 2021-04-20T18:14:48.768161+00:00 0:09:02.658869 19350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T18:05:43.915705+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T18:05:26.186735+00:00 2021-04-20T18:05:27.896549+00:00 0:00:01.709814 19349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T18:05:23.890202+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T17:05:00+00:00 PythonOperator 2021-04-20T18:05:04.262285+00:00 2021-04-20T18:05:07.202911+00:00 0:00:02.940626 19348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T18:05:01.822549+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T17:00:00+00:00 EmrJobFlowSensor 2021-04-20T18:00:59.995671+00:00 2021-04-20T18:10:02.911980+00:00 0:09:02.916309 19347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T18:00:57.371576+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T18:00:37.550231+00:00 2021-04-20T18:00:39.282674+00:00 0:00:01.732443 19346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T18:00:35.349102+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T17:00:00+00:00 PythonOperator 2021-04-20T18:00:16.009103+00:00 2021-04-20T18:00:19.142598+00:00 0:00:03.133495 19345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T18:00:13.371094+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T16:00:00+00:00 EmrJobFlowSensor 2021-04-20T17:11:26.661971+00:00 2021-04-20T17:21:29.512118+00:00 0:10:02.850147 19343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T17:11:24.378607+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T16:00:00+00:00 EmrJobFlowSensor 2021-04-20T17:11:14.544967+00:00 2021-04-20T17:19:17.172615+00:00 0:08:02.627648 19342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T17:11:12.296435+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T17:11:06.417269+00:00 2021-04-20T17:11:08.111561+00:00 0:00:01.694292 19341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T17:11:04.291721+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T17:10:53.031396+00:00 2021-04-20T17:10:54.682321+00:00 0:00:01.650925 19340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T17:10:50.262603+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T16:00:00+00:00 PythonOperator 2021-04-20T17:10:44.528959+00:00 2021-04-20T17:10:47.759149+00:00 0:00:03.230190 19339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T17:10:42.249122+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T16:00:00+00:00 PythonOperator 2021-04-20T17:10:30.681033+00:00 2021-04-20T17:10:33.666117+00:00 0:00:02.985084 19338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T17:10:28.255295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T16:00:00+00:00 TriggerDagRunOperator 2021-04-20T17:10:26.656354+00:00 2021-04-20T17:10:27.157317+00:00 0:00:00.500963 19337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T17:10:24.236547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T16:00:00+00:00 TriggerDagRunOperator 2021-04-20T17:10:26.473354+00:00 2021-04-20T17:10:26.907343+00:00 0:00:00.433989 19336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T17:10:24.236519+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T16:05:00+00:00 EmrJobFlowSensor 2021-04-20T17:05:54.121942+00:00 2021-04-20T17:14:56.550079+00:00 0:09:02.428137 19335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T17:05:51.793667+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T17:05:34.014364+00:00 2021-04-20T17:05:35.696359+00:00 0:00:01.681995 19334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T17:05:31.723530+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T16:05:00+00:00 PythonOperator 2021-04-20T17:05:11.832650+00:00 2021-04-20T17:05:14.722802+00:00 0:00:02.890152 19333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T17:05:09.633477+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T16:00:00+00:00 EmrJobFlowSensor 2021-04-20T17:01:15.726862+00:00 2021-04-20T17:10:19.352259+00:00 0:09:03.625397 19332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T17:01:13.260664+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T17:00:41.313869+00:00 2021-04-20T17:00:43.144729+00:00 0:00:01.830860 19331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T17:00:39.078613+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T16:00:00+00:00 PythonOperator 2021-04-20T17:00:21.304962+00:00 2021-04-20T17:00:24.349309+00:00 0:00:03.044347 19330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T17:00:19.052860+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T15:00:00+00:00 EmrJobFlowSensor 2021-04-20T16:11:19.076482+00:00 2021-04-20T16:20:21.884943+00:00 0:09:02.808461 19328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T16:11:16.652829+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T15:00:00+00:00 EmrJobFlowSensor 2021-04-20T16:10:58.793848+00:00 2021-04-20T16:21:01.581391+00:00 0:10:02.787543 19327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T16:10:56.557861+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T16:10:56.929965+00:00 2021-04-20T16:10:58.725971+00:00 0:00:01.796006 19326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T16:10:54.558676+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T16:10:39.084811+00:00 2021-04-20T16:10:40.733586+00:00 0:00:01.648775 19325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T16:10:36.541572+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T15:00:00+00:00 PythonOperator 2021-04-20T16:10:36.741560+00:00 2021-04-20T16:10:40.431935+00:00 0:00:03.690375 19324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T16:10:34.540437+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T15:00:00+00:00 PythonOperator 2021-04-20T16:10:15.255227+00:00 2021-04-20T16:10:18.186500+00:00 0:00:02.931273 19323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T16:10:12.540926+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T15:00:00+00:00 TriggerDagRunOperator 2021-04-20T16:10:07.061115+00:00 2021-04-20T16:10:07.832756+00:00 0:00:00.771641 19322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T16:10:04.517017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T15:00:00+00:00 TriggerDagRunOperator 2021-04-20T16:10:06.849210+00:00 2021-04-20T16:10:07.242984+00:00 0:00:00.393774 19321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T16:10:04.516979+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T15:05:00+00:00 EmrJobFlowSensor 2021-04-20T16:05:50.482148+00:00 2021-04-20T16:13:52.977101+00:00 0:08:02.494953 19320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T16:05:48.265471+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T16:05:30.797615+00:00 2021-04-20T16:05:32.526852+00:00 0:00:01.729237 19319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T16:05:28.340854+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T15:05:00+00:00 PythonOperator 2021-04-20T16:05:08.287034+00:00 2021-04-20T16:05:11.179988+00:00 0:00:02.892954 19318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T16:05:06.133639+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T15:00:00+00:00 EmrJobFlowSensor 2021-04-20T16:01:00.357252+00:00 2021-04-20T16:10:03.269627+00:00 0:09:02.912375 19317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T16:00:57.885318+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T16:00:34.092622+00:00 2021-04-20T16:00:35.763892+00:00 0:00:01.671270 19316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T16:00:31.874192+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T15:00:00+00:00 PythonOperator 2021-04-20T16:00:14.767688+00:00 2021-04-20T16:00:17.750659+00:00 0:00:02.982971 19315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T16:00:11.852563+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T14:00:00+00:00 EmrJobFlowSensor 2021-04-20T15:12:19.455413+00:00 2021-04-20T15:22:22.277968+00:00 0:10:02.822555 19313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T15:12:17.056902+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T14:00:00+00:00 EmrJobFlowSensor 2021-04-20T15:12:17.367903+00:00 2021-04-20T15:22:20.186614+00:00 0:10:02.818711 19312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T15:12:15.063031+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T15:11:57.492736+00:00 2021-04-20T15:11:59.311857+00:00 0:00:01.819121 19311 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T15:11:55.058784+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T15:11:55.407469+00:00 2021-04-20T15:11:57.126948+00:00 0:00:01.719479 19310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T15:11:53.055544+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T14:00:00+00:00 PythonOperator 2021-04-20T15:11:37.195613+00:00 2021-04-20T15:11:40.396130+00:00 0:00:03.200517 19309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T15:11:34.955877+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T14:00:00+00:00 PythonOperator 2021-04-20T15:11:35.586699+00:00 2021-04-20T15:11:38.534032+00:00 0:00:02.947333 19308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T15:11:32.893118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T14:00:00+00:00 TriggerDagRunOperator 2021-04-20T15:11:27.112421+00:00 2021-04-20T15:11:27.652038+00:00 0:00:00.539617 19307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T15:11:24.850125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T14:00:00+00:00 TriggerDagRunOperator 2021-04-20T15:11:27.099479+00:00 2021-04-20T15:11:27.504004+00:00 0:00:00.404525 19306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T15:11:24.850091+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T14:05:00+00:00 EmrJobFlowSensor 2021-04-20T15:05:48.668975+00:00 2021-04-20T15:14:51.257291+00:00 0:09:02.588316 19305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T15:05:46.174877+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T15:05:26.371811+00:00 2021-04-20T15:05:28.082738+00:00 0:00:01.710927 19304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T15:05:24.164349+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T14:05:00+00:00 PythonOperator 2021-04-20T15:05:04.550490+00:00 2021-04-20T15:05:07.717227+00:00 0:00:03.166737 19303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T15:05:02.083655+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T14:00:00+00:00 EmrJobFlowSensor 2021-04-20T15:00:55.880628+00:00 2021-04-20T15:10:58.848919+00:00 0:10:02.968291 19302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T15:00:53.659084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T15:00:32.786717+00:00 2021-04-20T15:00:34.620005+00:00 0:00:01.833288 19301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T15:00:29.365772+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T14:00:00+00:00 PythonOperator 2021-04-20T15:00:11.510100+00:00 2021-04-20T15:00:14.757487+00:00 0:00:03.247387 19300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T15:00:09.170487+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T13:00:00+00:00 EmrJobFlowSensor 2021-04-20T14:10:12.003807+00:00 2021-04-20T14:30:16.195640+00:00 0:20:04.191833 19298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T14:10:09.800126+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T13:00:00+00:00 EmrJobFlowSensor 2021-04-20T14:10:04.503304+00:00 2021-04-20T14:20:07.626931+00:00 0:10:03.123627 19297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T14:10:01.862104+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T14:09:50.022828+00:00 2021-04-20T14:09:51.833566+00:00 0:00:01.810738 19296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T14:09:47.780662+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T14:09:41.930680+00:00 2021-04-20T14:09:43.587066+00:00 0:00:01.656386 19295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T14:09:39.773882+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T13:00:00+00:00 PythonOperator 2021-04-20T14:09:30.283789+00:00 2021-04-20T14:09:33.241969+00:00 0:00:02.958180 19294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T14:09:27.775024+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T13:00:00+00:00 PythonOperator 2021-04-20T14:09:21.934755+00:00 2021-04-20T14:09:25.457667+00:00 0:00:03.522912 19293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T14:09:19.757903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T13:00:00+00:00 TriggerDagRunOperator 2021-04-20T14:09:10.305074+00:00 2021-04-20T14:09:10.832752+00:00 0:00:00.527678 19292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T14:09:07.850921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T13:00:00+00:00 TriggerDagRunOperator 2021-04-20T14:09:10.174052+00:00 2021-04-20T14:09:10.581361+00:00 0:00:00.407309 19291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T14:09:07.850875+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T13:05:00+00:00 EmrJobFlowSensor 2021-04-20T14:06:05.850142+00:00 2021-04-20T14:14:08.275818+00:00 0:08:02.425676 19290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T14:06:03.467707+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T14:05:45.736591+00:00 2021-04-20T14:05:47.470124+00:00 0:00:01.733533 19289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T14:05:43.390074+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T13:05:00+00:00 PythonOperator 2021-04-20T14:05:23.513075+00:00 2021-04-20T14:05:26.814941+00:00 0:00:03.301866 19288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T14:05:21.348639+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T13:00:00+00:00 EmrJobFlowSensor 2021-04-20T14:00:54.958177+00:00 2021-04-20T14:08:57.509090+00:00 0:08:02.550913 19287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T14:00:52.765772+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T14:00:35.245099+00:00 2021-04-20T14:00:37.469941+00:00 0:00:02.224842 19286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T14:00:32.734960+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T13:00:00+00:00 PythonOperator 2021-04-20T14:00:13.120206+00:00 2021-04-20T14:00:16.323833+00:00 0:00:03.203627 19285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T14:00:10.718962+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T12:00:00+00:00 EmrJobFlowSensor 2021-04-20T13:11:30.147442+00:00 2021-04-20T13:19:32.737029+00:00 0:08:02.589587 19283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T13:11:27.646983+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T12:00:00+00:00 EmrJobFlowSensor 2021-04-20T13:11:11.742146+00:00 2021-04-20T13:21:14.637209+00:00 0:10:02.895063 19282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T13:11:09.493175+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T13:10:59.758742+00:00 2021-04-20T13:11:01.465497+00:00 0:00:01.706755 19281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T13:10:57.504670+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T13:10:44.083272+00:00 2021-04-20T13:10:45.865246+00:00 0:00:01.781974 19280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T13:10:41.466971+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T12:00:00+00:00 PythonOperator 2021-04-20T13:10:35.706831+00:00 2021-04-20T13:10:38.679144+00:00 0:00:02.972313 19279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T13:10:33.459752+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T12:00:00+00:00 PythonOperator 2021-04-20T13:10:21.658888+00:00 2021-04-20T13:10:25.134130+00:00 0:00:03.475242 19278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T13:10:19.427872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T12:00:00+00:00 TriggerDagRunOperator 2021-04-20T13:10:16.050340+00:00 2021-04-20T13:10:16.482308+00:00 0:00:00.431968 19277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T13:10:13.459523+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T12:00:00+00:00 TriggerDagRunOperator 2021-04-20T13:10:15.910842+00:00 2021-04-20T13:10:16.465023+00:00 0:00:00.554181 19276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T13:10:13.459554+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T12:05:00+00:00 EmrJobFlowSensor 2021-04-20T13:06:13.338664+00:00 2021-04-20T13:14:15.860082+00:00 0:08:02.521418 19275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T13:06:11.119014+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T13:05:51.402618+00:00 2021-04-20T13:05:53.074496+00:00 0:00:01.671878 19274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T13:05:49.161398+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T12:05:00+00:00 PythonOperator 2021-04-20T13:05:31.618032+00:00 2021-04-20T13:05:34.507313+00:00 0:00:02.889281 19273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T13:05:29.240916+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T12:00:00+00:00 EmrJobFlowSensor 2021-04-20T13:00:50.688350+00:00 2021-04-20T13:09:53.306200+00:00 0:09:02.617850 19272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T13:00:48.497567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T13:00:30.917379+00:00 2021-04-20T13:00:32.663717+00:00 0:00:01.746338 19271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T13:00:28.564889+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T12:00:00+00:00 PythonOperator 2021-04-20T13:00:08.810985+00:00 2021-04-20T13:00:12.447149+00:00 0:00:03.636164 19270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T13:00:06.413854+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T11:00:00+00:00 EmrJobFlowSensor 2021-04-20T12:15:54.152918+00:00 2021-04-20T12:27:57.131931+00:00 0:12:02.979013 19269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T12:15:51.851668+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T11:00:00+00:00 EmrJobFlowSensor 2021-04-20T12:15:32.103313+00:00 2021-04-20T12:24:34.845855+00:00 0:09:02.742542 19268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T12:15:29.746926+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T12:15:21.973615+00:00 2021-04-20T12:15:23.708348+00:00 0:00:01.734733 19267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T12:15:19.727128+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T12:14:58.027958+00:00 2021-04-20T12:14:59.695539+00:00 0:00:01.667581 19266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T12:14:55.708814+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T11:00:00+00:00 PythonOperator 2021-04-20T12:14:44.055430+00:00 2021-04-20T12:14:47.513279+00:00 0:00:03.457849 19265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T12:14:41.694182+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T11:00:00+00:00 PythonOperator 2021-04-20T12:14:34.093433+00:00 2021-04-20T12:14:37.016729+00:00 0:00:02.923296 19264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T12:14:31.683041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T11:00:00+00:00 TriggerDagRunOperator 2021-04-20T12:10:17.124257+00:00 2021-04-20T12:10:17.644594+00:00 0:00:00.520337 19262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T12:10:14.901587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T11:00:00+00:00 TriggerDagRunOperator 2021-04-20T12:10:17.061348+00:00 2021-04-20T12:10:17.464157+00:00 0:00:00.402809 19261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T12:10:14.901553+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T11:05:00+00:00 EmrJobFlowSensor 2021-04-20T12:05:56.587103+00:00 2021-04-20T12:14:59.363271+00:00 0:09:02.776168 19260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T12:05:54.408060+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T12:05:32.525995+00:00 2021-04-20T12:05:34.177314+00:00 0:00:01.651319 19259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T12:05:30.382825+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T11:05:00+00:00 PythonOperator 2021-04-20T12:05:08.774437+00:00 2021-04-20T12:05:11.687051+00:00 0:00:02.912614 19258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T12:05:06.340821+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T11:00:00+00:00 EmrJobFlowSensor 2021-04-20T12:00:57.941695+00:00 2021-04-20T12:10:01.274380+00:00 0:09:03.332685 19257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T12:00:55.806470+00:00 2 default_pool