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 check_cluster_status 2021-04-11T20:00:00+00:00 EmrJobFlowSensor 2021-04-11T21:00:54.543635+00:00 2021-04-11T21:09:57.070813+00:00 0:09:02.527178 16128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:00:52.307521+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:00:32.758167+00:00 2021-04-11T21:00:34.496809+00:00 0:00:01.738642 16127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T21:00:30.353179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T20:00:00+00:00 PythonOperator 2021-04-11T21:00:10.629200+00:00 2021-04-11T21:00:13.329692+00:00 0:00:02.700492 16126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T21:00:08.260221+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:12:12.989239+00:00 2021-04-11T20:21:15.607325+00:00 0:09:02.618086 16124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:12:10.746220+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:11:59.228415+00:00 2021-04-11T20:22:02.103501+00:00 0:10:02.875086 16123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:56.680095+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:11:50.918487+00:00 2021-04-11T20:11:52.715252+00:00 0:00:01.796765 16122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:11:48.642220+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:11:39.144305+00:00 2021-04-11T20:11:40.839126+00:00 0:00:01.694821 16121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:11:36.757672+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:11:30.916665+00:00 2021-04-11T20:11:33.747213+00:00 0:00:02.830548 16120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:11:28.661401+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:11:17.147286+00:00 2021-04-11T20:11:20.478213+00:00 0:00:03.330927 16119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:11:14.595764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T19:00:00+00:00 TriggerDagRunOperator 2021-04-11T20:11:04.908861+00:00 2021-04-11T20:11:05.411113+00:00 0:00:00.502252 16118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:02.588863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T19:00:00+00:00 TriggerDagRunOperator 2021-04-11T20:11:04.732599+00:00 2021-04-11T20:11:05.144058+00:00 0:00:00.411459 16117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:02.588896+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T19:05:00+00:00 EmrJobFlowSensor 2021-04-11T20:05:48.148358+00:00 2021-04-11T20:13:50.569278+00:00 0:08:02.420920 16116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:05:45.993600+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:05:26.320255+00:00 2021-04-11T20:05:27.951355+00:00 0:00:01.631100 16115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:05:23.969732+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T19:05:00+00:00 PythonOperator 2021-04-11T20:05:06.196505+00:00 2021-04-11T20:05:08.992697+00:00 0:00:02.796192 16114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:05:03.944980+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:00:49.867578+00:00 2021-04-11T20:10:52.770312+00:00 0:10:02.902734 16113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:00:47.606700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:00:29.921124+00:00 2021-04-11T20:00:31.679724+00:00 0:00:01.758600 16112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T20:00:27.591950+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:00:08.189919+00:00 2021-04-11T20:00:10.899652+00:00 0:00:02.709733 16111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T20:00:05.564901+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:21:10.621424+00:00 2021-04-11T19:31:13.293733+00:00 0:10:02.672309 16109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:21:07.848894+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:21:07.997234+00:00 2021-04-11T19:31:11.151667+00:00 0:10:03.154433 16108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:21:05.777383+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:20:50.509541+00:00 2021-04-11T19:20:52.345793+00:00 0:00:01.836252 16107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:20:47.762232+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:20:48.236815+00:00 2021-04-11T19:20:50.315830+00:00 0:00:02.079015 16106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:20:45.766791+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:20:29.167957+00:00 2021-04-11T19:20:31.879669+00:00 0:00:02.711712 16105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:20:25.675162+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:20:26.802007+00:00 2021-04-11T19:20:30.291157+00:00 0:00:03.489150 16104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:20:23.665987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T18:00:00+00:00 TriggerDagRunOperator 2021-04-11T19:20:20.011255+00:00 2021-04-11T19:20:20.526970+00:00 0:00:00.515715 16103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:20:17.589573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T18:00:00+00:00 TriggerDagRunOperator 2021-04-11T19:20:19.851491+00:00 2021-04-11T19:20:20.261430+00:00 0:00:00.409939 16102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:20:17.589601+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T18:05:00+00:00 EmrJobFlowSensor 2021-04-11T19:05:54.716981+00:00 2021-04-11T19:13:57.207908+00:00 0:08:02.490927 16101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:05:52.271829+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:05:34.486626+00:00 2021-04-11T19:05:36.216128+00:00 0:00:01.729502 16100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:05:32.187360+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T18:05:00+00:00 PythonOperator 2021-04-11T19:05:12.263273+00:00 2021-04-11T19:05:15.702044+00:00 0:00:03.438771 16099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:05:10.137111+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:01:06.084310+00:00 2021-04-11T19:20:10.052611+00:00 0:19:03.968301 16098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:01:03.840873+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:00:45.881780+00:00 2021-04-11T19:00:47.543931+00:00 0:00:01.662151 16097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T19:00:43.713828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:00:24.620193+00:00 2021-04-11T19:00:27.563136+00:00 0:00:02.942943 16096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T19:00:21.751293+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:10:35.460924+00:00 2021-04-11T18:19:38.082373+00:00 0:09:02.621449 16094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:10:33.266474+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:10:33.671731+00:00 2021-04-11T18:20:36.402042+00:00 0:10:02.730311 16093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:10:31.349679+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:10:15.649625+00:00 2021-04-11T18:10:17.461137+00:00 0:00:01.811512 16092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:10:13.195416+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:10:11.502222+00:00 2021-04-11T18:10:13.207559+00:00 0:00:01.705337 16091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:10:09.273213+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:09:53.761661+00:00 2021-04-11T18:09:56.556734+00:00 0:00:02.795073 16090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:09:51.146176+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:09:51.338639+00:00 2021-04-11T18:09:54.652475+00:00 0:00:03.313836 16089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:09:49.153272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T17:00:00+00:00 TriggerDagRunOperator 2021-04-11T18:09:35.691585+00:00 2021-04-11T18:09:36.207051+00:00 0:00:00.515466 16088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:09:33.169341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T17:00:00+00:00 TriggerDagRunOperator 2021-04-11T18:09:35.558341+00:00 2021-04-11T18:09:35.957059+00:00 0:00:00.398718 16087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:09:33.169302+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T17:05:00+00:00 EmrJobFlowSensor 2021-04-11T18:05:47.186781+00:00 2021-04-11T18:14:49.853272+00:00 0:09:02.666491 16086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:05:44.852801+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:05:25.094070+00:00 2021-04-11T18:05:26.749780+00:00 0:00:01.655710 16085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:05:22.730594+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T17:05:00+00:00 PythonOperator 2021-04-11T18:05:04.851137+00:00 2021-04-11T18:05:07.516707+00:00 0:00:02.665570 16084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:05:02.712370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:01:20.666914+00:00 2021-04-11T18:09:23.275602+00:00 0:08:02.608688 16083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:01:18.417846+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:00:44.621916+00:00 2021-04-11T18:00:46.297419+00:00 0:00:01.675503 16082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T18:00:42.410706+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:00:25.109351+00:00 2021-04-11T18:00:28.033426+00:00 0:00:02.924075 16081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T18:00:22.344073+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:11:24.662666+00:00 2021-04-11T17:21:27.516388+00:00 0:10:02.853722 16079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:11:22.175141+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:11:12.856374+00:00 2021-04-11T17:20:16.243600+00:00 0:09:03.387226 16078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:11:10.109870+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:11:02.523041+00:00 2021-04-11T17:11:04.337095+00:00 0:00:01.814054 16077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T17:11:00.160590+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:10:50.336002+00:00 2021-04-11T17:10:52.016473+00:00 0:00:01.680471 16076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T17:10:48.083414+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T16:00:00+00:00 PythonOperator 2021-04-11T17:10:40.295228+00:00 2021-04-11T17:10:43.358963+00:00 0:00:03.063735 16075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:10:38.037098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T16:00:00+00:00 PythonOperator 2021-04-11T17:10:30.325051+00:00 2021-04-11T17:10:33.059740+00:00 0:00:02.734689 16074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:10:28.043324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T16:00:00+00:00 TriggerDagRunOperator 2021-04-11T17:10:20.391272+00:00 2021-04-11T17:10:20.927413+00:00 0:00:00.536141 16073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:10:18.017897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T16:00:00+00:00 TriggerDagRunOperator 2021-04-11T17:10:20.260404+00:00 2021-04-11T17:10:20.669691+00:00 0:00:00.409287 16072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:10:18.017870+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T16:05:00+00:00 EmrJobFlowSensor 2021-04-11T17:05:49.656080+00:00 2021-04-11T17:14:52.260646+00:00 0:09:02.604566 16071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:05:47.352542+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:05:29.654867+00:00 2021-04-11T17:05:31.408115+00:00 0:00:01.753248 16070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T17:05:27.333736+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T16:05:00+00:00 PythonOperator 2021-04-11T17:05:07.647849+00:00 2021-04-11T17:05:10.416044+00:00 0:00:02.768195 16069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:05:05.317324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:01:09.240876+00:00 2021-04-11T17:10:11.891300+00:00 0:09:02.650424 16068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:01:06.988111+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:00:45.202017+00:00 2021-04-11T17:00:46.919137+00:00 0:00:01.717120 16067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T17:00:42.888753+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T16:00:00+00:00 PythonOperator 2021-04-11T17:00:25.307314+00:00 2021-04-11T17:00:28.000069+00:00 0:00:02.692755 16066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T17:00:22.830877+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T15:00:00+00:00 EmrJobFlowSensor 2021-04-11T16:12:26.093892+00:00 2021-04-11T16:21:28.696598+00:00 0:09:02.602706 16064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:12:23.948243+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T15:00:00+00:00 EmrJobFlowSensor 2021-04-11T16:12:22.088255+00:00 2021-04-11T16:22:24.873669+00:00 0:10:02.785414 16063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:12:19.932499+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:12:04.088600+00:00 2021-04-11T16:12:05.793628+00:00 0:00:01.705028 16062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T16:12:01.912259+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:12:00.299714+00:00 2021-04-11T16:12:02.187218+00:00 0:00:01.887504 16061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T16:11:57.910816+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T15:00:00+00:00 PythonOperator 2021-04-11T16:11:42.390941+00:00 2021-04-11T16:11:45.196388+00:00 0:00:02.805447 16060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:11:39.896897+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T15:00:00+00:00 PythonOperator 2021-04-11T16:11:38.143641+00:00 2021-04-11T16:11:41.526373+00:00 0:00:03.382732 16059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:11:35.892719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T15:00:00+00:00 TriggerDagRunOperator 2021-04-11T16:11:22.320610+00:00 2021-04-11T16:11:22.914122+00:00 0:00:00.593512 16058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:11:19.873411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T15:00:00+00:00 TriggerDagRunOperator 2021-04-11T16:11:22.228933+00:00 2021-04-11T16:11:22.656454+00:00 0:00:00.427521 16057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:11:19.873379+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T15:05:00+00:00 EmrJobFlowSensor 2021-04-11T16:06:01.659824+00:00 2021-04-11T16:15:04.425148+00:00 0:09:02.765324 16056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:05:59.434550+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:05:37.721364+00:00 2021-04-11T16:05:39.508626+00:00 0:00:01.787262 16055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T16:05:35.417334+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T15:05:00+00:00 PythonOperator 2021-04-11T16:05:15.589325+00:00 2021-04-11T16:05:18.266588+00:00 0:00:02.677263 16054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:05:13.396464+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T15:00:00+00:00 EmrJobFlowSensor 2021-04-11T16:01:08.107286+00:00 2021-04-11T16:11:10.955308+00:00 0:10:02.848022 16053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:01:05.067362+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:00:45.395002+00:00 2021-04-11T16:00:47.226181+00:00 0:00:01.831179 16052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T16:00:43.046566+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T15:00:00+00:00 PythonOperator 2021-04-11T16:00:23.744721+00:00 2021-04-11T16:00:26.638285+00:00 0:00:02.893564 16051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T16:00:20.930706+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T14:00:00+00:00 EmrJobFlowSensor 2021-04-11T15:11:08.113111+00:00 2021-04-11T15:21:10.861954+00:00 0:10:02.748843 16049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:11:05.790841+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T14:00:00+00:00 EmrJobFlowSensor 2021-04-11T15:11:04.151579+00:00 2021-04-11T15:20:06.839227+00:00 0:09:02.687648 16048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:11:01.784551+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:10:46.130620+00:00 2021-04-11T15:10:47.963162+00:00 0:00:01.832542 16047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T15:10:43.763698+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:10:42.133401+00:00 2021-04-11T15:10:43.864789+00:00 0:00:01.731388 16046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T15:10:39.758726+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T14:00:00+00:00 PythonOperator 2021-04-11T15:10:26.411705+00:00 2021-04-11T15:10:29.154231+00:00 0:00:02.742526 16045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:10:23.775607+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T14:00:00+00:00 PythonOperator 2021-04-11T15:10:20.129331+00:00 2021-04-11T15:10:23.140498+00:00 0:00:03.011167 16044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:10:17.751659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T14:00:00+00:00 TriggerDagRunOperator 2021-04-11T15:10:04.095080+00:00 2021-04-11T15:10:04.679509+00:00 0:00:00.584429 16043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:10:01.650375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T14:00:00+00:00 TriggerDagRunOperator 2021-04-11T15:10:03.848506+00:00 2021-04-11T15:10:04.273373+00:00 0:00:00.424867 16042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:10:01.650404+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T14:05:00+00:00 EmrJobFlowSensor 2021-04-11T15:05:47.618160+00:00 2021-04-11T15:14:50.285234+00:00 0:09:02.667074 16041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:05:45.242358+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:05:25.499613+00:00 2021-04-11T15:05:27.237975+00:00 0:00:01.738362 16040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T15:05:23.226772+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T14:05:00+00:00 PythonOperator 2021-04-11T15:05:05.482163+00:00 2021-04-11T15:05:08.189490+00:00 0:00:02.707327 16039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:05:03.206957+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T14:00:00+00:00 EmrJobFlowSensor 2021-04-11T15:00:55.156389+00:00 2021-04-11T15:09:58.157313+00:00 0:09:03.000924 16038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:00:52.748129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:00:32.907338+00:00 2021-04-11T15:00:34.576999+00:00 0:00:01.669661 16037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T15:00:30.726258+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T14:00:00+00:00 PythonOperator 2021-04-11T15:00:11.340192+00:00 2021-04-11T15:00:14.092447+00:00 0:00:02.752255 16036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T15:00:08.706166+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T13:00:00+00:00 EmrJobFlowSensor 2021-04-11T14:12:04.529900+00:00 2021-04-11T14:22:07.406098+00:00 0:10:02.876198 16034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:12:01.797573+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T13:00:00+00:00 EmrJobFlowSensor 2021-04-11T14:12:04.240467+00:00 2021-04-11T14:20:06.789662+00:00 0:08:02.549195 16033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:12:01.797625+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:11:42.251321+00:00 2021-04-11T14:11:43.943528+00:00 0:00:01.692207 16032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T14:11:39.844434+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:11:42.277486+00:00 2021-04-11T14:11:44.153818+00:00 0:00:01.876332 16031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T14:11:39.844401+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T13:00:00+00:00 PythonOperator 2021-04-11T14:11:22.244074+00:00 2021-04-11T14:11:25.279948+00:00 0:00:03.035874 16030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:11:19.669329+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T13:00:00+00:00 PythonOperator 2021-04-11T14:11:22.286188+00:00 2021-04-11T14:11:25.164795+00:00 0:00:02.878607 16029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:11:19.669366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T13:00:00+00:00 TriggerDagRunOperator 2021-04-11T14:11:10.457145+00:00 2021-04-11T14:11:10.974969+00:00 0:00:00.517824 16028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:11:07.660834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T13:00:00+00:00 TriggerDagRunOperator 2021-04-11T14:11:09.982631+00:00 2021-04-11T14:11:10.525937+00:00 0:00:00.543306 16027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:11:07.660796+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T13:05:00+00:00 EmrJobFlowSensor 2021-04-11T14:06:04.101346+00:00 2021-04-11T14:15:06.771166+00:00 0:09:02.669820 16026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:06:01.181232+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:05:41.435173+00:00 2021-04-11T14:05:43.063088+00:00 0:00:01.627915 16025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T14:05:39.240885+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T13:05:00+00:00 PythonOperator 2021-04-11T14:05:21.360209+00:00 2021-04-11T14:05:24.066006+00:00 0:00:02.705797 16024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:05:19.102293+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T13:00:00+00:00 EmrJobFlowSensor 2021-04-11T14:01:01.131075+00:00 2021-04-11T14:11:04.070736+00:00 0:10:02.939661 16023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:00:58.844400+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:00:39.299998+00:00 2021-04-11T14:00:41.112682+00:00 0:00:01.812684 16022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T14:00:36.769807+00:00 2 default_pool