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 booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T00:10:55.130525+00:00 2021-04-24T00:10:56.912695+00:00 0:00:01.782170 20559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T00:10:52.656203+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T00:10:40.714961+00:00 2021-04-24T00:10:42.418381+00:00 0:00:01.703420 20558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T00:10:38.556391+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T23:00:00+00:00 PythonOperator 2021-04-24T00:10:22.981797+00:00 2021-04-24T00:10:26.152279+00:00 0:00:03.170482 20557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T00:10:20.541879+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T23:00:00+00:00 PythonOperator 2021-04-24T00:10:09.031044+00:00 2021-04-24T00:10:12.088308+00:00 0:00:03.057264 20556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T00:10:06.540715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T23:00:00+00:00 TriggerDagRunOperator 2021-04-24T00:10:03.303053+00:00 2021-04-24T00:10:04.026127+00:00 0:00:00.723074 20555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T00:10:00.554822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T23:00:00+00:00 TriggerDagRunOperator 2021-04-24T00:10:03.044427+00:00 2021-04-24T00:10:03.471322+00:00 0:00:00.426895 20554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T00:10:00.554866+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T23:05:00+00:00 EmrJobFlowSensor 2021-04-24T00:06:04.277253+00:00 2021-04-24T00:15:07.062018+00:00 0:09:02.784765 20553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T00:06:02.087065+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T00:05:44.305877+00:00 2021-04-24T00:05:46.063746+00:00 0:00:01.757869 20552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T00:05:42.022908+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T23:05:00+00:00 PythonOperator 2021-04-24T00:05:22.269982+00:00 2021-04-24T00:05:25.257633+00:00 0:00:02.987651 20551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T00:05:20.003860+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T23:00:00+00:00 EmrJobFlowSensor 2021-04-24T00:00:56.029738+00:00 2021-04-24T00:09:58.776770+00:00 0:09:02.747032 20550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T00:00:53.649859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T00:00:33.836151+00:00 2021-04-24T00:00:35.542055+00:00 0:00:01.705904 20549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T00:00:31.593065+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T23:00:00+00:00 PythonOperator 2021-04-24T00:00:11.764507+00:00 2021-04-24T00:00:14.696584+00:00 0:00:02.932077 20548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T00:00:09.518087+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T22:00:00+00:00 EmrJobFlowSensor 2021-04-23T23:14:27.508067+00:00 2021-04-23T23:23:30.096688+00:00 0:09:02.588621 20547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:14:25.220703+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T22:00:00+00:00 EmrJobFlowSensor 2021-04-23T23:14:19.577428+00:00 2021-04-23T23:24:22.353822+00:00 0:10:02.776394 20546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:14:17.217233+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T23:14:05.950474+00:00 2021-04-23T23:14:07.705838+00:00 0:00:01.755364 20545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T23:14:03.271192+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T23:13:57.650532+00:00 2021-04-23T23:13:59.360850+00:00 0:00:01.710318 20544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T23:13:55.268115+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T22:00:00+00:00 PythonOperator 2021-04-23T23:13:43.382288+00:00 2021-04-23T23:13:46.357936+00:00 0:00:02.975648 20543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T23:13:41.190423+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T22:00:00+00:00 PythonOperator 2021-04-23T23:13:35.443654+00:00 2021-04-23T23:13:38.774402+00:00 0:00:03.330748 20542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T23:13:33.173710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T22:00:00+00:00 TriggerDagRunOperator 2021-04-23T23:13:17.806957+00:00 2021-04-23T23:13:18.366642+00:00 0:00:00.559685 20541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:13:15.135126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T22:00:00+00:00 TriggerDagRunOperator 2021-04-23T23:13:17.586838+00:00 2021-04-23T23:13:18.028584+00:00 0:00:00.441746 20540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:13:15.135155+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T22:05:00+00:00 EmrJobFlowSensor 2021-04-23T23:06:10.466290+00:00 2021-04-23T23:15:13.078910+00:00 0:09:02.612620 20538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:06:08.295160+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T23:05:40.416983+00:00 2021-04-23T23:05:42.143179+00:00 0:00:01.726196 20537 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T23:05:38.255897+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T22:05:00+00:00 PythonOperator 2021-04-23T23:05:18.382791+00:00 2021-04-23T23:05:21.723473+00:00 0:00:03.340682 20536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T23:05:16.218852+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-22T23:00:00+00:00 EmrJobFlowSensor 2021-04-23T23:01:08.461015+00:00 2021-04-23T23:09:10.934744+00:00 0:08:02.473729 20535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:01:05.810640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T22:00:00+00:00 EmrJobFlowSensor 2021-04-23T23:01:06.143856+00:00 2021-04-23T23:10:09.170246+00:00 0:09:03.026390 20534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T23:01:03.808608+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T23:00:45.974750+00:00 2021-04-23T23:00:47.711978+00:00 0:00:01.737228 20533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T23:00:43.785726+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T23:00:44.253109+00:00 2021-04-23T23:00:46.133234+00:00 0:00:01.880125 20532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T23:00:41.788595+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-22T23:00:00+00:00 PythonOperator 2021-04-23T23:00:24.168089+00:00 2021-04-23T23:00:27.207821+00:00 0:00:03.039732 20531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T23:00:21.761426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T22:00:00+00:00 PythonOperator 2021-04-23T23:00:21.959315+00:00 2021-04-23T23:00:24.904314+00:00 0:00:02.944999 20530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T23:00:19.702692+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T21:00:00+00:00 EmrJobFlowSensor 2021-04-23T22:11:22.985496+00:00 2021-04-23T22:20:25.572705+00:00 0:09:02.587209 20529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T22:11:20.730279+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T21:00:00+00:00 EmrJobFlowSensor 2021-04-23T22:11:13.327749+00:00 2021-04-23T22:20:16.183807+00:00 0:09:02.856058 20528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T22:11:10.777327+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T22:11:01.544731+00:00 2021-04-23T22:11:03.517751+00:00 0:00:01.973020 20527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T22:10:58.776449+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T22:10:53.132859+00:00 2021-04-23T22:10:54.781743+00:00 0:00:01.648884 20526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T22:10:50.766064+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T21:00:00+00:00 PythonOperator 2021-04-23T22:10:41.007523+00:00 2021-04-23T22:10:44.257901+00:00 0:00:03.250378 20525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T22:10:38.742066+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T21:00:00+00:00 PythonOperator 2021-04-23T22:10:31.098969+00:00 2021-04-23T22:10:34.186030+00:00 0:00:03.087061 20524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T22:10:28.684714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T21:00:00+00:00 TriggerDagRunOperator 2021-04-23T22:10:21.417073+00:00 2021-04-23T22:10:21.929698+00:00 0:00:00.512625 20523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T22:10:18.754181+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T21:00:00+00:00 TriggerDagRunOperator 2021-04-23T22:10:21.347251+00:00 2021-04-23T22:10:21.772511+00:00 0:00:00.425260 20522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T22:10:18.754139+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T21:05:00+00:00 EmrJobFlowSensor 2021-04-23T22:05:47.573309+00:00 2021-04-23T22:14:50.073334+00:00 0:09:02.500025 20520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T22:05:45.268055+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T22:05:27.778027+00:00 2021-04-23T22:05:29.558927+00:00 0:00:01.780900 20519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T22:05:25.187666+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T21:05:00+00:00 PythonOperator 2021-04-23T22:05:05.906970+00:00 2021-04-23T22:05:08.880331+00:00 0:00:02.973361 20518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T22:05:03.107769+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T21:00:00+00:00 EmrJobFlowSensor 2021-04-23T22:01:03.032262+00:00 2021-04-23T22:10:05.767652+00:00 0:09:02.735390 20517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T22:01:00.681704+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T22:00:40.811112+00:00 2021-04-23T22:00:42.462200+00:00 0:00:01.651088 20516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T22:00:38.642679+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T21:00:00+00:00 PythonOperator 2021-04-23T22:00:19.048813+00:00 2021-04-23T22:00:21.976256+00:00 0:00:02.927443 20515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T22:00:16.681067+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T20:00:00+00:00 EmrJobFlowSensor 2021-04-23T21:24:01.505688+00:00 2021-04-23T21:24:03.096748+00:00 0:00:01.591060 20514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T21:23:59.234588+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T20:00:00+00:00 EmrJobFlowSensor 2021-04-23T21:11:28.255597+00:00 2021-04-23T21:20:30.834328+00:00 0:09:02.578731 20512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T21:11:25.830711+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T21:11:14.263639+00:00 2021-04-23T21:11:15.991096+00:00 0:00:01.727457 20511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T21:11:11.837876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T21:11:08.133906+00:00 2021-04-23T21:11:09.962571+00:00 0:00:01.828665 20510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T21:11:05.812676+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T20:00:00+00:00 PythonOperator 2021-04-23T21:10:52.114354+00:00 2021-04-23T21:10:55.330476+00:00 0:00:03.216122 20509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T21:10:49.857912+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T20:00:00+00:00 PythonOperator 2021-04-23T21:10:46.213184+00:00 2021-04-23T21:10:49.402496+00:00 0:00:03.189312 20508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T21:10:43.860978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T20:00:00+00:00 TriggerDagRunOperator 2021-04-23T21:10:28.795728+00:00 2021-04-23T21:10:29.314178+00:00 0:00:00.518450 20507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T21:10:25.565080+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T20:00:00+00:00 TriggerDagRunOperator 2021-04-23T21:10:28.582909+00:00 2021-04-23T21:10:29.014308+00:00 0:00:00.431399 20506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T21:10:25.565123+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T20:05:00+00:00 EmrJobFlowSensor 2021-04-23T21:06:01.075561+00:00 2021-04-23T21:15:03.695925+00:00 0:09:02.620364 20504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T21:05:58.854264+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T21:05:39.099006+00:00 2021-04-23T21:05:40.742380+00:00 0:00:01.643374 20503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T21:05:36.757315+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T20:05:00+00:00 PythonOperator 2021-04-23T21:05:16.800553+00:00 2021-04-23T21:05:19.963814+00:00 0:00:03.163261 20502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T21:05:14.628157+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T20:00:00+00:00 EmrJobFlowSensor 2021-04-23T21:01:09.273341+00:00 2021-04-23T21:10:11.990127+00:00 0:09:02.716786 20501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T21:01:06.289006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T21:00:46.837514+00:00 2021-04-23T21:00:48.518734+00:00 0:00:01.681220 20500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T21:00:44.206725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T20:00:00+00:00 PythonOperator 2021-04-23T21:00:20.523768+00:00 2021-04-23T21:00:24.156129+00:00 0:00:03.632361 20499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T21:00:18.185132+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T19:00:00+00:00 EmrJobFlowSensor 2021-04-23T20:11:44.149899+00:00 2021-04-23T20:21:46.940797+00:00 0:10:02.790898 20498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T20:11:41.543699+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T19:00:00+00:00 EmrJobFlowSensor 2021-04-23T20:11:41.594828+00:00 2021-04-23T20:21:44.404250+00:00 0:10:02.809422 20497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T20:11:39.443964+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T20:11:23.747009+00:00 2021-04-23T20:11:25.540922+00:00 0:00:01.793913 20496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T20:11:21.454015+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T20:11:21.573024+00:00 2021-04-23T20:11:23.425647+00:00 0:00:01.852623 20495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T20:11:19.383464+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T19:00:00+00:00 PythonOperator 2021-04-23T20:11:01.490462+00:00 2021-04-23T20:11:04.761111+00:00 0:00:03.270649 20494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T20:10:59.288593+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T19:00:00+00:00 PythonOperator 2021-04-23T20:10:59.632960+00:00 2021-04-23T20:11:02.715608+00:00 0:00:03.082648 20493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T20:10:57.294628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T19:00:00+00:00 TriggerDagRunOperator 2021-04-23T20:10:38.292642+00:00 2021-04-23T20:10:38.804946+00:00 0:00:00.512304 20492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T20:10:35.264011+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T19:00:00+00:00 TriggerDagRunOperator 2021-04-23T20:10:37.719503+00:00 2021-04-23T20:10:38.132541+00:00 0:00:00.413038 20491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T20:10:35.264037+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T19:05:00+00:00 EmrJobFlowSensor 2021-04-23T20:06:07.878590+00:00 2021-04-23T20:14:10.316440+00:00 0:08:02.437850 20489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T20:06:05.431269+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T20:05:41.852775+00:00 2021-04-23T20:05:43.460396+00:00 0:00:01.607621 20488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T20:05:39.469397+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T19:05:00+00:00 PythonOperator 2021-04-23T20:05:21.569249+00:00 2021-04-23T20:05:25.124798+00:00 0:00:03.555549 20487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T20:05:19.392738+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T19:00:00+00:00 EmrJobFlowSensor 2021-04-23T20:01:07.325273+00:00 2021-04-23T20:10:10.034992+00:00 0:09:02.709719 20486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T20:01:05.079493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T20:00:45.400034+00:00 2021-04-23T20:00:47.110690+00:00 0:00:01.710656 20485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T20:00:43.059877+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T19:00:00+00:00 PythonOperator 2021-04-23T20:00:25.139106+00:00 2021-04-23T20:00:28.117217+00:00 0:00:02.978111 20484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T20:00:22.956724+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T18:00:00+00:00 EmrJobFlowSensor 2021-04-23T19:12:28.373846+00:00 2021-04-23T19:21:31.070078+00:00 0:09:02.696232 20483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T19:12:26.106214+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T18:00:00+00:00 EmrJobFlowSensor 2021-04-23T19:12:16.197198+00:00 2021-04-23T19:21:18.758625+00:00 0:09:02.561427 20482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T19:12:14.093963+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T19:12:06.230172+00:00 2021-04-23T19:12:07.922777+00:00 0:00:01.692605 20481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T19:12:04.089184+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T19:11:54.494575+00:00 2021-04-23T19:11:56.350919+00:00 0:00:01.856344 20480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T19:11:52.069203+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T18:00:00+00:00 PythonOperator 2021-04-23T19:11:44.345688+00:00 2021-04-23T19:11:47.319940+00:00 0:00:02.974252 20479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T19:11:42.081864+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T18:00:00+00:00 PythonOperator 2021-04-23T19:11:32.705006+00:00 2021-04-23T19:11:36.479826+00:00 0:00:03.774820 20478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T19:11:29.986440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T18:00:00+00:00 TriggerDagRunOperator 2021-04-23T19:11:21.031066+00:00 2021-04-23T19:11:21.545951+00:00 0:00:00.514885 20477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T19:11:17.930585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T18:00:00+00:00 TriggerDagRunOperator 2021-04-23T19:11:20.297102+00:00 2021-04-23T19:11:21.338664+00:00 0:00:01.041562 20476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T19:11:17.930613+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T18:05:00+00:00 EmrJobFlowSensor 2021-04-23T19:06:07.480370+00:00 2021-04-23T19:15:10.077339+00:00 0:09:02.596969 20474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T19:06:05.330530+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T19:05:46.163963+00:00 2021-04-23T19:05:47.777901+00:00 0:00:01.613938 20473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T19:05:43.310327+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T18:05:00+00:00 PythonOperator 2021-04-23T19:05:24.011608+00:00 2021-04-23T19:05:27.092838+00:00 0:00:03.081230 20472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T19:05:21.344571+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T18:00:00+00:00 EmrJobFlowSensor 2021-04-23T19:01:05.641841+00:00 2021-04-23T19:11:08.596873+00:00 0:10:02.955032 20471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T19:01:03.073709+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T19:00:43.196940+00:00 2021-04-23T19:00:44.910948+00:00 0:00:01.714008 20470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T19:00:40.989568+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T18:00:00+00:00 PythonOperator 2021-04-23T19:00:23.798220+00:00 2021-04-23T19:00:26.877098+00:00 0:00:03.078878 20469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T19:00:20.942714+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T17:00:00+00:00 EmrJobFlowSensor 2021-04-23T18:11:36.202217+00:00 2021-04-23T18:20:38.819192+00:00 0:09:02.616975 20468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T18:11:33.989728+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T17:00:00+00:00 EmrJobFlowSensor 2021-04-23T18:11:30.527313+00:00 2021-04-23T18:21:33.276091+00:00 0:10:02.748778 20467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T18:11:28.059099+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T18:11:12.120838+00:00 2021-04-23T18:11:13.792371+00:00 0:00:01.671533 20466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T18:11:09.929345+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T18:11:08.483125+00:00 2021-04-23T18:11:10.352253+00:00 0:00:01.869128 20465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T18:11:05.979618+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T17:00:00+00:00 PythonOperator 2021-04-23T18:10:50.201820+00:00 2021-04-23T18:10:53.152891+00:00 0:00:02.951071 20464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T18:10:47.975299+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T17:00:00+00:00 PythonOperator 2021-04-23T18:10:48.528307+00:00 2021-04-23T18:10:51.731159+00:00 0:00:03.202852 20463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T18:10:45.960405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T17:00:00+00:00 TriggerDagRunOperator 2021-04-23T18:10:30.516380+00:00 2021-04-23T18:10:31.027896+00:00 0:00:00.511516 20462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T18:10:27.968048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T17:00:00+00:00 TriggerDagRunOperator 2021-04-23T18:10:30.524151+00:00 2021-04-23T18:10:31.135924+00:00 0:00:00.611773 20461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T18:10:27.967990+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T17:05:00+00:00 EmrJobFlowSensor 2021-04-23T18:07:17.863034+00:00 2021-04-23T18:16:20.483875+00:00 0:09:02.620841 20460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T18:07:15.594483+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T18:06:55.741998+00:00 2021-04-23T18:06:57.443243+00:00 0:00:01.701245 20459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T18:06:53.537568+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T17:05:00+00:00 PythonOperator 2021-04-23T18:06:35.760522+00:00 2021-04-23T18:06:38.770904+00:00 0:00:03.010382 20458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T18:06:33.521039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T17:00:00+00:00 EmrJobFlowSensor 2021-04-23T18:01:08.187627+00:00 2021-04-23T18:10:10.962145+00:00 0:09:02.774518 20456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T18:01:06.013489+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T18:00:44.269851+00:00 2021-04-23T18:00:46.098987+00:00 0:00:01.829136 20455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T18:00:41.991241+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T17:00:00+00:00 PythonOperator 2021-04-23T18:00:22.050031+00:00 2021-04-23T18:00:24.980818+00:00 0:00:02.930787 20454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T18:00:19.886265+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T16:00:00+00:00 EmrJobFlowSensor 2021-04-23T17:12:34.502127+00:00 2021-04-23T17:20:37.025412+00:00 0:08:02.523285 20453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T17:12:32.079507+00:00 2 default_pool