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-flow-job_v002 create_emr_steps 2021-04-09T15:00:00+00:00 PythonOperator 2021-04-09T16:08:34.524150+00:00 2021-04-09T16:08:37.331113+00:00 0:00:02.806963 15331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T16:08:31.439296+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T14:00:00+00:00 EmrJobFlowSensor 2021-04-09T15:12:16.107437+00:00 2021-04-09T15:22:18.857237+00:00 0:10:02.749800 15329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:12:13.844247+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T14:00:00+00:00 EmrJobFlowSensor 2021-04-09T15:12:12.376021+00:00 2021-04-09T15:21:15.259545+00:00 0:09:02.883524 15328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:12:09.840663+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:11:54.395390+00:00 2021-04-09T15:11:56.084119+00:00 0:00:01.688729 15327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T15:11:51.875390+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:11:50.454319+00:00 2021-04-09T15:11:52.197166+00:00 0:00:01.742847 15326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T15:11:47.875194+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T14:00:00+00:00 PythonOperator 2021-04-09T15:11:30.216236+00:00 2021-04-09T15:11:33.185564+00:00 0:00:02.969328 15325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:11:27.869876+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T14:00:00+00:00 PythonOperator 2021-04-09T15:11:16.460130+00:00 2021-04-09T15:11:19.296608+00:00 0:00:02.836478 15324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:11:13.807433+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T14:00:00+00:00 TriggerDagRunOperator 2021-04-09T15:11:06.106027+00:00 2021-04-09T15:11:06.667743+00:00 0:00:00.561716 15323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:11:03.800947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T14:00:00+00:00 TriggerDagRunOperator 2021-04-09T15:11:06.085162+00:00 2021-04-09T15:11:06.572734+00:00 0:00:00.487572 15322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:11:03.800893+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T14:05:00+00:00 EmrJobFlowSensor 2021-04-09T15:05:55.831606+00:00 2021-04-09T15:13:58.328861+00:00 0:08:02.497255 15321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:05:53.462871+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:05:35.698012+00:00 2021-04-09T15:05:37.423232+00:00 0:00:01.725220 15320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T15:05:33.393652+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T14:05:00+00:00 PythonOperator 2021-04-09T15:05:13.466757+00:00 2021-04-09T15:05:16.383430+00:00 0:00:02.916673 15319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:05:11.284733+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T14:00:00+00:00 EmrJobFlowSensor 2021-04-09T15:00:49.214916+00:00 2021-04-09T15:10:52.081135+00:00 0:10:02.866219 15318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:00:46.784833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:00:29.053646+00:00 2021-04-09T15:00:30.888915+00:00 0:00:01.835269 15317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T15:00:26.734790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T14:00:00+00:00 PythonOperator 2021-04-09T15:00:07.535390+00:00 2021-04-09T15:00:10.586560+00:00 0:00:03.051170 15316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T15:00:04.712384+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T13:00:00+00:00 EmrJobFlowSensor 2021-04-09T14:12:06.806313+00:00 2021-04-09T14:22:09.645004+00:00 0:10:02.838691 15314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:12:04.454708+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T13:00:00+00:00 EmrJobFlowSensor 2021-04-09T14:11:52.677255+00:00 2021-04-09T14:21:55.561797+00:00 0:10:02.884542 15313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:11:50.330164+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:11:44.606780+00:00 2021-04-09T14:11:46.275343+00:00 0:00:01.668563 15312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T14:11:42.321739+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:11:30.899135+00:00 2021-04-09T14:11:32.580070+00:00 0:00:01.680935 15311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T14:11:28.468852+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T13:00:00+00:00 PythonOperator 2021-04-09T14:11:24.719629+00:00 2021-04-09T14:11:27.539552+00:00 0:00:02.819923 15310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:11:22.303107+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T13:00:00+00:00 PythonOperator 2021-04-09T14:11:10.605800+00:00 2021-04-09T14:11:13.794960+00:00 0:00:03.189160 15309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:11:08.289964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T13:00:00+00:00 TriggerDagRunOperator 2021-04-09T14:11:04.673178+00:00 2021-04-09T14:11:05.215760+00:00 0:00:00.542582 15308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:11:02.287389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T13:00:00+00:00 TriggerDagRunOperator 2021-04-09T14:11:04.611048+00:00 2021-04-09T14:11:05.031089+00:00 0:00:00.420041 15307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:11:02.287434+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T13:05:00+00:00 EmrJobFlowSensor 2021-04-09T14:05:46.050128+00:00 2021-04-09T14:13:48.563954+00:00 0:08:02.513826 15306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:05:43.759850+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:05:26.093652+00:00 2021-04-09T14:05:27.941974+00:00 0:00:01.848322 15305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T14:05:23.750979+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T13:05:00+00:00 PythonOperator 2021-04-09T14:05:03.855362+00:00 2021-04-09T14:05:06.550481+00:00 0:00:02.695119 15304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:05:01.711163+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T13:00:00+00:00 EmrJobFlowSensor 2021-04-09T14:00:57.513969+00:00 2021-04-09T14:11:00.290016+00:00 0:10:02.776047 15303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:00:55.299743+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:00:35.778543+00:00 2021-04-09T14:00:37.493871+00:00 0:00:01.715328 15302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T14:00:33.288842+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T13:00:00+00:00 PythonOperator 2021-04-09T14:00:13.617261+00:00 2021-04-09T14:00:16.512679+00:00 0:00:02.895418 15301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T14:00:11.220087+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T12:00:00+00:00 EmrJobFlowSensor 2021-04-09T13:12:30.454091+00:00 2021-04-09T13:22:33.281134+00:00 0:10:02.827043 15299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T13:12:27.894615+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T12:00:00+00:00 EmrJobFlowSensor 2021-04-09T13:12:28.290957+00:00 2021-04-09T13:23:31.387828+00:00 0:11:03.096871 15298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T13:12:25.883978+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T13:12:08.233819+00:00 2021-04-09T13:12:10.049320+00:00 0:00:01.815501 15297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T13:12:05.818793+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T13:12:08.138805+00:00 2021-04-09T13:12:09.976082+00:00 0:00:01.837277 15296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T13:12:05.818827+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T12:00:00+00:00 PythonOperator 2021-04-09T13:11:48.150561+00:00 2021-04-09T13:11:50.850988+00:00 0:00:02.700427 15295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T13:11:45.798259+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T12:00:00+00:00 PythonOperator 2021-04-09T13:11:46.201715+00:00 2021-04-09T13:11:49.288043+00:00 0:00:03.086328 15294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T13:11:43.797987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T12:00:00+00:00 TriggerDagRunOperator 2021-04-09T13:11:22.062000+00:00 2021-04-09T13:11:22.689643+00:00 0:00:00.627643 15293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T13:11:19.734800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T12:00:00+00:00 TriggerDagRunOperator 2021-04-09T13:11:22.016637+00:00 2021-04-09T13:11:22.416943+00:00 0:00:00.400306 15292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T13:11:19.734772+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T12:05:00+00:00 EmrJobFlowSensor 2021-04-09T13:05:53.287993+00:00 2021-04-09T13:13:55.724842+00:00 0:08:02.436849 15291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T13:05:51.123418+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T13:05:31.283281+00:00 2021-04-09T13:05:32.989650+00:00 0:00:01.706369 15290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T13:05:29.105209+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T12:05:00+00:00 PythonOperator 2021-04-09T13:05:11.204345+00:00 2021-04-09T13:05:13.945894+00:00 0:00:02.741549 15289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T13:05:09.087333+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T12:00:00+00:00 EmrJobFlowSensor 2021-04-09T13:01:02.904624+00:00 2021-04-09T13:11:05.772717+00:00 0:10:02.868093 15288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T13:01:00.588824+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T13:00:40.808260+00:00 2021-04-09T13:00:42.588141+00:00 0:00:01.779881 15287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T13:00:38.577123+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T12:00:00+00:00 PythonOperator 2021-04-09T13:00:18.970785+00:00 2021-04-09T13:00:21.848020+00:00 0:00:02.877235 15286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T13:00:16.501153+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T11:00:00+00:00 EmrJobFlowSensor 2021-04-09T12:10:15.876709+00:00 2021-04-09T12:20:18.572167+00:00 0:10:02.695458 15284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T12:10:13.461197+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T11:00:00+00:00 EmrJobFlowSensor 2021-04-09T12:10:09.860621+00:00 2021-04-09T12:18:12.440872+00:00 0:08:02.580251 15283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T12:10:07.489908+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T12:09:53.754235+00:00 2021-04-09T12:09:55.630572+00:00 0:00:01.876337 15282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T12:09:51.407734+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T12:09:48.233066+00:00 2021-04-09T12:09:49.946086+00:00 0:00:01.713020 15281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T12:09:45.475360+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T11:00:00+00:00 PythonOperator 2021-04-09T12:09:31.923079+00:00 2021-04-09T12:09:35.065757+00:00 0:00:03.142678 15280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T12:09:29.362163+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T11:00:00+00:00 PythonOperator 2021-04-09T12:09:27.752531+00:00 2021-04-09T12:09:30.700522+00:00 0:00:02.947991 15279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T12:09:25.269889+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T11:00:00+00:00 TriggerDagRunOperator 2021-04-09T12:09:21.574147+00:00 2021-04-09T12:09:22.043435+00:00 0:00:00.469288 15278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T12:09:19.199429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T11:00:00+00:00 TriggerDagRunOperator 2021-04-09T12:09:21.496148+00:00 2021-04-09T12:09:22.033878+00:00 0:00:00.537730 15277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T12:09:19.199391+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T11:05:00+00:00 EmrJobFlowSensor 2021-04-09T12:05:57.101046+00:00 2021-04-09T12:14:59.593396+00:00 0:09:02.492350 15276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T12:05:54.886740+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T12:05:30.976789+00:00 2021-04-09T12:05:32.662106+00:00 0:00:01.685317 15275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T12:05:28.833192+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T11:05:00+00:00 PythonOperator 2021-04-09T12:05:08.989832+00:00 2021-04-09T12:05:11.641986+00:00 0:00:02.652154 15274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T12:05:06.818840+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T11:00:00+00:00 EmrJobFlowSensor 2021-04-09T12:01:00.852703+00:00 2021-04-09T12:09:03.417768+00:00 0:08:02.565065 15273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T12:00:58.453271+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T12:00:38.829211+00:00 2021-04-09T12:00:40.534298+00:00 0:00:01.705087 15272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T12:00:36.367976+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T11:00:00+00:00 PythonOperator 2021-04-09T12:00:16.841200+00:00 2021-04-09T12:00:19.691478+00:00 0:00:02.850278 15271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T12:00:14.366310+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T10:00:00+00:00 EmrJobFlowSensor 2021-04-09T11:11:40.334372+00:00 2021-04-09T11:20:43.055502+00:00 0:09:02.721130 15269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:11:37.567456+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T10:00:00+00:00 EmrJobFlowSensor 2021-04-09T11:11:31.911631+00:00 2021-04-09T11:19:34.531703+00:00 0:08:02.620072 15268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:11:29.569004+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T11:11:20.244664+00:00 2021-04-09T11:11:22.080685+00:00 0:00:01.836021 15267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T11:11:17.754669+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T11:11:10.034155+00:00 2021-04-09T11:11:11.714105+00:00 0:00:01.679950 15266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T11:11:07.458267+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T10:00:00+00:00 PythonOperator 2021-04-09T11:10:57.624995+00:00 2021-04-09T11:11:00.555464+00:00 0:00:02.930469 15265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:10:55.446612+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T10:00:00+00:00 PythonOperator 2021-04-09T11:10:49.907284+00:00 2021-04-09T11:10:52.760564+00:00 0:00:02.853280 15264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:10:47.439872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T10:00:00+00:00 TriggerDagRunOperator 2021-04-09T11:10:40.090855+00:00 2021-04-09T11:10:40.547283+00:00 0:00:00.456428 15263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:10:37.434516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T10:00:00+00:00 TriggerDagRunOperator 2021-04-09T11:10:40.090632+00:00 2021-04-09T11:10:40.659770+00:00 0:00:00.569138 15262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:10:37.434480+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T10:05:00+00:00 EmrJobFlowSensor 2021-04-09T11:05:53.442856+00:00 2021-04-09T11:14:56.048154+00:00 0:09:02.605298 15261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:05:51.063457+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T11:05:33.537227+00:00 2021-04-09T11:05:35.290827+00:00 0:00:01.753600 15260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T11:05:31.150327+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T10:05:00+00:00 PythonOperator 2021-04-09T11:05:11.029146+00:00 2021-04-09T11:05:13.739396+00:00 0:00:02.710250 15259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:05:08.876389+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T10:00:00+00:00 EmrJobFlowSensor 2021-04-09T11:01:13.087601+00:00 2021-04-09T11:10:15.905736+00:00 0:09:02.818135 15258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:01:10.572700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T11:00:42.771129+00:00 2021-04-09T11:00:44.532153+00:00 0:00:01.761024 15257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T11:00:40.499295+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T10:00:00+00:00 PythonOperator 2021-04-09T11:00:19.018399+00:00 2021-04-09T11:00:21.841059+00:00 0:00:02.822660 15256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T11:00:16.409727+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T09:00:00+00:00 EmrJobFlowSensor 2021-04-09T10:11:32.625609+00:00 2021-04-09T10:21:35.296469+00:00 0:10:02.670860 15254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:11:29.751291+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T09:00:00+00:00 EmrJobFlowSensor 2021-04-09T10:11:30.215123+00:00 2021-04-09T10:20:33.099162+00:00 0:09:02.884039 15253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:11:27.740706+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:11:10.520107+00:00 2021-04-09T10:11:12.248433+00:00 0:00:01.728326 15252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T10:11:07.579886+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:11:08.149176+00:00 2021-04-09T10:11:10.239365+00:00 0:00:02.090189 15251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T10:11:05.575577+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T09:00:00+00:00 PythonOperator 2021-04-09T10:10:47.851058+00:00 2021-04-09T10:10:50.813422+00:00 0:00:02.962364 15250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:10:45.499419+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T09:00:00+00:00 PythonOperator 2021-04-09T10:10:47.739566+00:00 2021-04-09T10:10:50.762353+00:00 0:00:03.022787 15249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:10:45.499385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T09:00:00+00:00 TriggerDagRunOperator 2021-04-09T10:10:28.085789+00:00 2021-04-09T10:10:28.617363+00:00 0:00:00.531574 15248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:10:25.482998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T09:00:00+00:00 TriggerDagRunOperator 2021-04-09T10:10:27.923973+00:00 2021-04-09T10:10:28.309864+00:00 0:00:00.385891 15247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:10:25.483027+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T09:05:00+00:00 EmrJobFlowSensor 2021-04-09T10:06:03.351056+00:00 2021-04-09T10:15:06.055989+00:00 0:09:02.704933 15246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:06:01.036082+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:05:39.456922+00:00 2021-04-09T10:05:41.137807+00:00 0:00:01.680885 15245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T10:05:37.083244+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T09:05:00+00:00 PythonOperator 2021-04-09T10:05:17.326642+00:00 2021-04-09T10:05:20.148520+00:00 0:00:02.821878 15244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:05:15.056161+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T09:00:00+00:00 EmrJobFlowSensor 2021-04-09T10:01:06.879768+00:00 2021-04-09T10:10:09.552830+00:00 0:09:02.673062 15243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:01:04.443776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:00:42.722020+00:00 2021-04-09T10:00:44.542082+00:00 0:00:01.820062 15242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T10:00:40.423159+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T09:00:00+00:00 PythonOperator 2021-04-09T10:00:22.722811+00:00 2021-04-09T10:00:25.505018+00:00 0:00:02.782207 15241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T10:00:20.411017+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T08:00:00+00:00 EmrJobFlowSensor 2021-04-09T09:11:21.580725+00:00 2021-04-09T09:21:24.393801+00:00 0:10:02.813076 15239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:11:19.074844+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T08:00:00+00:00 EmrJobFlowSensor 2021-04-09T09:11:19.400994+00:00 2021-04-09T09:20:22.146622+00:00 0:09:02.745628 15238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:11:17.063124+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:11:01.956564+00:00 2021-04-09T09:11:03.899087+00:00 0:00:01.942523 15237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T09:10:59.378398+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:10:59.324052+00:00 2021-04-09T09:11:01.246681+00:00 0:00:01.922629 15236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T09:10:56.607796+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T08:00:00+00:00 PythonOperator 2021-04-09T09:10:38.924969+00:00 2021-04-09T09:10:41.958749+00:00 0:00:03.033780 15235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:10:36.644078+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T08:00:00+00:00 PythonOperator 2021-04-09T09:10:37.055401+00:00 2021-04-09T09:10:39.789091+00:00 0:00:02.733690 15234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:10:34.650527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T08:00:00+00:00 TriggerDagRunOperator 2021-04-09T09:10:17.032487+00:00 2021-04-09T09:10:17.457444+00:00 0:00:00.424957 15233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:10:14.523618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T08:00:00+00:00 TriggerDagRunOperator 2021-04-09T09:10:17.046331+00:00 2021-04-09T09:10:17.602514+00:00 0:00:00.556183 15232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:10:14.523654+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T08:05:00+00:00 EmrJobFlowSensor 2021-04-09T09:05:54.330485+00:00 2021-04-09T09:14:56.955439+00:00 0:09:02.624954 15231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:05:52.021666+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:05:34.225113+00:00 2021-04-09T09:05:35.908506+00:00 0:00:01.683393 15230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T09:05:32.005314+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T08:05:00+00:00 PythonOperator 2021-04-09T09:05:12.074300+00:00 2021-04-09T09:05:14.735452+00:00 0:00:02.661152 15229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:05:09.983425+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T08:00:00+00:00 EmrJobFlowSensor 2021-04-09T09:00:55.902274+00:00 2021-04-09T09:09:58.686677+00:00 0:09:02.784403 15228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:00:53.521297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:00:31.925006+00:00 2021-04-09T09:00:33.614555+00:00 0:00:01.689549 15227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T09:00:29.560469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T08:00:00+00:00 PythonOperator 2021-04-09T09:00:10.115129+00:00 2021-04-09T09:00:12.868951+00:00 0:00:02.753822 15226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T09:00:07.469512+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T07:00:00+00:00 EmrJobFlowSensor 2021-04-09T08:10:29.128645+00:00 2021-04-09T08:19:31.919801+00:00 0:09:02.791156 15224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T08:10:26.834282+00:00 2 default_pool