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-05-04T17:00:00+00:00 PythonOperator 2021-05-04T18:00:05.443274+00:00 2021-05-04T18:00:08.607420+00:00 0:00:03.164146 24449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T18:00:03.019169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T16:00:00+00:00 TriggerDagRunOperator 2021-05-04T17:11:21.976206+00:00 2021-05-04T17:11:22.506801+00:00 0:00:00.530595 24441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T17:11:19.695099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T16:00:00+00:00 TriggerDagRunOperator 2021-05-04T17:11:21.887024+00:00 2021-05-04T17:11:22.325218+00:00 0:00:00.438194 24440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T17:11:19.695133+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T16:00:00+00:00 EmrJobFlowSensor 2021-05-04T17:01:00.590060+00:00 2021-05-04T17:11:03.448069+00:00 0:10:02.858009 24436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T17:00:58.050689+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T17:00:40.348555+00:00 2021-05-04T17:00:42.050921+00:00 0:00:01.702366 24435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T17:00:37.864424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T16:00:00+00:00 PythonOperator 2021-05-04T17:00:18.381723+00:00 2021-05-04T17:00:21.452541+00:00 0:00:03.070818 24434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T17:00:15.697545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T15:00:00+00:00 TriggerDagRunOperator 2021-05-04T16:10:05.629688+00:00 2021-05-04T16:10:06.129509+00:00 0:00:00.499821 24426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T16:10:03.073697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T15:00:00+00:00 TriggerDagRunOperator 2021-05-04T16:10:05.481563+00:00 2021-05-04T16:10:05.873642+00:00 0:00:00.392079 24425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T16:10:03.073742+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T15:00:00+00:00 EmrJobFlowSensor 2021-05-04T16:00:48.044714+00:00 2021-05-04T16:09:50.779689+00:00 0:09:02.734975 24421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T16:00:45.790736+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T16:00:28.039480+00:00 2021-05-04T16:00:29.916614+00:00 0:00:01.877134 24420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T16:00:25.700503+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T15:00:00+00:00 PythonOperator 2021-05-04T16:00:05.984854+00:00 2021-05-04T16:00:09.179958+00:00 0:00:03.195104 24419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T16:00:03.662449+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T14:00:00+00:00 TriggerDagRunOperator 2021-05-04T15:10:01.515593+00:00 2021-05-04T15:10:02.017194+00:00 0:00:00.501601 24411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T15:09:58.264265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T14:00:00+00:00 TriggerDagRunOperator 2021-05-04T15:10:01.330353+00:00 2021-05-04T15:10:01.742793+00:00 0:00:00.412440 24410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T15:09:58.264210+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T14:00:00+00:00 EmrJobFlowSensor 2021-05-04T15:00:47.828185+00:00 2021-05-04T15:09:50.491608+00:00 0:09:02.663423 24406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T15:00:45.162887+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T15:00:25.331545+00:00 2021-05-04T15:00:27.190156+00:00 0:00:01.858611 24405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T15:00:23.009702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T14:00:00+00:00 PythonOperator 2021-05-04T15:00:05.439049+00:00 2021-05-04T15:00:08.662416+00:00 0:00:03.223367 24404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T15:00:02.989388+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T13:00:00+00:00 TriggerDagRunOperator 2021-05-04T14:10:20.846297+00:00 2021-05-04T14:10:21.371908+00:00 0:00:00.525611 24396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T14:10:18.511865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T13:00:00+00:00 TriggerDagRunOperator 2021-05-04T14:10:20.791878+00:00 2021-05-04T14:10:21.222323+00:00 0:00:00.430445 24395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T14:10:18.511917+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T13:00:00+00:00 EmrJobFlowSensor 2021-05-04T14:01:06.017161+00:00 2021-05-04T14:10:08.775294+00:00 0:09:02.758133 24391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T14:01:03.555670+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T14:00:43.925019+00:00 2021-05-04T14:00:45.733679+00:00 0:00:01.808660 24390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T14:00:41.549800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T13:00:00+00:00 PythonOperator 2021-05-04T14:00:11.814245+00:00 2021-05-04T14:00:14.847431+00:00 0:00:03.033186 24389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T14:00:09.448828+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T12:00:00+00:00 TriggerDagRunOperator 2021-05-04T13:09:22.699289+00:00 2021-05-04T13:09:23.238105+00:00 0:00:00.538816 24381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T13:09:19.962601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T12:00:00+00:00 TriggerDagRunOperator 2021-05-04T13:09:22.565997+00:00 2021-05-04T13:09:22.999645+00:00 0:00:00.433648 24380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T13:09:19.962557+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T12:00:00+00:00 EmrJobFlowSensor 2021-05-04T13:01:13.150821+00:00 2021-05-04T13:09:15.747780+00:00 0:08:02.596959 24376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T13:01:10.570125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T13:00:50.702183+00:00 2021-05-04T13:00:52.395820+00:00 0:00:01.693637 24375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T13:00:48.512193+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T12:00:00+00:00 PythonOperator 2021-05-04T13:00:22.842333+00:00 2021-05-04T13:00:25.915190+00:00 0:00:03.072857 24374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T13:00:20.419295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T11:00:00+00:00 TriggerDagRunOperator 2021-05-04T12:09:08.631075+00:00 2021-05-04T12:09:09.168954+00:00 0:00:00.537879 24366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T12:09:05.846515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T11:00:00+00:00 TriggerDagRunOperator 2021-05-04T12:09:08.217763+00:00 2021-05-04T12:09:08.658755+00:00 0:00:00.440992 24365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T12:09:05.846469+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T11:00:00+00:00 EmrJobFlowSensor 2021-05-04T12:00:53.353450+00:00 2021-05-04T12:08:55.905906+00:00 0:08:02.552456 24361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T12:00:51.006868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T12:00:31.497963+00:00 2021-05-04T12:00:33.335606+00:00 0:00:01.837643 24360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T12:00:29.066109+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T11:00:00+00:00 PythonOperator 2021-05-04T12:00:09.906240+00:00 2021-05-04T12:00:13.023080+00:00 0:00:03.116840 24359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T12:00:06.975466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T10:00:00+00:00 TriggerDagRunOperator 2021-05-04T11:10:08.133116+00:00 2021-05-04T11:10:08.557077+00:00 0:00:00.423961 24351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T11:10:05.556049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T10:00:00+00:00 TriggerDagRunOperator 2021-05-04T11:10:08.008472+00:00 2021-05-04T11:10:08.584744+00:00 0:00:00.576272 24350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T11:10:05.556094+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T10:00:00+00:00 EmrJobFlowSensor 2021-05-04T11:00:46.691819+00:00 2021-05-04T11:09:49.514783+00:00 0:09:02.822964 24346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T11:00:44.438624+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T11:00:24.788608+00:00 2021-05-04T11:00:26.531720+00:00 0:00:01.743112 24345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T11:00:22.460174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T10:00:00+00:00 PythonOperator 2021-05-04T11:00:05.050808+00:00 2021-05-04T11:00:08.175938+00:00 0:00:03.125130 24344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T11:00:01.992920+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T09:00:00+00:00 TriggerDagRunOperator 2021-05-04T10:10:10.198515+00:00 2021-05-04T10:10:10.645633+00:00 0:00:00.447118 24336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:10:07.589146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T09:00:00+00:00 TriggerDagRunOperator 2021-05-04T10:10:10.211502+00:00 2021-05-04T10:10:10.766440+00:00 0:00:00.554938 24335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:10:07.589189+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T09:00:00+00:00 EmrJobFlowSensor 2021-05-04T10:00:56.814727+00:00 2021-05-04T10:09:59.518972+00:00 0:09:02.704245 24331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:00:54.446672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T10:00:34.670866+00:00 2021-05-04T10:00:36.402337+00:00 0:00:01.731471 24330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T10:00:32.346350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T09:00:00+00:00 PythonOperator 2021-05-04T10:00:12.782824+00:00 2021-05-04T10:00:15.864897+00:00 0:00:03.082073 24329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T10:00:10.316992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T08:00:00+00:00 TriggerDagRunOperator 2021-05-04T09:11:20.406368+00:00 2021-05-04T09:11:20.932374+00:00 0:00:00.526006 24321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T09:11:17.865213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T08:00:00+00:00 TriggerDagRunOperator 2021-05-04T09:11:20.284067+00:00 2021-05-04T09:11:20.716068+00:00 0:00:00.432001 24320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T09:11:17.865168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T08:00:00+00:00 EmrJobFlowSensor 2021-05-04T09:00:58.797134+00:00 2021-05-04T09:11:01.618619+00:00 0:10:02.821485 24316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T09:00:56.452456+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T09:00:38.511910+00:00 2021-05-04T09:00:40.282803+00:00 0:00:01.770893 24315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T09:00:36.295233+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T08:00:00+00:00 PythonOperator 2021-05-04T09:00:16.594879+00:00 2021-05-04T09:00:19.674658+00:00 0:00:03.079779 24314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T09:00:14.225449+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T07:00:00+00:00 TriggerDagRunOperator 2021-05-04T08:09:12.346836+00:00 2021-05-04T08:09:12.911861+00:00 0:00:00.565025 24306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:09:10.059505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T07:00:00+00:00 TriggerDagRunOperator 2021-05-04T08:09:12.338956+00:00 2021-05-04T08:09:12.837359+00:00 0:00:00.498403 24305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:09:10.059534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T07:00:00+00:00 EmrJobFlowSensor 2021-05-04T08:00:57.206283+00:00 2021-05-04T08:08:59.746461+00:00 0:08:02.540178 24301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:00:55.040580+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:00:35.334701+00:00 2021-05-04T08:00:37.028931+00:00 0:00:01.694230 24300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T08:00:33.012790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T07:00:00+00:00 PythonOperator 2021-05-04T08:00:07.235143+00:00 2021-05-04T08:00:10.526875+00:00 0:00:03.291732 24299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T08:00:04.999892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T06:00:00+00:00 TriggerDagRunOperator 2021-05-04T07:13:35.724740+00:00 2021-05-04T07:13:36.230611+00:00 0:00:00.505871 24292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:13:32.961071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T06:00:00+00:00 TriggerDagRunOperator 2021-05-04T07:13:35.609112+00:00 2021-05-04T07:13:36.036520+00:00 0:00:00.427408 24291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:13:32.961098+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T06:00:00+00:00 EmrJobFlowSensor 2021-05-04T07:00:58.231229+00:00 2021-05-04T07:10:00.872507+00:00 0:09:02.641278 24286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:00:56.095518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:00:36.393191+00:00 2021-05-04T07:00:38.075626+00:00 0:00:01.682435 24285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T07:00:34.149251+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T06:00:00+00:00 PythonOperator 2021-05-04T07:00:16.259498+00:00 2021-05-04T07:00:19.311483+00:00 0:00:03.051985 24284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T07:00:14.009746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T05:00:00+00:00 TriggerDagRunOperator 2021-05-04T06:10:41.107039+00:00 2021-05-04T06:10:41.631599+00:00 0:00:00.524560 24277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:10:38.771100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T05:00:00+00:00 TriggerDagRunOperator 2021-05-04T06:10:40.997702+00:00 2021-05-04T06:10:41.405722+00:00 0:00:00.408020 24276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:10:38.771134+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T05:00:00+00:00 EmrJobFlowSensor 2021-05-04T06:07:27.784581+00:00 2021-05-04T06:10:29.586710+00:00 0:03:01.802129 24273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:07:24.413314+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:00:30.655143+00:00 2021-05-04T06:00:32.492782+00:00 0:00:01.837639 24270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T06:00:27.657803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T05:00:00+00:00 PythonOperator 2021-05-04T06:00:10.105216+00:00 2021-05-04T06:00:13.124427+00:00 0:00:03.019211 24269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T06:00:07.585856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T04:00:00+00:00 TriggerDagRunOperator 2021-05-04T05:10:48.799210+00:00 2021-05-04T05:10:49.332611+00:00 0:00:00.533401 24262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:10:46.332990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T04:00:00+00:00 TriggerDagRunOperator 2021-05-04T05:10:48.571373+00:00 2021-05-04T05:10:49.018315+00:00 0:00:00.446942 24261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:10:46.333025+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T04:00:00+00:00 EmrJobFlowSensor 2021-05-04T05:01:31.841568+00:00 2021-05-04T05:10:34.472972+00:00 0:09:02.631404 24257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:01:29.625797+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:01:09.827974+00:00 2021-05-04T05:01:11.541745+00:00 0:00:01.713771 24256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T05:01:07.597284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T04:00:00+00:00 PythonOperator 2021-05-04T05:00:50.385631+00:00 2021-05-04T05:00:53.516926+00:00 0:00:03.131295 24255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T05:00:47.641198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T03:00:00+00:00 TriggerDagRunOperator 2021-05-04T04:10:10.839361+00:00 2021-05-04T04:10:11.368048+00:00 0:00:00.528687 24247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:10:08.545452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T03:00:00+00:00 TriggerDagRunOperator 2021-05-04T04:10:10.791148+00:00 2021-05-04T04:10:11.227530+00:00 0:00:00.436382 24246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:10:08.545403+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T03:00:00+00:00 EmrJobFlowSensor 2021-05-04T04:01:04.330586+00:00 2021-05-04T04:10:07.276865+00:00 0:09:02.946279 24242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:01:01.744145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:00:41.931320+00:00 2021-05-04T04:00:43.720385+00:00 0:00:01.789065 24241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T04:00:39.641938+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T03:00:00+00:00 PythonOperator 2021-05-04T04:00:20.106731+00:00 2021-05-04T04:00:23.267283+00:00 0:00:03.160552 24240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T04:00:17.622100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T02:00:00+00:00 TriggerDagRunOperator 2021-05-04T03:10:20.318269+00:00 2021-05-04T03:10:20.852149+00:00 0:00:00.533880 24232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:10:17.922540+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T02:00:00+00:00 TriggerDagRunOperator 2021-05-04T03:10:20.250772+00:00 2021-05-04T03:10:20.678739+00:00 0:00:00.427967 24231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:10:17.922574+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T02:00:00+00:00 EmrJobFlowSensor 2021-05-04T03:00:57.287819+00:00 2021-05-04T03:09:59.955789+00:00 0:09:02.667970 24227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T03:00:55.053871+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T03:00:35.391354+00:00 2021-05-04T03:00:37.187041+00:00 0:00:01.795687 24226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T03:00:32.985956+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T02:00:00+00:00 PythonOperator 2021-05-04T03:00:13.448654+00:00 2021-05-04T03:00:16.523736+00:00 0:00:03.075082 24225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T03:00:10.926942+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T01:00:00+00:00 TriggerDagRunOperator 2021-05-04T02:10:16.761620+00:00 2021-05-04T02:10:17.280095+00:00 0:00:00.518475 24217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T02:10:14.295085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T01:00:00+00:00 TriggerDagRunOperator 2021-05-04T02:10:16.669758+00:00 2021-05-04T02:10:17.162235+00:00 0:00:00.492477 24216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T02:10:14.295053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T01:00:00+00:00 EmrJobFlowSensor 2021-05-04T02:00:51.624988+00:00 2021-05-04T02:09:54.269779+00:00 0:09:02.644791 24212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T02:00:49.323269+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T02:00:29.914852+00:00 2021-05-04T02:00:31.650436+00:00 0:00:01.735584 24211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T02:00:27.373410+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T01:00:00+00:00 PythonOperator 2021-05-04T02:00:09.790504+00:00 2021-05-04T02:00:12.937226+00:00 0:00:03.146722 24210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T02:00:07.363868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T00:00:00+00:00 TriggerDagRunOperator 2021-05-04T01:09:09.410355+00:00 2021-05-04T01:09:09.918476+00:00 0:00:00.508121 24202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T01:09:06.846807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T00:00:00+00:00 TriggerDagRunOperator 2021-05-04T01:09:09.236510+00:00 2021-05-04T01:09:09.652560+00:00 0:00:00.416050 24201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T01:09:06.846747+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T00:00:00+00:00 EmrJobFlowSensor 2021-05-04T01:00:56.165236+00:00 2021-05-04T01:08:58.652087+00:00 0:08:02.486851 24197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T01:00:53.849690+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T01:00:34.118868+00:00 2021-05-04T01:00:35.851606+00:00 0:00:01.732738 24196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T01:00:31.783657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T00:00:00+00:00 PythonOperator 2021-05-04T01:00:14.331420+00:00 2021-05-04T01:00:17.443751+00:00 0:00:03.112331 24195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T01:00:11.765655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T23:00:00+00:00 TriggerDagRunOperator 2021-05-04T00:10:25.831564+00:00 2021-05-04T00:10:26.356372+00:00 0:00:00.524808 24187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T00:10:23.325472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T23:00:00+00:00 TriggerDagRunOperator 2021-05-04T00:10:25.788443+00:00 2021-05-04T00:10:26.207348+00:00 0:00:00.418905 24186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T00:10:23.325521+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T23:00:00+00:00 EmrJobFlowSensor 2021-05-04T00:01:04.939213+00:00 2021-05-04T00:10:07.889066+00:00 0:09:02.949853 24182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T00:01:02.485968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T00:00:44.641353+00:00 2021-05-04T00:00:46.306723+00:00 0:00:01.665370 24181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T00:00:42.439341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T23:00:00+00:00 PythonOperator 2021-05-04T00:00:23.371505+00:00 2021-05-04T00:00:26.504913+00:00 0:00:03.133408 24180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T00:00:20.479726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T22:00:00+00:00 TriggerDagRunOperator 2021-05-03T23:09:22.550360+00:00 2021-05-03T23:09:23.025037+00:00 0:00:00.474677 24172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T23:09:19.859527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T22:00:00+00:00 TriggerDagRunOperator 2021-05-03T23:09:22.105725+00:00 2021-05-03T23:09:22.682240+00:00 0:00:00.576515 24171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T23:09:19.859491+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T22:00:00+00:00 EmrJobFlowSensor 2021-05-03T23:01:11.238389+00:00 2021-05-03T23:09:13.812733+00:00 0:08:02.574344 24167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T23:01:09.099189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T23:00:47.376736+00:00 2021-05-03T23:00:49.101363+00:00 0:00:01.724627 24165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T23:00:45.160767+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T22:00:00+00:00 PythonOperator 2021-05-03T23:00:23.223083+00:00 2021-05-03T23:00:26.233100+00:00 0:00:03.010017 24163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T23:00:21.036098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T21:00:00+00:00 TriggerDagRunOperator 2021-05-03T22:09:30.753785+00:00 2021-05-03T22:09:31.227893+00:00 0:00:00.474108 24154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T22:09:28.148292+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T21:00:00+00:00 TriggerDagRunOperator 2021-05-03T22:09:30.733836+00:00 2021-05-03T22:09:31.320458+00:00 0:00:00.586622 24153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T22:09:28.148342+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T21:00:00+00:00 EmrJobFlowSensor 2021-05-03T22:01:05.511565+00:00 2021-05-03T22:09:08.174402+00:00 0:08:02.662837 24149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T22:01:03.268985+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T22:00:41.404774+00:00 2021-05-03T22:00:43.236264+00:00 0:00:01.831490 24148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T22:00:39.210529+00:00 2 default_pool