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 trigger_dagrun_booking-processing-job_v002 2021-04-12T17:00:00+00:00 TriggerDagRunOperator 2021-04-12T18:08:59.565343+00:00 2021-04-12T18:09:00.087049+00:00 0:00:00.521706 16448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:08:57.135727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T17:00:00+00:00 TriggerDagRunOperator 2021-04-12T18:08:59.435741+00:00 2021-04-12T18:08:59.867141+00:00 0:00:00.431400 16447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:08:57.135695+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T17:05:00+00:00 EmrJobFlowSensor 2021-04-12T18:06:14.981657+00:00 2021-04-12T18:15:17.678700+00:00 0:09:02.697043 16446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:06:12.813017+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:05:55.059239+00:00 2021-04-12T18:05:56.681283+00:00 0:00:01.622044 16445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T18:05:52.794975+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T17:05:00+00:00 PythonOperator 2021-04-12T18:05:24.976025+00:00 2021-04-12T18:05:27.746994+00:00 0:00:02.770969 16444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:05:22.769133+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T17:00:00+00:00 EmrJobFlowSensor 2021-04-12T18:00:46.664462+00:00 2021-04-12T18:08:49.295853+00:00 0:08:02.631391 16443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:00:44.367538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:00:26.515590+00:00 2021-04-12T18:00:28.301798+00:00 0:00:01.786208 16442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T18:00:24.295528+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T17:00:00+00:00 PythonOperator 2021-04-12T18:00:04.564059+00:00 2021-04-12T18:00:07.339899+00:00 0:00:02.775840 16441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T18:00:02.214194+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:12:11.049197+00:00 2021-04-12T17:21:13.699946+00:00 0:09:02.650749 16439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:12:08.891513+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:12:07.037750+00:00 2021-04-12T17:21:09.725126+00:00 0:09:02.687376 16438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:12:04.887170+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:11:48.999866+00:00 2021-04-12T17:11:50.639283+00:00 0:00:01.639417 16437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:11:46.796360+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:11:45.317904+00:00 2021-04-12T17:11:47.014783+00:00 0:00:01.696879 16436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:11:42.851041+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:11:27.034139+00:00 2021-04-12T17:11:29.729697+00:00 0:00:02.695558 16435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:11:24.767290+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:11:25.194661+00:00 2021-04-12T17:11:28.349244+00:00 0:00:03.154583 16434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:11:22.767775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T16:00:00+00:00 TriggerDagRunOperator 2021-04-12T17:11:10.910959+00:00 2021-04-12T17:11:11.316629+00:00 0:00:00.405670 16433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:11:08.690641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T16:00:00+00:00 TriggerDagRunOperator 2021-04-12T17:11:10.919404+00:00 2021-04-12T17:11:11.464392+00:00 0:00:00.544988 16432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:11:08.690678+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T16:05:00+00:00 EmrJobFlowSensor 2021-04-12T17:05:58.502918+00:00 2021-04-12T17:15:01.179260+00:00 0:09:02.676342 16431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:05:56.104040+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:05:36.845938+00:00 2021-04-12T17:05:38.633370+00:00 0:00:01.787432 16430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:05:34.090414+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T16:05:00+00:00 PythonOperator 2021-04-12T17:05:08.335149+00:00 2021-04-12T17:05:11.006528+00:00 0:00:02.671379 16429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:05:06.048902+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:00:55.755059+00:00 2021-04-12T17:10:58.469341+00:00 0:10:02.714282 16428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:00:53.583213+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:00:33.858864+00:00 2021-04-12T17:00:35.773891+00:00 0:00:01.915027 16427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T17:00:31.553256+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:00:11.819539+00:00 2021-04-12T17:00:14.522780+00:00 0:00:02.703241 16426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T17:00:09.537740+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T15:00:00+00:00 EmrJobFlowSensor 2021-04-12T16:13:21.942842+00:00 2021-04-12T16:22:24.650414+00:00 0:09:02.707572 16424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:13:19.694097+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:12:59.907991+00:00 2021-04-12T16:13:01.684788+00:00 0:00:01.776797 16423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T16:12:57.651085+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T15:00:00+00:00 EmrJobFlowSensor 2021-04-12T16:12:27.798713+00:00 2021-04-12T16:22:30.534895+00:00 0:10:02.736182 16422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:12:25.608544+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:12:04.155539+00:00 2021-04-12T16:12:05.995424+00:00 0:00:01.839885 16421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T16:12:01.652379+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T15:00:00+00:00 PythonOperator 2021-04-12T16:11:45.891762+00:00 2021-04-12T16:11:48.724647+00:00 0:00:02.832885 16420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:11:43.563539+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T15:00:00+00:00 PythonOperator 2021-04-12T16:11:41.714242+00:00 2021-04-12T16:11:44.919444+00:00 0:00:03.205202 16419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:11:39.562567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T15:00:00+00:00 TriggerDagRunOperator 2021-04-12T16:11:18.086995+00:00 2021-04-12T16:11:18.656028+00:00 0:00:00.569033 16418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:11:15.544380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T15:00:00+00:00 TriggerDagRunOperator 2021-04-12T16:11:17.887732+00:00 2021-04-12T16:11:18.286858+00:00 0:00:00.399126 16417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:11:15.544349+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T15:05:00+00:00 EmrJobFlowSensor 2021-04-12T16:07:03.563706+00:00 2021-04-12T16:16:06.314162+00:00 0:09:02.750456 16416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:07:01.275427+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:06:43.375072+00:00 2021-04-12T16:06:45.751509+00:00 0:00:02.376437 16415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T16:06:41.212131+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T15:05:00+00:00 PythonOperator 2021-04-12T16:06:21.365778+00:00 2021-04-12T16:06:24.199466+00:00 0:00:02.833688 16414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:06:19.194186+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T15:00:00+00:00 EmrJobFlowSensor 2021-04-12T16:00:59.128922+00:00 2021-04-12T16:11:01.989928+00:00 0:10:02.861006 16413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:00:56.632061+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:00:36.822035+00:00 2021-04-12T16:00:38.532956+00:00 0:00:01.710921 16412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T16:00:34.614781+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T15:00:00+00:00 PythonOperator 2021-04-12T16:00:15.010129+00:00 2021-04-12T16:00:17.784138+00:00 0:00:02.774009 16411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T16:00:12.598565+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T14:00:00+00:00 EmrJobFlowSensor 2021-04-12T15:11:29.140065+00:00 2021-04-12T15:21:31.993547+00:00 0:10:02.853482 16409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:11:26.773544+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T14:00:00+00:00 EmrJobFlowSensor 2021-04-12T15:11:11.002700+00:00 2021-04-12T15:19:13.581597+00:00 0:08:02.578897 16408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:11:08.704721+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T15:11:07.090736+00:00 2021-04-12T15:11:08.768762+00:00 0:00:01.678026 16407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T15:11:04.745246+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T15:10:50.903701+00:00 2021-04-12T15:10:52.695728+00:00 0:00:01.792027 16406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T15:10:48.683039+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T14:00:00+00:00 PythonOperator 2021-04-12T15:10:44.993477+00:00 2021-04-12T15:10:48.355433+00:00 0:00:03.361956 16405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T15:10:42.673686+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T14:00:00+00:00 PythonOperator 2021-04-12T15:10:28.981387+00:00 2021-04-12T15:10:31.689131+00:00 0:00:02.707744 16404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T15:10:26.660695+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T14:00:00+00:00 TriggerDagRunOperator 2021-04-12T15:10:21.013794+00:00 2021-04-12T15:10:21.540395+00:00 0:00:00.526601 16403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:10:18.656850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T14:00:00+00:00 TriggerDagRunOperator 2021-04-12T15:10:20.914183+00:00 2021-04-12T15:10:21.312743+00:00 0:00:00.398560 16402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:10:18.656803+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T14:05:00+00:00 EmrJobFlowSensor 2021-04-12T15:06:08.921989+00:00 2021-04-12T15:15:11.500792+00:00 0:09:02.578803 16401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:06:06.289410+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T15:05:46.281833+00:00 2021-04-12T15:05:47.936463+00:00 0:00:01.654630 16400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T15:05:44.201119+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T14:05:00+00:00 PythonOperator 2021-04-12T15:05:20.257441+00:00 2021-04-12T15:05:23.179482+00:00 0:00:02.922041 16399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T15:05:18.062878+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T14:00:00+00:00 EmrJobFlowSensor 2021-04-12T15:01:04.372665+00:00 2021-04-12T15:10:07.226740+00:00 0:09:02.854075 16398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T15:01:01.747007+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T15:00:34.263339+00:00 2021-04-12T15:00:35.958605+00:00 0:00:01.695266 16397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T15:00:31.662894+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T14:00:00+00:00 PythonOperator 2021-04-12T15:00:10.152503+00:00 2021-04-12T15:00:12.986429+00:00 0:00:02.833926 16396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T15:00:07.626533+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T13:00:00+00:00 EmrJobFlowSensor 2021-04-12T14:11:40.270037+00:00 2021-04-12T14:20:42.912987+00:00 0:09:02.642950 16394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T14:11:37.740328+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T13:00:00+00:00 EmrJobFlowSensor 2021-04-12T14:11:38.045682+00:00 2021-04-12T14:20:40.812946+00:00 0:09:02.767264 16393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T14:11:35.743860+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T14:11:14.171072+00:00 2021-04-12T14:11:16.028907+00:00 0:00:01.857835 16392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T14:11:11.717293+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T14:11:14.069191+00:00 2021-04-12T14:11:15.817044+00:00 0:00:01.747853 16391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T14:11:11.717321+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T13:00:00+00:00 PythonOperator 2021-04-12T14:10:53.833998+00:00 2021-04-12T14:10:57.151901+00:00 0:00:03.317903 16390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T14:10:51.702151+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T13:00:00+00:00 PythonOperator 2021-04-12T14:10:51.964468+00:00 2021-04-12T14:10:54.767079+00:00 0:00:02.802611 16389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T14:10:49.699064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T13:00:00+00:00 TriggerDagRunOperator 2021-04-12T14:10:34.316753+00:00 2021-04-12T14:10:34.834893+00:00 0:00:00.518140 16388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T14:10:31.685888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T13:00:00+00:00 TriggerDagRunOperator 2021-04-12T14:10:34.188804+00:00 2021-04-12T14:10:34.621715+00:00 0:00:00.432911 16387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T14:10:31.685854+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T13:05:00+00:00 EmrJobFlowSensor 2021-04-12T14:05:57.490732+00:00 2021-04-12T14:15:00.091414+00:00 0:09:02.600682 16386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T14:05:55.314464+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T14:05:37.392859+00:00 2021-04-12T14:05:39.032956+00:00 0:00:01.640097 16385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T14:05:35.301075+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T13:05:00+00:00 PythonOperator 2021-04-12T14:05:15.612229+00:00 2021-04-12T14:05:18.334909+00:00 0:00:02.722680 16384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T14:05:13.352179+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T13:00:00+00:00 EmrJobFlowSensor 2021-04-12T14:01:06.959519+00:00 2021-04-12T14:10:09.634496+00:00 0:09:02.674977 16383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T14:01:04.694000+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T14:00:44.839604+00:00 2021-04-12T14:00:46.536982+00:00 0:00:01.697378 16382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T14:00:42.604770+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T13:00:00+00:00 PythonOperator 2021-04-12T14:00:19.541044+00:00 2021-04-12T14:00:22.610240+00:00 0:00:03.069196 16381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T14:00:16.653046+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T12:00:00+00:00 EmrJobFlowSensor 2021-04-12T13:12:28.474800+00:00 2021-04-12T13:22:31.191143+00:00 0:10:02.716343 16379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T13:12:26.143426+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T12:00:00+00:00 EmrJobFlowSensor 2021-04-12T13:12:14.335027+00:00 2021-04-12T13:22:17.091758+00:00 0:10:02.756731 16378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T13:12:12.083262+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T13:12:06.427059+00:00 2021-04-12T13:12:08.161787+00:00 0:00:01.734728 16377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T13:12:04.067396+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T13:11:52.314234+00:00 2021-04-12T13:11:54.006133+00:00 0:00:01.691899 16376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T13:11:50.055711+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T12:00:00+00:00 PythonOperator 2021-04-12T13:11:46.199375+00:00 2021-04-12T13:11:48.944663+00:00 0:00:02.745288 16375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T13:11:44.050864+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T12:00:00+00:00 PythonOperator 2021-04-12T13:11:30.303393+00:00 2021-04-12T13:11:33.364579+00:00 0:00:03.061186 16374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T13:11:28.050866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T12:00:00+00:00 TriggerDagRunOperator 2021-04-12T13:11:24.482224+00:00 2021-04-12T13:11:25.005263+00:00 0:00:00.523039 16373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T13:11:22.030996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T12:00:00+00:00 TriggerDagRunOperator 2021-04-12T13:11:24.298425+00:00 2021-04-12T13:11:24.739902+00:00 0:00:00.441477 16372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T13:11:22.031030+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T12:05:00+00:00 EmrJobFlowSensor 2021-04-12T13:05:47.935038+00:00 2021-04-12T13:14:50.698448+00:00 0:09:02.763410 16371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T13:05:45.646486+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T13:05:25.853861+00:00 2021-04-12T13:05:27.534044+00:00 0:00:01.680183 16370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T13:05:23.658089+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T12:05:00+00:00 PythonOperator 2021-04-12T13:05:04.064453+00:00 2021-04-12T13:05:06.873105+00:00 0:00:02.808652 16369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T13:05:01.672705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T12:00:00+00:00 EmrJobFlowSensor 2021-04-12T13:01:05.484706+00:00 2021-04-12T13:11:08.221048+00:00 0:10:02.736342 16368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T13:01:03.201212+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T13:00:41.370033+00:00 2021-04-12T13:00:43.068885+00:00 0:00:01.698852 16367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T13:00:39.164881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T12:00:00+00:00 PythonOperator 2021-04-12T13:00:21.532712+00:00 2021-04-12T13:00:24.262191+00:00 0:00:02.729479 16366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T13:00:19.090984+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T11:00:00+00:00 EmrJobFlowSensor 2021-04-12T12:12:16.712055+00:00 2021-04-12T12:22:19.431673+00:00 0:10:02.719618 16364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T12:12:14.506058+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T11:00:00+00:00 EmrJobFlowSensor 2021-04-12T12:12:12.728974+00:00 2021-04-12T12:21:15.499860+00:00 0:09:02.770886 16363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T12:12:10.500479+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T12:11:56.719757+00:00 2021-04-12T12:11:58.409020+00:00 0:00:01.689263 16362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T12:11:54.497916+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T12:11:52.806805+00:00 2021-04-12T12:11:54.597731+00:00 0:00:01.790926 16361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T12:11:50.466332+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T11:00:00+00:00 PythonOperator 2021-04-12T12:11:34.769975+00:00 2021-04-12T12:11:37.815092+00:00 0:00:03.045117 16360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T12:11:32.445810+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T11:00:00+00:00 PythonOperator 2021-04-12T12:11:31.206095+00:00 2021-04-12T12:11:34.215270+00:00 0:00:03.009175 16359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T12:11:28.542443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T11:00:00+00:00 TriggerDagRunOperator 2021-04-12T12:11:19.041895+00:00 2021-04-12T12:11:19.572817+00:00 0:00:00.530922 16358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T12:11:16.435204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T11:00:00+00:00 TriggerDagRunOperator 2021-04-12T12:11:18.681481+00:00 2021-04-12T12:11:19.139834+00:00 0:00:00.458353 16357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T12:11:16.435237+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T11:05:00+00:00 EmrJobFlowSensor 2021-04-12T12:06:06.304827+00:00 2021-04-12T12:14:08.830491+00:00 0:08:02.525664 16356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T12:06:04.092722+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T12:05:46.200784+00:00 2021-04-12T12:05:47.859701+00:00 0:00:01.658917 16355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T12:05:44.026507+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T11:05:00+00:00 PythonOperator 2021-04-12T12:05:24.539371+00:00 2021-04-12T12:05:27.215567+00:00 0:00:02.676196 16354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T12:05:22.063595+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T11:00:00+00:00 EmrJobFlowSensor 2021-04-12T12:01:00.377283+00:00 2021-04-12T12:11:03.288668+00:00 0:10:02.911385 16353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T12:00:57.763058+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T12:00:40.176052+00:00 2021-04-12T12:00:41.984704+00:00 0:00:01.808652 16352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T12:00:37.648883+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T11:00:00+00:00 PythonOperator 2021-04-12T12:00:17.787108+00:00 2021-04-12T12:00:20.515405+00:00 0:00:02.728297 16351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T12:00:15.521501+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T10:00:00+00:00 EmrJobFlowSensor 2021-04-12T11:12:28.312411+00:00 2021-04-12T11:24:31.213244+00:00 0:12:02.900833 16349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T11:12:26.116323+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T10:00:00+00:00 EmrJobFlowSensor 2021-04-12T11:12:16.317492+00:00 2021-04-12T11:21:19.031515+00:00 0:09:02.714023 16348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T11:12:14.106778+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T11:12:06.542096+00:00 2021-04-12T11:12:08.268967+00:00 0:00:01.726871 16347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T11:12:04.151857+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T11:11:54.737692+00:00 2021-04-12T11:11:56.731180+00:00 0:00:01.993488 16346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T11:11:52.083553+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T10:00:00+00:00 PythonOperator 2021-04-12T11:11:44.340170+00:00 2021-04-12T11:11:47.358776+00:00 0:00:03.018606 16345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T11:11:42.045837+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T10:00:00+00:00 PythonOperator 2021-04-12T11:11:34.647498+00:00 2021-04-12T11:11:37.384972+00:00 0:00:02.737474 16344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T11:11:32.039027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T10:00:00+00:00 TriggerDagRunOperator 2021-04-12T11:11:22.541994+00:00 2021-04-12T11:11:23.099967+00:00 0:00:00.557973 16343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T11:11:20.035272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T10:00:00+00:00 TriggerDagRunOperator 2021-04-12T11:11:22.299451+00:00 2021-04-12T11:11:22.710456+00:00 0:00:00.411005 16342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T11:11:20.035238+00:00 2 default_pool