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-17T05:00:00+00:00 PythonOperator 2021-04-17T06:13:40.246069+00:00 2021-04-17T06:13:43.212536+00:00 0:00:02.966467 18084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T06:13:37.976030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T04:00:00+00:00 TriggerDagRunOperator 2021-04-17T05:12:04.512349+00:00 2021-04-17T05:12:05.296122+00:00 0:00:00.783773 18075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T05:12:02.167440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T04:00:00+00:00 TriggerDagRunOperator 2021-04-17T05:12:04.490122+00:00 2021-04-17T05:12:05.400350+00:00 0:00:00.910228 18074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T05:12:02.167406+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T04:00:00+00:00 EmrJobFlowSensor 2021-04-17T05:00:47.562785+00:00 2021-04-17T05:11:50.429473+00:00 0:11:02.866688 18070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T05:00:45.254909+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T05:00:27.307109+00:00 2021-04-17T05:00:29.013557+00:00 0:00:01.706448 18069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T05:00:25.109637+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T04:00:00+00:00 PythonOperator 2021-04-17T05:00:05.776643+00:00 2021-04-17T05:00:08.750250+00:00 0:00:02.973607 18068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T05:00:03.086064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T03:00:00+00:00 TriggerDagRunOperator 2021-04-17T04:10:46.379265+00:00 2021-04-17T04:10:46.893144+00:00 0:00:00.513879 18060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:10:43.992123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T03:00:00+00:00 TriggerDagRunOperator 2021-04-17T04:10:46.180663+00:00 2021-04-17T04:10:46.590625+00:00 0:00:00.409962 18059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:10:43.992093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T03:00:00+00:00 EmrJobFlowSensor 2021-04-17T04:00:59.408309+00:00 2021-04-17T04:10:02.131409+00:00 0:09:02.723100 18055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T04:00:57.204879+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T04:00:39.370412+00:00 2021-04-17T04:00:41.075990+00:00 0:00:01.705578 18054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T04:00:37.186459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T03:00:00+00:00 PythonOperator 2021-04-17T04:00:13.544242+00:00 2021-04-17T04:00:16.584886+00:00 0:00:03.040644 18053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T04:00:11.084329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T02:00:00+00:00 TriggerDagRunOperator 2021-04-17T03:09:19.474683+00:00 2021-04-17T03:09:20.055520+00:00 0:00:00.580837 18045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:09:16.914819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T02:00:00+00:00 TriggerDagRunOperator 2021-04-17T03:09:19.362304+00:00 2021-04-17T03:09:19.784620+00:00 0:00:00.422316 18044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:09:16.914856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T02:00:00+00:00 EmrJobFlowSensor 2021-04-17T03:01:09.660955+00:00 2021-04-17T03:09:12.131203+00:00 0:08:02.470248 18040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:01:06.615207+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:00:44.732258+00:00 2021-04-17T03:00:46.541628+00:00 0:00:01.809370 18039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T03:00:42.591357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T02:00:00+00:00 PythonOperator 2021-04-17T03:00:23.158739+00:00 2021-04-17T03:00:26.048437+00:00 0:00:02.889698 18038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T03:00:20.583776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T01:00:00+00:00 TriggerDagRunOperator 2021-04-17T02:11:19.469474+00:00 2021-04-17T02:11:19.989096+00:00 0:00:00.519622 18030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:11:17.004247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T01:00:00+00:00 TriggerDagRunOperator 2021-04-17T02:11:19.213969+00:00 2021-04-17T02:11:19.626006+00:00 0:00:00.412037 18029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:11:17.004280+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T01:00:00+00:00 EmrJobFlowSensor 2021-04-17T02:01:06.316656+00:00 2021-04-17T02:11:09.251917+00:00 0:10:02.935261 18025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:01:03.970301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:00:46.143793+00:00 2021-04-17T02:00:47.958733+00:00 0:00:01.814940 18024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T02:00:43.896283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T01:00:00+00:00 PythonOperator 2021-04-17T02:00:24.318562+00:00 2021-04-17T02:00:27.472801+00:00 0:00:03.154239 18023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T02:00:21.947599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T00:00:00+00:00 TriggerDagRunOperator 2021-04-17T01:11:07.174848+00:00 2021-04-17T01:11:07.764511+00:00 0:00:00.589663 18015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:11:04.263350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T00:00:00+00:00 TriggerDagRunOperator 2021-04-17T01:11:06.686716+00:00 2021-04-17T01:11:07.095997+00:00 0:00:00.409281 18014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:11:04.263308+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:00:53.306866+00:00 2021-04-17T01:10:56.213570+00:00 0:10:02.906704 18010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:00:51.062426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:00:33.812782+00:00 2021-04-17T01:00:35.582141+00:00 0:00:01.769359 18009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T01:00:31.022968+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:00:10.185269+00:00 2021-04-17T01:00:13.135840+00:00 0:00:02.950571 18008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T01:00:07.064704+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T23:00:00+00:00 TriggerDagRunOperator 2021-04-17T00:10:17.919690+00:00 2021-04-17T00:10:18.333895+00:00 0:00:00.414205 18000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:10:15.223944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T23:00:00+00:00 TriggerDagRunOperator 2021-04-17T00:10:17.921573+00:00 2021-04-17T00:10:18.493554+00:00 0:00:00.571981 17999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:10:15.223994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:01:06.497787+00:00 2021-04-17T00:10:09.198966+00:00 0:09:02.701179 17995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:01:04.342935+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:00:42.815077+00:00 2021-04-17T00:00:44.596200+00:00 0:00:01.781123 17994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T00:00:40.320549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:00:22.899299+00:00 2021-04-17T00:00:26.070296+00:00 0:00:03.170997 17993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T00:00:20.307451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T22:00:00+00:00 TriggerDagRunOperator 2021-04-16T23:11:14.863920+00:00 2021-04-16T23:11:15.404395+00:00 0:00:00.540475 17985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:11:12.397547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T22:00:00+00:00 TriggerDagRunOperator 2021-04-16T23:11:14.642413+00:00 2021-04-16T23:11:15.079326+00:00 0:00:00.436913 17984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:11:12.397492+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:00:51.518757+00:00 2021-04-16T23:10:54.213462+00:00 0:10:02.694705 17980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:00:49.322403+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:00:29.934696+00:00 2021-04-16T23:00:31.745517+00:00 0:00:01.810821 17979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T23:00:27.374361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:00:10.108217+00:00 2021-04-16T23:00:13.153618+00:00 0:00:03.045401 17978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T23:00:07.347534+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T21:00:00+00:00 TriggerDagRunOperator 2021-04-16T22:09:20.226587+00:00 2021-04-16T22:09:20.775518+00:00 0:00:00.548931 17970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:09:17.551745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T21:00:00+00:00 TriggerDagRunOperator 2021-04-16T22:09:19.941541+00:00 2021-04-16T22:09:20.357993+00:00 0:00:00.416452 17969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:09:17.551708+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T21:00:00+00:00 EmrJobFlowSensor 2021-04-16T22:00:58.486177+00:00 2021-04-16T22:09:01.112145+00:00 0:08:02.625968 17965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:00:56.205098+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:00:36.311434+00:00 2021-04-16T22:00:38.041643+00:00 0:00:01.730209 17964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T22:00:34.185893+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T21:00:00+00:00 PythonOperator 2021-04-16T22:00:16.461096+00:00 2021-04-16T22:00:19.370508+00:00 0:00:02.909412 17963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T22:00:14.109327+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T20:00:00+00:00 TriggerDagRunOperator 2021-04-16T21:09:30.825033+00:00 2021-04-16T21:09:31.355985+00:00 0:00:00.530952 17954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:09:27.967631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T20:00:00+00:00 TriggerDagRunOperator 2021-04-16T21:09:30.716780+00:00 2021-04-16T21:09:31.171815+00:00 0:00:00.455035 17953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:09:27.967677+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T20:00:00+00:00 EmrJobFlowSensor 2021-04-16T21:01:01.895392+00:00 2021-04-16T21:09:04.552786+00:00 0:08:02.657394 17949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:00:59.166299+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:00:39.820884+00:00 2021-04-16T21:00:41.707118+00:00 0:00:01.886234 17948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T21:00:37.152472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T20:00:00+00:00 PythonOperator 2021-04-16T21:00:17.310636+00:00 2021-04-16T21:00:20.237209+00:00 0:00:02.926573 17947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T21:00:15.033987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T19:00:00+00:00 TriggerDagRunOperator 2021-04-16T20:09:31.153781+00:00 2021-04-16T20:09:31.699922+00:00 0:00:00.546141 17937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:09:28.464637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T19:00:00+00:00 TriggerDagRunOperator 2021-04-16T20:09:31.054234+00:00 2021-04-16T20:09:31.498321+00:00 0:00:00.444087 17936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:09:28.464691+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T19:00:00+00:00 EmrJobFlowSensor 2021-04-16T20:01:03.965920+00:00 2021-04-16T20:09:06.560666+00:00 0:08:02.594746 17932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:01:01.620407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:00:40.010013+00:00 2021-04-16T20:00:41.712559+00:00 0:00:01.702546 17931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T20:00:37.664296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T19:00:00+00:00 PythonOperator 2021-04-16T20:00:18.111485+00:00 2021-04-16T20:00:21.074635+00:00 0:00:02.963150 17930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T20:00:15.650421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T18:00:00+00:00 TriggerDagRunOperator 2021-04-16T19:10:03.828864+00:00 2021-04-16T19:10:04.274128+00:00 0:00:00.445264 17922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:01.156725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T18:00:00+00:00 TriggerDagRunOperator 2021-04-16T19:10:03.837504+00:00 2021-04-16T19:10:04.442519+00:00 0:00:00.605015 17921 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:01.156674+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T18:00:00+00:00 EmrJobFlowSensor 2021-04-16T19:00:52.694838+00:00 2021-04-16T19:09:55.419939+00:00 0:09:02.725101 17917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:00:50.059274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:00:28.868541+00:00 2021-04-16T19:00:30.555485+00:00 0:00:01.686944 17916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T19:00:26.043622+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T18:00:00+00:00 PythonOperator 2021-04-16T19:00:08.342826+00:00 2021-04-16T19:00:11.344698+00:00 0:00:03.001872 17915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T19:00:05.987444+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T17:00:00+00:00 TriggerDagRunOperator 2021-04-16T18:09:07.160451+00:00 2021-04-16T18:09:07.572129+00:00 0:00:00.411678 17907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:09:04.746804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T17:00:00+00:00 TriggerDagRunOperator 2021-04-16T18:09:06.976858+00:00 2021-04-16T18:09:07.545779+00:00 0:00:00.568921 17906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:09:04.746834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T17:00:00+00:00 EmrJobFlowSensor 2021-04-16T18:01:00.441872+00:00 2021-04-16T18:09:03.054964+00:00 0:08:02.613092 17902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:00:58.079013+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:00:34.697177+00:00 2021-04-16T18:00:36.586707+00:00 0:00:01.889530 17901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T18:00:32.006223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T17:00:00+00:00 PythonOperator 2021-04-16T18:00:12.527430+00:00 2021-04-16T18:00:15.466164+00:00 0:00:02.938734 17900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T18:00:09.989832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T16:00:00+00:00 TriggerDagRunOperator 2021-04-16T17:11:22.312010+00:00 2021-04-16T17:11:22.877231+00:00 0:00:00.565221 17892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:11:19.860804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T16:00:00+00:00 TriggerDagRunOperator 2021-04-16T17:11:22.224630+00:00 2021-04-16T17:11:22.669449+00:00 0:00:00.444819 17891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:11:19.860774+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T16:00:00+00:00 EmrJobFlowSensor 2021-04-16T17:00:54.536129+00:00 2021-04-16T17:10:57.215410+00:00 0:10:02.679281 17887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:00:52.305596+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:00:32.702892+00:00 2021-04-16T17:00:34.968408+00:00 0:00:02.265516 17886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T17:00:30.282635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T16:00:00+00:00 PythonOperator 2021-04-16T17:00:10.449889+00:00 2021-04-16T17:00:13.383638+00:00 0:00:02.933749 17885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T17:00:08.203967+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T15:00:00+00:00 TriggerDagRunOperator 2021-04-16T16:34:40.565431+00:00 2021-04-16T16:34:41.001225+00:00 0:00:00.435794 17878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:34:37.683593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T15:00:00+00:00 TriggerDagRunOperator 2021-04-16T16:34:40.394228+00:00 2021-04-16T16:34:40.934574+00:00 0:00:00.540346 17877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:34:37.683627+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T15:00:00+00:00 EmrJobFlowSensor 2021-04-16T16:25:26.787593+00:00 2021-04-16T16:34:29.510253+00:00 0:09:02.722660 17875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:25:24.531098+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:25:06.676669+00:00 2021-04-16T16:25:08.399702+00:00 0:00:01.723033 17873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T16:25:04.515362+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T15:00:00+00:00 PythonOperator 2021-04-16T16:24:45.337541+00:00 2021-04-16T16:24:48.431158+00:00 0:00:03.093617 17871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T16:24:42.518989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T14:00:00+00:00 TriggerDagRunOperator 2021-04-16T15:10:19.328593+00:00 2021-04-16T15:10:19.745725+00:00 0:00:00.417132 17863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:10:16.849196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T14:00:00+00:00 TriggerDagRunOperator 2021-04-16T15:10:19.166321+00:00 2021-04-16T15:10:19.706724+00:00 0:00:00.540403 17862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:10:16.849146+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T14:00:00+00:00 EmrJobFlowSensor 2021-04-16T15:01:04.160507+00:00 2021-04-16T15:10:06.815398+00:00 0:09:02.654891 17858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:01:01.752081+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:00:41.924476+00:00 2021-04-16T15:00:43.806044+00:00 0:00:01.881568 17857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T15:00:39.733131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T14:00:00+00:00 PythonOperator 2021-04-16T15:00:20.822070+00:00 2021-04-16T15:00:23.794395+00:00 0:00:02.972325 17856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T15:00:17.741887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T13:00:00+00:00 TriggerDagRunOperator 2021-04-16T14:10:24.270586+00:00 2021-04-16T14:10:24.718593+00:00 0:00:00.448007 17848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:10:21.907563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T13:00:00+00:00 TriggerDagRunOperator 2021-04-16T14:10:24.207679+00:00 2021-04-16T14:10:24.793360+00:00 0:00:00.585681 17847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:10:21.907534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T13:00:00+00:00 EmrJobFlowSensor 2021-04-16T14:00:57.633599+00:00 2021-04-16T14:10:00.160289+00:00 0:09:02.526690 17843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:00:54.925540+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:00:35.247585+00:00 2021-04-16T14:00:37.076962+00:00 0:00:01.829377 17842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T14:00:32.906194+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:00:13.230783+00:00 2021-04-16T14:00:16.719074+00:00 0:00:03.488291 17841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T14:00:10.891633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T12:00:00+00:00 TriggerDagRunOperator 2021-04-16T13:11:14.715883+00:00 2021-04-16T13:11:15.239509+00:00 0:00:00.523626 17833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:11:12.334071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T12:00:00+00:00 TriggerDagRunOperator 2021-04-16T13:11:14.507208+00:00 2021-04-16T13:11:14.922780+00:00 0:00:00.415572 17832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:11:12.334104+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T12:00:00+00:00 EmrJobFlowSensor 2021-04-16T13:00:55.613299+00:00 2021-04-16T13:10:58.362129+00:00 0:10:02.748830 17828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:00:53.446326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:00:35.597091+00:00 2021-04-16T13:00:37.558766+00:00 0:00:01.961675 17827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T13:00:33.432263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T12:00:00+00:00 PythonOperator 2021-04-16T13:00:14.490497+00:00 2021-04-16T13:00:17.412732+00:00 0:00:02.922235 17826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T13:00:11.540884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T11:00:00+00:00 TriggerDagRunOperator 2021-04-16T12:11:23.946296+00:00 2021-04-16T12:11:24.470300+00:00 0:00:00.524004 17818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:11:21.621361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T11:00:00+00:00 TriggerDagRunOperator 2021-04-16T12:11:23.793789+00:00 2021-04-16T12:11:24.209842+00:00 0:00:00.416053 17817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:11:21.621390+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T11:00:00+00:00 EmrJobFlowSensor 2021-04-16T12:01:04.783376+00:00 2021-04-16T12:11:08.180879+00:00 0:10:03.397503 17813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T12:01:02.476392+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T12:00:42.589650+00:00 2021-04-16T12:00:44.276108+00:00 0:00:01.686458 17812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T12:00:40.456793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T11:00:00+00:00 PythonOperator 2021-04-16T12:00:22.882887+00:00 2021-04-16T12:00:26.383636+00:00 0:00:03.500749 17811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T12:00:20.444042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T10:00:00+00:00 TriggerDagRunOperator 2021-04-16T11:10:25.666456+00:00 2021-04-16T11:10:26.171866+00:00 0:00:00.505410 17803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T11:10:23.099029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T10:00:00+00:00 TriggerDagRunOperator 2021-04-16T11:10:25.439031+00:00 2021-04-16T11:10:25.865124+00:00 0:00:00.426093 17802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T11:10:23.098998+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T10:00:00+00:00 EmrJobFlowSensor 2021-04-16T11:00:58.310063+00:00 2021-04-16T11:10:01.119405+00:00 0:09:02.809342 17798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T11:00:56.006247+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T11:00:28.384517+00:00 2021-04-16T11:00:30.121106+00:00 0:00:01.736589 17797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T11:00:26.040720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T10:00:00+00:00 PythonOperator 2021-04-16T11:00:08.925075+00:00 2021-04-16T11:00:11.884565+00:00 0:00:02.959490 17796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T11:00:05.854508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T09:00:00+00:00 TriggerDagRunOperator 2021-04-16T10:11:08.898944+00:00 2021-04-16T10:11:09.431931+00:00 0:00:00.532987 17788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T10:11:06.258999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T09:00:00+00:00 TriggerDagRunOperator 2021-04-16T10:11:08.787331+00:00 2021-04-16T10:11:09.241179+00:00 0:00:00.453848 17787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T10:11:06.259053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T09:00:00+00:00 EmrJobFlowSensor 2021-04-16T10:00:57.558462+00:00 2021-04-16T10:11:00.304362+00:00 0:10:02.745900 17783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T10:00:55.411483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T10:00:35.720092+00:00 2021-04-16T10:00:37.586482+00:00 0:00:01.866390 17782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T10:00:33.396085+00:00 2 default_pool