Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 check_cluster_status 2021-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
success vc-asset-import_v002 check_cluster_status 2021-04-12T10:05:00+00:00 EmrJobFlowSensor 2021-04-12T11:05:49.775572+00:00 2021-04-12T11:13:52.290652+00:00 0:08:02.515080 16341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T11:05:47.597605+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T11:05:27.765024+00:00 2021-04-12T11:05:29.507003+00:00 0:00:01.741979 16340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T11:05:25.545251+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T10:05:00+00:00 PythonOperator 2021-04-12T11:05:05.845885+00:00 2021-04-12T11:05:08.504049+00:00 0:00:02.658164 16339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T11:05:03.569779+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T10:00:00+00:00 EmrJobFlowSensor 2021-04-12T11:00:57.223363+00:00 2021-04-12T11:10:59.915618+00:00 0:10:02.692255 16338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T11:00:55.106121+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T11:00:37.345904+00:00 2021-04-12T11:00:39.143228+00:00 0:00:01.797324 16337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T11:00:35.086672+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T10:00:00+00:00 PythonOperator 2021-04-12T11:00:15.348528+00:00 2021-04-12T11:00:18.463580+00:00 0:00:03.115052 16336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T11:00:13.001799+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T09:00:00+00:00 EmrJobFlowSensor 2021-04-12T10:27:10.029121+00:00 2021-04-12T10:27:11.538225+00:00 0:00:01.509104 16335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:27:07.660054+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T09:00:00+00:00 EmrJobFlowSensor 2021-04-12T10:15:24.809081+00:00 2021-04-12T10:24:27.428409+00:00 0:09:02.619328 16333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:15:22.511429+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T10:15:17.035216+00:00 2021-04-12T10:15:18.846845+00:00 0:00:01.811629 16332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T10:15:14.575875+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T10:15:03.133819+00:00 2021-04-12T10:15:04.980729+00:00 0:00:01.846910 16331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T10:15:00.577896+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T09:00:00+00:00 PythonOperator 2021-04-12T10:14:57.157693+00:00 2021-04-12T10:15:00.228140+00:00 0:00:03.070447 16330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T10:14:54.440950+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T09:00:00+00:00 PythonOperator 2021-04-12T10:14:41.025145+00:00 2021-04-12T10:14:44.020278+00:00 0:00:02.995133 16329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T10:14:38.477765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T09:00:00+00:00 TriggerDagRunOperator 2021-04-12T10:14:33.382712+00:00 2021-04-12T10:14:33.938494+00:00 0:00:00.555782 16328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:14:30.559399+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T09:00:00+00:00 TriggerDagRunOperator 2021-04-12T10:14:33.187980+00:00 2021-04-12T10:14:33.623253+00:00 0:00:00.435273 16327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:14:30.559454+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T09:05:00+00:00 EmrJobFlowSensor 2021-04-12T10:05:48.782498+00:00 2021-04-12T10:14:51.435762+00:00 0:09:02.653264 16325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:05:46.647220+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T10:05:28.799954+00:00 2021-04-12T10:05:30.443855+00:00 0:00:01.643901 16324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T10:05:26.622923+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T09:05:00+00:00 PythonOperator 2021-04-12T10:05:06.939019+00:00 2021-04-12T10:05:09.664599+00:00 0:00:02.725580 16323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T10:05:04.666588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T09:00:00+00:00 EmrJobFlowSensor 2021-04-12T10:00:56.277011+00:00 2021-04-12T10:10:58.964873+00:00 0:10:02.687862 16322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T10:00:54.172881+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T10:00:34.590222+00:00 2021-04-12T10:00:36.397072+00:00 0:00:01.806850 16321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T10:00:32.150377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T09:00:00+00:00 PythonOperator 2021-04-12T10:00:12.499521+00:00 2021-04-12T10:00:15.240625+00:00 0:00:02.741104 16320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T10:00:10.162560+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T08:00:00+00:00 EmrJobFlowSensor 2021-04-12T09:11:41.670735+00:00 2021-04-12T09:20:44.236263+00:00 0:09:02.565528 16319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:11:39.462321+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T08:00:00+00:00 EmrJobFlowSensor 2021-04-12T09:11:34.372839+00:00 2021-04-12T09:20:37.021122+00:00 0:09:02.648283 16318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:11:31.469743+00:00 2 default_pool