Task Instances

Reset Filters
  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 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 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 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 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 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-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 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-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 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-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T16:00:00+00:00 TriggerDagRunOperator 2021-04-23T17:11:28.750440+00:00 2021-04-23T17:11:29.238222+00:00 0:00:00.487782 20447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T17:11:25.975592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T16:00:00+00:00 TriggerDagRunOperator 2021-04-23T17:11:28.304899+00:00 2021-04-23T17:11:28.737885+00:00 0:00:00.432986 20446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T17:11:25.975554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T16:00:00+00:00 EmrJobFlowSensor 2021-04-23T17:02:13.345127+00:00 2021-04-23T17:11:16.507794+00:00 0:09:03.162667 20442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T17:02:11.056063+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T17:01:53.318699+00:00 2021-04-23T17:01:55.028670+00:00 0:00:01.709971 20441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T17:01:51.085323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T16:00:00+00:00 PythonOperator 2021-04-23T17:01:33.433891+00:00 2021-04-23T17:01:36.445412+00:00 0:00:03.011521 20440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T17:01:30.686195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T15:00:00+00:00 TriggerDagRunOperator 2021-04-23T16:11:15.136087+00:00 2021-04-23T16:11:15.635972+00:00 0:00:00.499885 20432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T16:11:12.587641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T15:00:00+00:00 TriggerDagRunOperator 2021-04-23T16:11:14.892379+00:00 2021-04-23T16:11:15.314726+00:00 0:00:00.422347 20431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T16:11:12.587610+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T15:00:00+00:00 EmrJobFlowSensor 2021-04-23T16:01:05.786703+00:00 2021-04-23T16:11:08.746279+00:00 0:10:02.959576 20427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T16:01:03.558854+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T16:00:43.708616+00:00 2021-04-23T16:00:45.556649+00:00 0:00:01.848033 20426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T16:00:41.472485+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T15:00:00+00:00 PythonOperator 2021-04-23T16:00:21.837775+00:00 2021-04-23T16:00:24.820230+00:00 0:00:02.982455 20425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T16:00:19.404702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T14:00:00+00:00 TriggerDagRunOperator 2021-04-23T15:11:08.162642+00:00 2021-04-23T15:11:08.792251+00:00 0:00:00.629609 20417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T15:11:05.155507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T14:00:00+00:00 TriggerDagRunOperator 2021-04-23T15:11:07.535595+00:00 2021-04-23T15:11:07.929365+00:00 0:00:00.393770 20416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T15:11:05.155539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T14:00:00+00:00 EmrJobFlowSensor 2021-04-23T15:00:48.181481+00:00 2021-04-23T15:10:51.053665+00:00 0:10:02.872184 20412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T15:00:46.012072+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T15:00:26.192913+00:00 2021-04-23T15:00:27.948511+00:00 0:00:01.755598 20411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T15:00:23.995476+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T14:00:00+00:00 PythonOperator 2021-04-23T15:00:06.311464+00:00 2021-04-23T15:00:09.351660+00:00 0:00:03.040196 20410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T15:00:03.913760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T13:00:00+00:00 TriggerDagRunOperator 2021-04-23T14:10:25.025386+00:00 2021-04-23T14:10:25.582977+00:00 0:00:00.557591 20402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T14:10:22.707095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T13:00:00+00:00 TriggerDagRunOperator 2021-04-23T14:10:24.998670+00:00 2021-04-23T14:10:25.478874+00:00 0:00:00.480204 20401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T14:10:22.707123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T13:00:00+00:00 EmrJobFlowSensor 2021-04-23T14:01:02.324766+00:00 2021-04-23T14:10:05.164746+00:00 0:09:02.839980 20397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T14:00:59.953045+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T14:00:40.365052+00:00 2021-04-23T14:00:42.042412+00:00 0:00:01.677360 20396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T14:00:37.851846+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T13:00:00+00:00 PythonOperator 2021-04-23T14:00:18.566769+00:00 2021-04-23T14:00:21.567048+00:00 0:00:03.000279 20395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T14:00:15.779448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T12:00:00+00:00 TriggerDagRunOperator 2021-04-23T13:10:20.127616+00:00 2021-04-23T13:10:20.657252+00:00 0:00:00.529636 20387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T13:10:17.794440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T12:00:00+00:00 TriggerDagRunOperator 2021-04-23T13:10:19.989383+00:00 2021-04-23T13:10:20.443836+00:00 0:00:00.454453 20386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T13:10:17.794474+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T12:00:00+00:00 EmrJobFlowSensor 2021-04-23T13:00:55.345471+00:00 2021-04-23T13:09:58.162656+00:00 0:09:02.817185 20382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T13:00:52.841839+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T13:00:35.199166+00:00 2021-04-23T13:00:37.016225+00:00 0:00:01.817059 20381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T13:00:32.826112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T12:00:00+00:00 PythonOperator 2021-04-23T13:00:13.026167+00:00 2021-04-23T13:00:16.280983+00:00 0:00:03.254816 20380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T13:00:10.715556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T11:00:00+00:00 TriggerDagRunOperator 2021-04-23T12:11:30.485742+00:00 2021-04-23T12:11:30.920352+00:00 0:00:00.434610 20370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T12:11:27.835379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T11:00:00+00:00 TriggerDagRunOperator 2021-04-23T12:11:30.407090+00:00 2021-04-23T12:11:30.949882+00:00 0:00:00.542792 20369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T12:11:27.835436+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T11:00:00+00:00 EmrJobFlowSensor 2021-04-23T12:00:48.308088+00:00 2021-04-23T12:09:50.951762+00:00 0:09:02.643674 20367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T12:00:46.016857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T12:00:28.561785+00:00 2021-04-23T12:00:30.385863+00:00 0:00:01.824078 20366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T12:00:25.998670+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T11:00:00+00:00 PythonOperator 2021-04-23T12:00:06.336018+00:00 2021-04-23T12:00:09.901869+00:00 0:00:03.565851 20365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T12:00:04.044643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T10:00:00+00:00 TriggerDagRunOperator 2021-04-23T11:11:13.788287+00:00 2021-04-23T11:11:14.314131+00:00 0:00:00.525844 20358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T11:11:11.338734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T10:00:00+00:00 TriggerDagRunOperator 2021-04-23T11:11:13.570338+00:00 2021-04-23T11:11:14.006889+00:00 0:00:00.436551 20357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T11:11:11.338763+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T10:00:00+00:00 EmrJobFlowSensor 2021-04-23T11:01:05.718373+00:00 2021-04-23T11:11:08.564166+00:00 0:10:02.845793 20352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T11:01:03.385473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T11:00:43.558271+00:00 2021-04-23T11:00:45.266545+00:00 0:00:01.708274 20351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T11:00:41.363387+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T10:00:00+00:00 PythonOperator 2021-04-23T11:00:21.755666+00:00 2021-04-23T11:00:24.941018+00:00 0:00:03.185352 20350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T11:00:19.344373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T09:00:00+00:00 TriggerDagRunOperator 2021-04-23T10:15:03.125380+00:00 2021-04-23T10:15:03.547718+00:00 0:00:00.422338 20343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T10:15:00.679637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T09:00:00+00:00 TriggerDagRunOperator 2021-04-23T10:15:02.911761+00:00 2021-04-23T10:15:03.463496+00:00 0:00:00.551735 20342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T10:15:00.679608+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T09:00:00+00:00 EmrJobFlowSensor 2021-04-23T10:03:48.139714+00:00 2021-04-23T10:14:51.093555+00:00 0:11:02.953841 20338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T10:03:45.773278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T10:03:25.881506+00:00 2021-04-23T10:03:27.564795+00:00 0:00:01.683289 20337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T10:03:23.703748+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T09:00:00+00:00 PythonOperator 2021-04-23T10:03:04.101849+00:00 2021-04-23T10:03:07.107579+00:00 0:00:03.005730 20336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T10:03:01.678697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T08:00:00+00:00 TriggerDagRunOperator 2021-04-23T09:11:06.837462+00:00 2021-04-23T09:11:07.368608+00:00 0:00:00.531146 20328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T09:11:04.364669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T08:00:00+00:00 TriggerDagRunOperator 2021-04-23T09:11:06.745603+00:00 2021-04-23T09:11:07.170056+00:00 0:00:00.424453 20327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T09:11:04.364711+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T08:00:00+00:00 EmrJobFlowSensor 2021-04-23T09:00:55.697818+00:00 2021-04-23T09:10:58.447578+00:00 0:10:02.749760 20323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T09:00:53.362924+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T09:00:35.736579+00:00 2021-04-23T09:00:37.662602+00:00 0:00:01.926023 20322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T09:00:33.340800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T08:00:00+00:00 PythonOperator 2021-04-23T09:00:13.705783+00:00 2021-04-23T09:00:16.677920+00:00 0:00:02.972137 20321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T09:00:11.280186+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T07:00:00+00:00 TriggerDagRunOperator 2021-04-23T08:11:22.882635+00:00 2021-04-23T08:11:23.386287+00:00 0:00:00.503652 20313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T08:11:20.424733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T07:00:00+00:00 TriggerDagRunOperator 2021-04-23T08:11:22.690622+00:00 2021-04-23T08:11:23.102674+00:00 0:00:00.412052 20312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T08:11:20.424771+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T07:00:00+00:00 EmrJobFlowSensor 2021-04-23T08:01:05.844037+00:00 2021-04-23T08:11:08.651209+00:00 0:10:02.807172 20308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T08:01:03.624125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T08:00:44.094149+00:00 2021-04-23T08:00:45.902663+00:00 0:00:01.808514 20307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T08:00:41.662558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T07:00:00+00:00 PythonOperator 2021-04-23T08:00:22.029579+00:00 2021-04-23T08:00:24.991579+00:00 0:00:02.962000 20306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T08:00:19.589297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T06:00:00+00:00 TriggerDagRunOperator 2021-04-23T07:10:13.210539+00:00 2021-04-23T07:10:13.699956+00:00 0:00:00.489417 20298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T07:10:10.562144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T06:00:00+00:00 TriggerDagRunOperator 2021-04-23T07:10:13.048964+00:00 2021-04-23T07:10:13.593421+00:00 0:00:00.544457 20297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T07:10:10.562179+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T06:00:00+00:00 EmrJobFlowSensor 2021-04-23T07:01:05.633985+00:00 2021-04-23T07:10:08.365358+00:00 0:09:02.731373 20293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T07:01:03.421710+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T07:00:41.794661+00:00 2021-04-23T07:00:43.537496+00:00 0:00:01.742835 20292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T07:00:39.459523+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T06:00:00+00:00 PythonOperator 2021-04-23T07:00:13.631581+00:00 2021-04-23T07:00:16.584854+00:00 0:00:02.953273 20291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T07:00:11.382034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T05:00:00+00:00 TriggerDagRunOperator 2021-04-23T06:11:11.852296+00:00 2021-04-23T06:11:12.310753+00:00 0:00:00.458457 20283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T06:11:09.179917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T05:00:00+00:00 TriggerDagRunOperator 2021-04-23T06:11:11.799300+00:00 2021-04-23T06:11:12.391049+00:00 0:00:00.591749 20282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T06:11:09.179964+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T05:00:00+00:00 EmrJobFlowSensor 2021-04-23T06:00:50.300993+00:00 2021-04-23T06:10:53.291308+00:00 0:10:02.990315 20278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T06:00:47.979944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T06:00:28.103090+00:00 2021-04-23T06:00:29.794321+00:00 0:00:01.691231 20277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T06:00:25.905285+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T05:00:00+00:00 PythonOperator 2021-04-23T06:00:06.256135+00:00 2021-04-23T06:00:09.241968+00:00 0:00:02.985833 20276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T06:00:03.885579+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T04:00:00+00:00 TriggerDagRunOperator 2021-04-23T05:11:04.838461+00:00 2021-04-23T05:11:05.436037+00:00 0:00:00.597576 20268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T05:11:01.744516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T04:00:00+00:00 TriggerDagRunOperator 2021-04-23T05:11:04.078236+00:00 2021-04-23T05:11:04.466722+00:00 0:00:00.388486 20267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T05:11:01.744551+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T04:00:00+00:00 EmrJobFlowSensor 2021-04-23T05:00:52.865767+00:00 2021-04-23T05:10:55.656403+00:00 0:10:02.790636 20263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T05:00:50.505796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T05:00:30.902966+00:00 2021-04-23T05:00:32.641940+00:00 0:00:01.738974 20262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T05:00:28.543404+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T04:00:00+00:00 PythonOperator 2021-04-23T05:00:08.867272+00:00 2021-04-23T05:00:11.903371+00:00 0:00:03.036099 20261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T05:00:06.421859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T03:00:00+00:00 TriggerDagRunOperator 2021-04-23T04:12:18.578824+00:00 2021-04-23T04:12:19.132544+00:00 0:00:00.553720 20253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T04:12:15.943567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T03:00:00+00:00 TriggerDagRunOperator 2021-04-23T04:12:18.512932+00:00 2021-04-23T04:12:18.947025+00:00 0:00:00.434093 20252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T04:12:15.943603+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T03:00:00+00:00 EmrJobFlowSensor 2021-04-23T04:01:05.496134+00:00 2021-04-23T04:12:08.567387+00:00 0:11:03.071253 20248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T04:01:02.547607+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T04:00:42.879652+00:00 2021-04-23T04:00:45.125753+00:00 0:00:02.246101 20247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T04:00:40.490755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T03:00:00+00:00 PythonOperator 2021-04-23T04:00:20.723855+00:00 2021-04-23T04:00:23.684432+00:00 0:00:02.960577 20246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T04:00:18.378252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T02:00:00+00:00 TriggerDagRunOperator 2021-04-23T03:12:15.436566+00:00 2021-04-23T03:12:15.944947+00:00 0:00:00.508381 20238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T03:12:12.953086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T02:00:00+00:00 TriggerDagRunOperator 2021-04-23T03:12:15.290589+00:00 2021-04-23T03:12:15.723975+00:00 0:00:00.433386 20237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T03:12:12.953133+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T02:00:00+00:00 EmrJobFlowSensor 2021-04-23T03:00:57.204942+00:00 2021-04-23T03:12:00.153573+00:00 0:11:02.948631 20233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T03:00:55.087742+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T03:00:35.295982+00:00 2021-04-23T03:00:37.011384+00:00 0:00:01.715402 20232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T03:00:33.037209+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T02:00:00+00:00 PythonOperator 2021-04-23T03:00:13.371519+00:00 2021-04-23T03:00:16.689279+00:00 0:00:03.317760 20231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T03:00:11.019888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T01:00:00+00:00 TriggerDagRunOperator 2021-04-23T02:12:28.487318+00:00 2021-04-23T02:12:29.033822+00:00 0:00:00.546504 20223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T02:12:26.059721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T01:00:00+00:00 TriggerDagRunOperator 2021-04-23T02:12:28.254225+00:00 2021-04-23T02:12:28.742115+00:00 0:00:00.487890 20222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T02:12:26.059688+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T01:00:00+00:00 EmrJobFlowSensor 2021-04-23T02:01:01.526042+00:00 2021-04-23T02:12:04.726044+00:00 0:11:03.200002 20218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T02:00:59.057875+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T02:00:39.174584+00:00 2021-04-23T02:00:40.855124+00:00 0:00:01.680540 20217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T02:00:36.958294+00:00 2 default_pool