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-28T21:00:00+00:00 PythonOperator 2021-04-28T22:00:16.552982+00:00 2021-04-28T22:00:19.583488+00:00 0:00:03.030506 22332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T22:00:14.094156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T20:00:00+00:00 TriggerDagRunOperator 2021-04-28T21:10:12.141862+00:00 2021-04-28T21:10:12.670736+00:00 0:00:00.528874 22324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T21:10:09.560526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T20:00:00+00:00 TriggerDagRunOperator 2021-04-28T21:10:11.977595+00:00 2021-04-28T21:10:12.397134+00:00 0:00:00.419539 22323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T21:10:09.560490+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T20:00:00+00:00 EmrJobFlowSensor 2021-04-28T21:00:56.212396+00:00 2021-04-28T21:09:59.033853+00:00 0:09:02.821457 22319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T21:00:54.002257+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T21:00:34.563808+00:00 2021-04-28T21:00:36.443930+00:00 0:00:01.880122 22318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T21:00:32.059335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T20:00:00+00:00 PythonOperator 2021-04-28T21:00:12.425322+00:00 2021-04-28T21:00:15.407155+00:00 0:00:02.981833 22317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T21:00:10.046361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T19:00:00+00:00 TriggerDagRunOperator 2021-04-28T20:10:13.852493+00:00 2021-04-28T20:10:14.388051+00:00 0:00:00.535558 22309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T20:10:11.145131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T19:00:00+00:00 TriggerDagRunOperator 2021-04-28T20:10:13.734966+00:00 2021-04-28T20:10:14.359505+00:00 0:00:00.624539 22308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T20:10:11.145080+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T19:00:00+00:00 EmrJobFlowSensor 2021-04-28T20:01:03.719527+00:00 2021-04-28T20:10:06.434763+00:00 0:09:02.715236 22304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T20:01:01.555298+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T20:00:39.845480+00:00 2021-04-28T20:00:41.534400+00:00 0:00:01.688920 22303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T20:00:37.525527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T19:00:00+00:00 PythonOperator 2021-04-28T20:00:20.086647+00:00 2021-04-28T20:00:23.068762+00:00 0:00:02.982115 22302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T20:00:17.520421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T18:00:00+00:00 TriggerDagRunOperator 2021-04-28T19:10:12.953254+00:00 2021-04-28T19:10:13.427025+00:00 0:00:00.473771 22294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T19:10:10.629004+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T18:00:00+00:00 TriggerDagRunOperator 2021-04-28T19:10:12.933339+00:00 2021-04-28T19:10:13.512111+00:00 0:00:00.578772 22293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T19:10:10.629055+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T18:00:00+00:00 EmrJobFlowSensor 2021-04-28T19:00:55.912248+00:00 2021-04-28T19:09:58.624140+00:00 0:09:02.711892 22289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T19:00:53.365245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T19:00:33.766759+00:00 2021-04-28T19:00:35.545807+00:00 0:00:01.779048 22288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T19:00:31.252614+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T18:00:00+00:00 PythonOperator 2021-04-28T19:00:11.866412+00:00 2021-04-28T19:00:14.864450+00:00 0:00:02.998038 22287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T19:00:09.261219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T17:00:00+00:00 TriggerDagRunOperator 2021-04-28T18:11:20.027510+00:00 2021-04-28T18:11:20.533483+00:00 0:00:00.505973 22279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T18:11:17.561760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T17:00:00+00:00 TriggerDagRunOperator 2021-04-28T18:11:19.910102+00:00 2021-04-28T18:11:20.311734+00:00 0:00:00.401632 22278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T18:11:17.561705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T17:00:00+00:00 EmrJobFlowSensor 2021-04-28T18:00:56.329989+00:00 2021-04-28T18:10:59.126912+00:00 0:10:02.796923 22274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T18:00:53.986235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T18:00:34.325278+00:00 2021-04-28T18:00:36.033355+00:00 0:00:01.708077 22273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T18:00:31.848281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T17:00:00+00:00 PythonOperator 2021-04-28T18:00:12.044438+00:00 2021-04-28T18:00:15.064833+00:00 0:00:03.020395 22272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T18:00:09.726443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T16:00:00+00:00 TriggerDagRunOperator 2021-04-28T17:10:09.805698+00:00 2021-04-28T17:10:10.250353+00:00 0:00:00.444655 22264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T17:10:07.447274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T16:00:00+00:00 TriggerDagRunOperator 2021-04-28T17:10:09.785589+00:00 2021-04-28T17:10:10.326989+00:00 0:00:00.541400 22263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T17:10:07.447233+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T16:00:00+00:00 EmrJobFlowSensor 2021-04-28T17:00:48.442168+00:00 2021-04-28T17:09:51.112939+00:00 0:09:02.670771 22259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T17:00:46.144949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T17:00:26.584575+00:00 2021-04-28T17:00:28.449088+00:00 0:00:01.864513 22258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T17:00:24.156305+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T16:00:00+00:00 PythonOperator 2021-04-28T17:00:04.543429+00:00 2021-04-28T17:00:07.785099+00:00 0:00:03.241670 22257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T17:00:02.086101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T15:00:00+00:00 TriggerDagRunOperator 2021-04-28T16:10:21.533555+00:00 2021-04-28T16:10:22.162313+00:00 0:00:00.628758 22249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T16:10:19.300038+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T15:00:00+00:00 TriggerDagRunOperator 2021-04-28T16:10:21.465935+00:00 2021-04-28T16:10:21.886828+00:00 0:00:00.420893 22248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T16:10:19.300000+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T15:00:00+00:00 EmrJobFlowSensor 2021-04-28T16:01:14.448596+00:00 2021-04-28T16:10:17.154815+00:00 0:09:02.706219 22244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T16:01:12.088098+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T16:00:54.364021+00:00 2021-04-28T16:00:56.181361+00:00 0:00:01.817340 22243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T16:00:52.038230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T15:00:00+00:00 PythonOperator 2021-04-28T16:00:32.961140+00:00 2021-04-28T16:00:35.977326+00:00 0:00:03.016186 22242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T16:00:30.072541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T14:00:00+00:00 TriggerDagRunOperator 2021-04-28T15:11:09.302354+00:00 2021-04-28T15:11:09.809302+00:00 0:00:00.506948 22234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T15:11:06.421635+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T14:00:00+00:00 TriggerDagRunOperator 2021-04-28T15:11:09.011849+00:00 2021-04-28T15:11:09.417938+00:00 0:00:00.406089 22233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T15:11:06.421680+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T14:00:00+00:00 EmrJobFlowSensor 2021-04-28T15:00:47.508653+00:00 2021-04-28T15:10:50.420342+00:00 0:10:02.911689 22229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T15:00:45.102258+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T15:00:25.396313+00:00 2021-04-28T15:00:27.184762+00:00 0:00:01.788449 22228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T15:00:23.011084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T14:00:00+00:00 PythonOperator 2021-04-28T15:00:05.655287+00:00 2021-04-28T15:00:08.717304+00:00 0:00:03.062017 22227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T15:00:03.051653+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T13:00:00+00:00 TriggerDagRunOperator 2021-04-28T14:16:05.853321+00:00 2021-04-28T14:16:06.393771+00:00 0:00:00.540450 22220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:16:02.983153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T13:00:00+00:00 TriggerDagRunOperator 2021-04-28T14:16:05.788627+00:00 2021-04-28T14:16:06.191868+00:00 0:00:00.403241 22219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:16:02.983182+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T13:00:00+00:00 EmrJobFlowSensor 2021-04-28T14:00:48.354176+00:00 2021-04-28T14:11:51.360066+00:00 0:11:03.005890 22214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:00:45.859933+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:00:28.250411+00:00 2021-04-28T14:00:30.145168+00:00 0:00:01.894757 22213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T14:00:25.768733+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T13:00:00+00:00 PythonOperator 2021-04-28T14:00:05.986651+00:00 2021-04-28T14:00:09.037897+00:00 0:00:03.051246 22212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T14:00:03.666892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T12:00:00+00:00 TriggerDagRunOperator 2021-04-28T13:11:36.254026+00:00 2021-04-28T13:11:36.793119+00:00 0:00:00.539093 22205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:11:33.611911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T12:00:00+00:00 TriggerDagRunOperator 2021-04-28T13:11:36.103133+00:00 2021-04-28T13:11:36.544221+00:00 0:00:00.441088 22204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:11:33.611882+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T12:00:00+00:00 EmrJobFlowSensor 2021-04-28T13:01:08.975028+00:00 2021-04-28T13:11:11.885473+00:00 0:10:02.910445 22199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T13:01:06.655929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T13:00:46.943789+00:00 2021-04-28T13:00:48.765787+00:00 0:00:01.821998 22198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T13:00:44.645953+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T12:00:00+00:00 PythonOperator 2021-04-28T13:00:25.321287+00:00 2021-04-28T13:00:28.389703+00:00 0:00:03.068416 22197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T13:00:22.663116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T11:00:00+00:00 TriggerDagRunOperator 2021-04-28T12:11:18.683498+00:00 2021-04-28T12:11:19.190407+00:00 0:00:00.506909 22190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:11:15.964626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T11:00:00+00:00 TriggerDagRunOperator 2021-04-28T12:11:18.366581+00:00 2021-04-28T12:11:18.828975+00:00 0:00:00.462394 22189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:11:15.964583+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T11:00:00+00:00 EmrJobFlowSensor 2021-04-28T12:00:59.809148+00:00 2021-04-28T12:11:02.766506+00:00 0:10:02.957358 22184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:00:57.409091+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:00:37.687798+00:00 2021-04-28T12:00:39.501295+00:00 0:00:01.813497 22183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T12:00:35.392307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T11:00:00+00:00 PythonOperator 2021-04-28T12:00:15.622933+00:00 2021-04-28T12:00:18.653348+00:00 0:00:03.030415 22182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T12:00:13.287867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T10:00:00+00:00 TriggerDagRunOperator 2021-04-28T11:10:24.985565+00:00 2021-04-28T11:10:25.433492+00:00 0:00:00.447927 22175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:10:22.557464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T10:00:00+00:00 TriggerDagRunOperator 2021-04-28T11:10:24.919777+00:00 2021-04-28T11:10:25.516247+00:00 0:00:00.596470 22174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:10:22.557505+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T10:00:00+00:00 EmrJobFlowSensor 2021-04-28T11:00:58.909148+00:00 2021-04-28T11:10:01.753993+00:00 0:09:02.844845 22169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:00:56.400151+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:00:38.838981+00:00 2021-04-28T11:00:40.651879+00:00 0:00:01.812898 22168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T11:00:36.353055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T10:00:00+00:00 PythonOperator 2021-04-28T11:00:16.492175+00:00 2021-04-28T11:00:19.512344+00:00 0:00:03.020169 22167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T11:00:14.243452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T09:00:00+00:00 TriggerDagRunOperator 2021-04-28T10:12:25.080866+00:00 2021-04-28T10:12:25.482760+00:00 0:00:00.401894 22160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:12:22.711190+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T09:00:00+00:00 TriggerDagRunOperator 2021-04-28T10:12:25.099740+00:00 2021-04-28T10:12:25.647378+00:00 0:00:00.547638 22159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:12:22.711161+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T09:00:00+00:00 EmrJobFlowSensor 2021-04-28T10:02:12.093000+00:00 2021-04-28T10:12:14.894473+00:00 0:10:02.801473 22155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:02:09.793184+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:01:50.044680+00:00 2021-04-28T10:01:51.730037+00:00 0:00:01.685357 22154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T10:01:47.693834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T09:00:00+00:00 PythonOperator 2021-04-28T10:01:29.946838+00:00 2021-04-28T10:01:32.966914+00:00 0:00:03.020076 22153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T10:01:27.670488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T08:00:00+00:00 TriggerDagRunOperator 2021-04-28T09:10:06.657674+00:00 2021-04-28T09:10:07.195174+00:00 0:00:00.537500 22145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:10:04.406206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T08:00:00+00:00 TriggerDagRunOperator 2021-04-28T09:10:06.589843+00:00 2021-04-28T09:10:07.043971+00:00 0:00:00.454128 22144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:10:04.406240+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T08:00:00+00:00 EmrJobFlowSensor 2021-04-28T09:01:00.220467+00:00 2021-04-28T09:10:03.183532+00:00 0:09:02.963065 22140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:00:57.670237+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:00:38.107909+00:00 2021-04-28T09:00:39.991643+00:00 0:00:01.883734 22139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T09:00:35.661230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T08:00:00+00:00 PythonOperator 2021-04-28T09:00:17.813441+00:00 2021-04-28T09:00:20.798743+00:00 0:00:02.985302 22138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T09:00:15.559436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T07:00:00+00:00 TriggerDagRunOperator 2021-04-28T08:10:33.949428+00:00 2021-04-28T08:10:34.506853+00:00 0:00:00.557425 22130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:10:31.481141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T07:00:00+00:00 TriggerDagRunOperator 2021-04-28T08:10:33.928335+00:00 2021-04-28T08:10:34.404895+00:00 0:00:00.476560 22129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:10:31.481107+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:01:06.593184+00:00 2021-04-28T08:10:09.423368+00:00 0:09:02.830184 22125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:01:04.246528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:00:44.620082+00:00 2021-04-28T08:00:46.346131+00:00 0:00:01.726049 22124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T08:00:42.280573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:00:25.208881+00:00 2021-04-28T08:00:28.176293+00:00 0:00:02.967412 22123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T08:00:22.263727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T06:00:00+00:00 TriggerDagRunOperator 2021-04-28T07:11:33.794375+00:00 2021-04-28T07:11:34.331457+00:00 0:00:00.537082 22115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:11:31.471436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T06:00:00+00:00 TriggerDagRunOperator 2021-04-28T07:11:33.736169+00:00 2021-04-28T07:11:34.230664+00:00 0:00:00.494495 22114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:11:31.471406+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T06:00:00+00:00 EmrJobFlowSensor 2021-04-28T07:01:08.755812+00:00 2021-04-28T07:11:11.554386+00:00 0:10:02.798574 22110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:01:06.261422+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:00:44.855186+00:00 2021-04-28T07:00:46.688950+00:00 0:00:01.833764 22109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T07:00:42.244726+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T06:00:00+00:00 PythonOperator 2021-04-28T07:00:23.107873+00:00 2021-04-28T07:00:26.219222+00:00 0:00:03.111349 22108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T07:00:20.276379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T05:00:00+00:00 TriggerDagRunOperator 2021-04-28T06:11:12.437918+00:00 2021-04-28T06:11:12.865886+00:00 0:00:00.427968 22100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:11:10.104589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T05:00:00+00:00 TriggerDagRunOperator 2021-04-28T06:11:12.413879+00:00 2021-04-28T06:11:12.999395+00:00 0:00:00.585516 22099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:11:10.104557+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T05:00:00+00:00 EmrJobFlowSensor 2021-04-28T06:00:51.073389+00:00 2021-04-28T06:10:53.798664+00:00 0:10:02.725275 22095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:00:48.903255+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:00:31.141104+00:00 2021-04-28T06:00:32.921866+00:00 0:00:01.780762 22094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T06:00:28.885473+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T05:00:00+00:00 PythonOperator 2021-04-28T06:00:09.191033+00:00 2021-04-28T06:00:12.230419+00:00 0:00:03.039386 22093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T06:00:06.827796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T04:00:00+00:00 TriggerDagRunOperator 2021-04-28T05:11:20.957838+00:00 2021-04-28T05:11:21.470389+00:00 0:00:00.512551 22085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:11:18.585830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T04:00:00+00:00 TriggerDagRunOperator 2021-04-28T05:11:20.823771+00:00 2021-04-28T05:11:21.242431+00:00 0:00:00.418660 22084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:11:18.585863+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T04:00:00+00:00 EmrJobFlowSensor 2021-04-28T05:01:00.364612+00:00 2021-04-28T05:11:03.300559+00:00 0:10:02.935947 22080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:00:57.652700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:00:38.061692+00:00 2021-04-28T05:00:39.766238+00:00 0:00:01.704546 22079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T05:00:35.652241+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T04:00:00+00:00 PythonOperator 2021-04-28T05:00:17.925890+00:00 2021-04-28T05:00:20.895831+00:00 0:00:02.969941 22078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T05:00:15.569881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T03:00:00+00:00 TriggerDagRunOperator 2021-04-28T04:10:14.448487+00:00 2021-04-28T04:10:14.879254+00:00 0:00:00.430767 22070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:10:11.922237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T03:00:00+00:00 TriggerDagRunOperator 2021-04-28T04:10:14.229285+00:00 2021-04-28T04:10:14.827979+00:00 0:00:00.598694 22069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:10:11.922269+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T03:00:00+00:00 EmrJobFlowSensor 2021-04-28T04:01:03.026255+00:00 2021-04-28T04:10:05.608461+00:00 0:09:02.582206 22065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:01:00.853944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:00:41.239213+00:00 2021-04-28T04:00:42.955146+00:00 0:00:01.715933 22064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T04:00:38.815066+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T03:00:00+00:00 PythonOperator 2021-04-28T04:00:19.693468+00:00 2021-04-28T04:00:22.690842+00:00 0:00:02.997374 22063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T04:00:16.851003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T02:00:00+00:00 TriggerDagRunOperator 2021-04-28T03:11:15.822441+00:00 2021-04-28T03:11:16.238728+00:00 0:00:00.416287 22055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:11:13.406499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T02:00:00+00:00 TriggerDagRunOperator 2021-04-28T03:11:15.675147+00:00 2021-04-28T03:11:16.233534+00:00 0:00:00.558387 22054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:11:13.406449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T02:00:00+00:00 EmrJobFlowSensor 2021-04-28T03:01:06.410961+00:00 2021-04-28T03:11:09.293084+00:00 0:10:02.882123 22050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:01:04.187996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:00:44.784626+00:00 2021-04-28T03:00:46.611183+00:00 0:00:01.826557 22049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T03:00:42.122088+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T02:00:00+00:00 PythonOperator 2021-04-28T03:00:22.497636+00:00 2021-04-28T03:00:25.505601+00:00 0:00:03.007965 22048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T03:00:20.103423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T01:00:00+00:00 TriggerDagRunOperator 2021-04-28T02:10:19.206879+00:00 2021-04-28T02:10:19.690907+00:00 0:00:00.484028 22040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:10:16.853103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T01:00:00+00:00 TriggerDagRunOperator 2021-04-28T02:10:19.177598+00:00 2021-04-28T02:10:19.757672+00:00 0:00:00.580074 22039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:10:16.853070+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T01:00:00+00:00 EmrJobFlowSensor 2021-04-28T02:01:04.148111+00:00 2021-04-28T02:10:06.799899+00:00 0:09:02.651788 22035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:01:01.902857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:00:42.254761+00:00 2021-04-28T02:00:44.050260+00:00 0:00:01.795499 22034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T02:00:39.948226+00:00 2 default_pool