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-03-21T04:00:00+00:00 EmrJobFlowSensor 2021-03-21T05:11:45.361107+00:00 2021-03-21T05:20:48.008803+00:00 0:09:02.647696 10229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T05:11:43.169262+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T05:11:29.310575+00:00 2021-03-21T05:11:30.960838+00:00 0:00:01.650263 10228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T05:11:27.152794+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T04:00:00+00:00 PythonOperator 2021-03-21T05:11:07.235143+00:00 2021-03-21T05:11:10.124876+00:00 0:00:02.889733 10227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T05:11:05.038410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T04:00:00+00:00 TriggerDagRunOperator 2021-03-21T05:10:51.314516+00:00 2021-03-21T05:10:51.725257+00:00 0:00:00.410741 10226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T05:10:49.022796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T04:00:00+00:00 TriggerDagRunOperator 2021-03-21T05:10:51.349659+00:00 2021-03-21T05:10:51.886955+00:00 0:00:00.537296 10225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T05:10:49.022757+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T04:00:00+00:00 EmrJobFlowSensor 2021-03-21T05:00:44.456028+00:00 2021-03-21T05:10:47.167199+00:00 0:10:02.711171 10224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T05:00:42.032286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T05:00:28.351301+00:00 2021-03-21T05:00:30.082230+00:00 0:00:01.730929 10223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T05:00:25.961374+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T04:00:00+00:00 PythonOperator 2021-03-21T05:00:12.214838+00:00 2021-03-21T05:00:14.920214+00:00 0:00:02.705376 10222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T05:00:09.902335+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T03:00:00+00:00 EmrJobFlowSensor 2021-03-21T04:11:17.748220+00:00 2021-03-21T04:21:20.708546+00:00 0:10:02.960326 10220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T04:11:15.476010+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T04:11:01.608820+00:00 2021-03-21T04:11:03.331169+00:00 0:00:01.722349 10219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T04:10:59.464372+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T03:00:00+00:00 PythonOperator 2021-03-21T04:10:43.801133+00:00 2021-03-21T04:10:46.692208+00:00 0:00:02.891075 10218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T04:10:41.457303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T03:00:00+00:00 TriggerDagRunOperator 2021-03-21T04:10:25.704761+00:00 2021-03-21T04:10:26.239732+00:00 0:00:00.534971 10217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T04:10:23.384100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T03:00:00+00:00 TriggerDagRunOperator 2021-03-21T04:10:25.613288+00:00 2021-03-21T04:10:25.999910+00:00 0:00:00.386622 10216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T04:10:23.384074+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T03:00:00+00:00 EmrJobFlowSensor 2021-03-21T04:01:06.303930+00:00 2021-03-21T04:10:08.946042+00:00 0:09:02.642112 10215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T04:01:04.166705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T04:00:50.880137+00:00 2021-03-21T04:00:52.753357+00:00 0:00:01.873220 10214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T04:00:48.320942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T03:00:00+00:00 PythonOperator 2021-03-21T04:00:34.548937+00:00 2021-03-21T04:00:37.286452+00:00 0:00:02.737515 10213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T04:00:32.088727+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T02:00:00+00:00 EmrJobFlowSensor 2021-03-21T03:09:57.553755+00:00 2021-03-21T03:19:00.304262+00:00 0:09:02.750507 10211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T03:09:55.200962+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T03:09:41.364064+00:00 2021-03-21T03:09:43.050729+00:00 0:00:01.686665 10210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T03:09:39.187246+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T02:00:00+00:00 PythonOperator 2021-03-21T03:09:25.511501+00:00 2021-03-21T03:09:28.213406+00:00 0:00:02.701905 10209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T03:09:23.246321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T02:00:00+00:00 TriggerDagRunOperator 2021-03-21T03:09:11.663469+00:00 2021-03-21T03:09:12.166354+00:00 0:00:00.502885 10208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T03:09:09.234231+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T02:00:00+00:00 TriggerDagRunOperator 2021-03-21T03:09:11.523419+00:00 2021-03-21T03:09:11.906264+00:00 0:00:00.382845 10207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T03:09:09.234280+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T02:00:00+00:00 EmrJobFlowSensor 2021-03-21T03:01:04.764729+00:00 2021-03-21T03:09:07.507404+00:00 0:08:02.742675 10206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T03:01:02.346121+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T03:00:30.606582+00:00 2021-03-21T03:00:32.470381+00:00 0:00:01.863799 10205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T03:00:28.265479+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T02:00:00+00:00 PythonOperator 2021-03-21T03:00:12.484573+00:00 2021-03-21T03:00:15.199442+00:00 0:00:02.714869 10204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T03:00:10.203155+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T01:00:00+00:00 EmrJobFlowSensor 2021-03-21T02:10:16.619320+00:00 2021-03-21T02:18:19.419927+00:00 0:08:02.800607 10202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T02:10:14.232791+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T02:09:54.304431+00:00 2021-03-21T02:09:55.965619+00:00 0:00:01.661188 10201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T02:09:52.100602+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T01:00:00+00:00 PythonOperator 2021-03-21T02:09:34.560301+00:00 2021-03-21T02:09:37.308588+00:00 0:00:02.748287 10200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T02:09:32.082529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T01:00:00+00:00 TriggerDagRunOperator 2021-03-21T02:09:22.550150+00:00 2021-03-21T02:09:23.080593+00:00 0:00:00.530443 10199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T02:09:20.075218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T01:00:00+00:00 TriggerDagRunOperator 2021-03-21T02:09:22.391005+00:00 2021-03-21T02:09:22.793577+00:00 0:00:00.402572 10198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T02:09:20.075184+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T01:00:00+00:00 EmrJobFlowSensor 2021-03-21T02:01:03.272595+00:00 2021-03-21T02:09:05.965912+00:00 0:08:02.693317 10197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T02:01:00.831994+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T02:00:37.109405+00:00 2021-03-21T02:00:38.955173+00:00 0:00:01.845768 10196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T02:00:34.808293+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T01:00:00+00:00 PythonOperator 2021-03-21T02:00:19.254639+00:00 2021-03-21T02:00:21.968782+00:00 0:00:02.714143 10195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T02:00:16.828271+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T00:00:00+00:00 EmrJobFlowSensor 2021-03-21T01:10:44.768324+00:00 2021-03-21T01:19:47.632541+00:00 0:09:02.864217 10193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T01:10:42.398772+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T01:10:28.784862+00:00 2021-03-21T01:10:30.479244+00:00 0:00:01.694382 10192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T01:10:26.433260+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T00:00:00+00:00 PythonOperator 2021-03-21T01:10:12.697615+00:00 2021-03-21T01:10:15.554926+00:00 0:00:02.857311 10191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T01:10:10.356533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T00:00:00+00:00 TriggerDagRunOperator 2021-03-21T01:09:58.697436+00:00 2021-03-21T01:09:59.234850+00:00 0:00:00.537414 10190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T01:09:56.295870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T00:00:00+00:00 TriggerDagRunOperator 2021-03-21T01:09:58.631153+00:00 2021-03-21T01:09:59.055856+00:00 0:00:00.424703 10189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T01:09:56.295842+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T00:00:00+00:00 EmrJobFlowSensor 2021-03-21T01:00:39.685869+00:00 2021-03-21T01:09:42.314482+00:00 0:09:02.628613 10188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T01:00:37.391482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T01:00:23.772570+00:00 2021-03-21T01:00:25.601385+00:00 0:00:01.828815 10187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T01:00:21.377354+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T00:00:00+00:00 PythonOperator 2021-03-21T01:00:06.144403+00:00 2021-03-21T01:00:09.111738+00:00 0:00:02.967335 10186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T01:00:03.428781+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T23:00:00+00:00 EmrJobFlowSensor 2021-03-21T00:11:49.684730+00:00 2021-03-21T00:20:52.284428+00:00 0:09:02.599698 10184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T00:11:47.331409+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T00:11:31.488627+00:00 2021-03-21T00:11:33.376253+00:00 0:00:01.887626 10183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T00:11:29.255219+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T23:00:00+00:00 PythonOperator 2021-03-21T00:11:15.388354+00:00 2021-03-21T00:11:18.127711+00:00 0:00:02.739357 10182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T00:11:13.179090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T23:00:00+00:00 TriggerDagRunOperator 2021-03-21T00:10:56.079950+00:00 2021-03-21T00:10:56.454426+00:00 0:00:00.374476 10181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T00:10:53.167023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T23:00:00+00:00 TriggerDagRunOperator 2021-03-21T00:10:55.738464+00:00 2021-03-21T00:10:56.266660+00:00 0:00:00.528196 10180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T00:10:53.167052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T23:00:00+00:00 EmrJobFlowSensor 2021-03-21T00:00:46.279969+00:00 2021-03-21T00:10:49.035013+00:00 0:10:02.755044 10179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T00:00:44.038805+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T00:00:28.669119+00:00 2021-03-21T00:00:30.372871+00:00 0:00:01.703752 10178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T00:00:26.034722+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T23:00:00+00:00 PythonOperator 2021-03-21T00:00:12.303290+00:00 2021-03-21T00:00:15.066379+00:00 0:00:02.763089 10177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T00:00:10.025113+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T22:00:00+00:00 EmrJobFlowSensor 2021-03-20T23:12:05.209232+00:00 2021-03-20T23:21:07.793286+00:00 0:09:02.584054 10175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T23:12:03.037215+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T23:11:45.429351+00:00 2021-03-20T23:11:47.280170+00:00 0:00:01.850819 10174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T23:11:43.000521+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T22:00:00+00:00 PythonOperator 2021-03-20T23:11:19.526416+00:00 2021-03-20T23:11:22.405586+00:00 0:00:02.879170 10173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T23:11:16.978910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T22:00:00+00:00 TriggerDagRunOperator 2021-03-20T23:10:59.736310+00:00 2021-03-20T23:11:00.262995+00:00 0:00:00.526685 10172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T23:10:57.020095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T22:00:00+00:00 TriggerDagRunOperator 2021-03-20T23:10:59.369861+00:00 2021-03-20T23:10:59.775785+00:00 0:00:00.405924 10171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T23:10:57.020054+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T22:00:00+00:00 EmrJobFlowSensor 2021-03-20T23:00:48.101934+00:00 2021-03-20T23:10:50.830284+00:00 0:10:02.728350 10170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T23:00:45.882868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T23:00:30.364949+00:00 2021-03-20T23:00:32.261643+00:00 0:00:01.896694 10169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T23:00:27.918222+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T22:00:00+00:00 PythonOperator 2021-03-20T23:00:14.497658+00:00 2021-03-20T23:00:17.275979+00:00 0:00:02.778321 10168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T23:00:11.926753+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T21:00:00+00:00 EmrJobFlowSensor 2021-03-20T22:11:44.608762+00:00 2021-03-20T22:19:47.170279+00:00 0:08:02.561517 10166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T22:11:42.406769+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T22:11:29.051438+00:00 2021-03-20T22:11:30.903889+00:00 0:00:01.852451 10165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T22:11:26.390302+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T21:00:00+00:00 PythonOperator 2021-03-20T22:11:10.789053+00:00 2021-03-20T22:11:13.635364+00:00 0:00:02.846311 10164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T22:11:08.433754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T21:00:00+00:00 TriggerDagRunOperator 2021-03-20T22:11:04.992334+00:00 2021-03-20T22:11:05.576368+00:00 0:00:00.584034 10163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T22:11:02.435529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T21:00:00+00:00 TriggerDagRunOperator 2021-03-20T22:11:04.701111+00:00 2021-03-20T22:11:05.088467+00:00 0:00:00.387356 10162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T22:11:02.435564+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T21:00:00+00:00 EmrJobFlowSensor 2021-03-20T22:00:47.659970+00:00 2021-03-20T22:10:50.346937+00:00 0:10:02.686967 10161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T22:00:45.424476+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T22:00:31.427831+00:00 2021-03-20T22:00:33.131006+00:00 0:00:01.703175 10160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T22:00:29.294535+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T21:00:00+00:00 PythonOperator 2021-03-20T22:00:15.979813+00:00 2021-03-20T22:00:18.929047+00:00 0:00:02.949234 10159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T22:00:13.283341+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T20:00:00+00:00 EmrJobFlowSensor 2021-03-20T21:11:54.515236+00:00 2021-03-20T21:20:57.173880+00:00 0:09:02.658644 10157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T21:11:52.047890+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T21:11:36.330588+00:00 2021-03-20T21:11:38.175908+00:00 0:00:01.845320 10156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T21:11:33.967519+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T20:00:00+00:00 PythonOperator 2021-03-20T21:11:20.494745+00:00 2021-03-20T21:11:23.226290+00:00 0:00:02.731545 10155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T21:11:18.034305+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T20:00:00+00:00 TriggerDagRunOperator 2021-03-20T21:11:04.198028+00:00 2021-03-20T21:11:04.771175+00:00 0:00:00.573147 10154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T21:11:01.898946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T20:00:00+00:00 TriggerDagRunOperator 2021-03-20T21:11:04.099626+00:00 2021-03-20T21:11:04.541970+00:00 0:00:00.442344 10153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T21:11:01.898919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T20:00:00+00:00 EmrJobFlowSensor 2021-03-20T21:00:41.000401+00:00 2021-03-20T21:10:43.763406+00:00 0:10:02.763005 10152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T21:00:38.770835+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T21:00:25.134753+00:00 2021-03-20T21:00:26.960094+00:00 0:00:01.825341 10151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T21:00:22.759740+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T20:00:00+00:00 PythonOperator 2021-03-20T21:00:09.531791+00:00 2021-03-20T21:00:12.242616+00:00 0:00:02.710825 10150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T21:00:06.670065+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T19:00:00+00:00 EmrJobFlowSensor 2021-03-20T20:11:44.622726+00:00 2021-03-20T20:21:47.578874+00:00 0:10:02.956148 10148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T20:11:42.051574+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T20:11:28.181956+00:00 2021-03-20T20:11:29.886392+00:00 0:00:01.704436 10147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T20:11:25.990563+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T19:00:00+00:00 PythonOperator 2021-03-20T20:11:12.329694+00:00 2021-03-20T20:11:15.188679+00:00 0:00:02.858985 10146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T20:11:09.974715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T19:00:00+00:00 TriggerDagRunOperator 2021-03-20T20:10:54.605674+00:00 2021-03-20T20:10:55.135608+00:00 0:00:00.529934 10145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T20:10:52.029159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T19:00:00+00:00 TriggerDagRunOperator 2021-03-20T20:10:54.533087+00:00 2021-03-20T20:10:54.915261+00:00 0:00:00.382174 10144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T20:10:52.029116+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T19:00:00+00:00 EmrJobFlowSensor 2021-03-20T20:01:23.083253+00:00 2021-03-20T20:10:25.748625+00:00 0:09:02.665372 10143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T20:01:20.885359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T20:00:55.340133+00:00 2021-03-20T20:00:57.240236+00:00 0:00:01.900103 10142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T20:00:52.863718+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T19:00:00+00:00 PythonOperator 2021-03-20T20:00:39.690820+00:00 2021-03-20T20:00:42.395031+00:00 0:00:02.704211 10141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T20:00:36.731851+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T18:00:00+00:00 EmrJobFlowSensor 2021-03-20T19:11:58.551082+00:00 2021-03-20T19:21:01.381568+00:00 0:09:02.830486 10139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T19:11:56.060697+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T19:11:42.178340+00:00 2021-03-20T19:11:43.878649+00:00 0:00:01.700309 10138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T19:11:39.997473+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T18:00:00+00:00 PythonOperator 2021-03-20T19:11:26.180259+00:00 2021-03-20T19:11:28.900709+00:00 0:00:02.720450 10137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T19:11:23.990342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T18:00:00+00:00 TriggerDagRunOperator 2021-03-20T19:11:06.389865+00:00 2021-03-20T19:11:06.809239+00:00 0:00:00.419374 10136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T19:11:03.966095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T18:00:00+00:00 TriggerDagRunOperator 2021-03-20T19:11:06.331920+00:00 2021-03-20T19:11:06.936049+00:00 0:00:00.604129 10135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T19:11:03.966068+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T18:00:00+00:00 EmrJobFlowSensor 2021-03-20T19:00:51.250520+00:00 2021-03-20T19:10:54.084865+00:00 0:10:02.834345 10134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T19:00:49.024301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T19:00:35.104092+00:00 2021-03-20T19:00:36.799315+00:00 0:00:01.695223 10133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T19:00:32.945061+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T18:00:00+00:00 PythonOperator 2021-03-20T19:00:19.617436+00:00 2021-03-20T19:00:22.520607+00:00 0:00:02.903171 10132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T19:00:16.887320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T17:00:00+00:00 EmrJobFlowSensor 2021-03-20T18:11:14.179818+00:00 2021-03-20T18:20:16.827932+00:00 0:09:02.648114 10130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T18:11:11.818515+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T18:10:57.970474+00:00 2021-03-20T18:10:59.695091+00:00 0:00:01.724617 10129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T18:10:55.689555+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T17:00:00+00:00 PythonOperator 2021-03-20T18:10:37.900484+00:00 2021-03-20T18:10:40.590779+00:00 0:00:02.690295 10128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T18:10:35.670110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T17:00:00+00:00 TriggerDagRunOperator 2021-03-20T18:10:14.071738+00:00 2021-03-20T18:10:14.598521+00:00 0:00:00.526783 10127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T18:10:11.607297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T17:00:00+00:00 TriggerDagRunOperator 2021-03-20T18:10:13.846051+00:00 2021-03-20T18:10:14.301251+00:00 0:00:00.455200 10126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T18:10:11.607324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T17:00:00+00:00 EmrJobFlowSensor 2021-03-20T18:00:52.705147+00:00 2021-03-20T18:09:55.248080+00:00 0:09:02.542933 10125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T18:00:50.465901+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T18:00:36.509949+00:00 2021-03-20T18:00:38.238977+00:00 0:00:01.729028 10124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T18:00:34.349237+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T17:00:00+00:00 PythonOperator 2021-03-20T18:00:08.894113+00:00 2021-03-20T18:00:11.608636+00:00 0:00:02.714523 10123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T18:00:06.290054+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T16:00:00+00:00 EmrJobFlowSensor 2021-03-20T17:11:37.242696+00:00 2021-03-20T17:30:41.170703+00:00 0:19:03.928007 10121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T17:11:35.080637+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T17:11:21.288758+00:00 2021-03-20T17:11:22.997989+00:00 0:00:01.709231 10120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T17:11:19.123496+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T16:00:00+00:00 PythonOperator 2021-03-20T17:11:05.488419+00:00 2021-03-20T17:11:08.390659+00:00 0:00:02.902240 10119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T17:11:03.051673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T16:00:00+00:00 TriggerDagRunOperator 2021-03-20T17:10:45.767822+00:00 2021-03-20T17:10:46.285000+00:00 0:00:00.517178 10118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T17:10:42.987730+00:00 2 default_pool