Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-14T23:00:00+00:00 EmrJobFlowSensor 2020-11-15T23:00:23.104748+00:00 2020-11-15T23:09:25.554845+00:00 0:09:02.450097 5649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-15T23:00:21.539873+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-14T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-15T23:00:13.165099+00:00 2020-11-15T23:00:14.710893+00:00 0:00:01.545794 5648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-15T23:00:11.529504+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-14T23:00:00+00:00 PythonOperator 2020-11-15T23:00:03.202875+00:00 2020-11-15T23:00:05.950238+00:00 0:00:02.747363 5647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-15T23:00:01.534089+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-13T23:00:00+00:00 EmrJobFlowSensor 2020-11-14T23:00:29.843665+00:00 2020-11-14T23:09:32.339129+00:00 0:09:02.495464 5622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-14T23:00:28.210051+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-13T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-14T23:00:19.849177+00:00 2020-11-14T23:00:21.535450+00:00 0:00:01.686273 5621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-14T23:00:18.199331+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-13T23:00:00+00:00 PythonOperator 2020-11-14T23:00:09.845770+00:00 2020-11-14T23:00:12.583841+00:00 0:00:02.738071 5620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-14T23:00:08.196803+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-12T23:00:00+00:00 EmrJobFlowSensor 2020-11-13T23:00:46.583070+00:00 2020-11-13T23:10:49.220192+00:00 0:10:02.637122 5595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-13T23:00:44.990564+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-12T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-13T23:00:28.532738+00:00 2020-11-13T23:00:30.189871+00:00 0:00:01.657133 5594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-13T23:00:26.967642+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-12T23:00:00+00:00 PythonOperator 2020-11-13T23:00:10.494573+00:00 2020-11-13T23:00:13.154807+00:00 0:00:02.660234 5593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-13T23:00:08.951679+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-11T23:00:00+00:00 EmrJobFlowSensor 2020-11-12T23:00:28.307300+00:00 2020-11-12T23:10:30.997757+00:00 0:10:02.690457 5569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-12T23:00:26.689200+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-11T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-12T23:00:18.272194+00:00 2020-11-12T23:00:19.910650+00:00 0:00:01.638456 5568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-12T23:00:16.671050+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-11T23:00:00+00:00 PythonOperator 2020-11-12T23:00:08.283400+00:00 2020-11-12T23:00:10.995858+00:00 0:00:02.712458 5567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-12T23:00:06.662872+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-10T23:00:00+00:00 EmrJobFlowSensor 2020-11-11T23:00:27.066764+00:00 2020-11-11T23:10:29.768469+00:00 0:10:02.701705 5542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-11T23:00:25.386783+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-10T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-11T23:00:17.018724+00:00 2020-11-11T23:00:18.590904+00:00 0:00:01.572180 5541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-11T23:00:15.389215+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-10T23:00:00+00:00 PythonOperator 2020-11-11T23:00:08.951066+00:00 2020-11-11T23:00:11.639213+00:00 0:00:02.688147 5540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-11T23:00:07.381838+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-09T23:00:00+00:00 EmrJobFlowSensor 2020-11-10T23:00:22.965656+00:00 2020-11-10T23:10:25.668593+00:00 0:10:02.702937 5515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T23:00:21.199021+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-09T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-10T23:00:13.053735+00:00 2020-11-10T23:00:14.675955+00:00 0:00:01.622220 5514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-10T23:00:11.191765+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-09T23:00:00+00:00 PythonOperator 2020-11-10T23:00:02.886386+00:00 2020-11-10T23:00:05.571486+00:00 0:00:02.685100 5513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-10T23:00:01.199917+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-11-10T15:14:41.887887+00:00 PythonOperator 2020-11-10T15:14:45.398827+00:00 2020-11-10T15:14:48.073576+00:00 0:00:02.674749 5504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T15:14:43.566229+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-11-10T06:56:52.091410+00:00 PythonOperator 2020-11-10T06:56:58.201598+00:00 2020-11-10T06:57:00.956569+00:00 0:00:02.754971 5495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T06:56:56.458741+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-10T05:00:00+00:00 EmrJobFlowSensor 2020-11-10T06:22:55.268979+00:00 2020-11-10T06:34:58.241120+00:00 0:12:02.972141 5493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T06:22:53.625611+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-10T05:00:00+00:00 EmrCreateJobFlowOperator 2020-11-10T06:22:45.625851+00:00 2020-11-10T06:22:47.321684+00:00 0:00:01.695833 5492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-10T06:22:43.627481+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-10T05:00:00+00:00 PythonOperator 2020-11-10T06:10:30.667516+00:00 2020-11-10T06:10:33.449874+00:00 0:00:02.782358 5491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-10T06:10:28.955299+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-10T04:00:00+00:00 EmrJobFlowSensor 2020-11-10T06:10:30.677910+00:00 2020-11-10T06:22:33.775462+00:00 0:12:03.097552 5490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T06:10:28.955330+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-10T04:00:00+00:00 EmrCreateJobFlowOperator 2020-11-10T06:10:22.676402+00:00 2020-11-10T06:10:24.399713+00:00 0:00:01.723311 5489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-10T06:10:20.953695+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-06T12:00:54.278096+00:00 EmrJobFlowSensor 2020-11-10T05:58:08.102350+00:00 2020-11-10T06:10:11.144630+00:00 0:12:03.042280 5488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T05:58:06.310279+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-10T04:00:00+00:00 PythonOperator 2020-11-10T05:58:08.018370+00:00 2020-11-10T05:58:11.164217+00:00 0:00:03.145847 5487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-10T05:58:06.310251+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-06T12:00:54.278096+00:00 EmrCreateJobFlowOperator 2020-11-10T05:58:00.056031+00:00 2020-11-10T05:58:01.847646+00:00 0:00:01.791615 5486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-10T05:57:58.288057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-08T23:00:00+00:00 EmrJobFlowSensor 2020-11-09T23:00:27.597271+00:00 2020-11-09T23:10:30.235522+00:00 0:10:02.638251 5478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-09T23:00:25.942624+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-08T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-09T23:00:21.589104+00:00 2020-11-09T23:00:23.111282+00:00 0:00:01.522178 5477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-09T23:00:19.941225+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-08T23:00:00+00:00 PythonOperator 2020-11-09T23:00:07.601242+00:00 2020-11-09T23:00:10.276585+00:00 0:00:02.675343 5476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-09T23:00:05.920288+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-11-09T08:28:09.058196+00:00 PythonOperator 2020-11-09T08:28:15.534356+00:00 2020-11-09T08:28:18.189321+00:00 0:00:02.654965 5460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-09T08:28:13.858712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-07T23:00:00+00:00 EmrJobFlowSensor 2020-11-08T23:00:24.264422+00:00 2020-11-08T23:09:26.861819+00:00 0:09:02.597397 5450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-08T23:00:22.578354+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-07T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-08T23:00:16.225649+00:00 2020-11-08T23:00:17.816841+00:00 0:00:01.591192 5449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-08T23:00:14.570541+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-07T23:00:00+00:00 PythonOperator 2020-11-08T23:00:06.350268+00:00 2020-11-08T23:00:09.191572+00:00 0:00:02.841304 5448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-08T23:00:04.562180+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-06T23:00:00+00:00 EmrJobFlowSensor 2020-11-07T23:00:27.437730+00:00 2020-11-07T23:10:30.115166+00:00 0:10:02.677436 5423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-07T23:00:25.828055+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-06T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-07T23:00:17.378289+00:00 2020-11-07T23:00:18.984136+00:00 0:00:01.605847 5422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-07T23:00:15.819783+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-06T23:00:00+00:00 PythonOperator 2020-11-07T23:00:09.418713+00:00 2020-11-07T23:00:12.180656+00:00 0:00:02.761943 5421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-07T23:00:07.804272+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-05T23:00:00+00:00 EmrJobFlowSensor 2020-11-06T23:00:25.324315+00:00 2020-11-06T23:09:27.794076+00:00 0:09:02.469761 5396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-06T23:00:23.823162+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-05T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-06T23:00:17.409812+00:00 2020-11-06T23:00:19.055585+00:00 0:00:01.645773 5395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-06T23:00:15.808893+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-05T23:00:00+00:00 PythonOperator 2020-11-06T23:00:07.571706+00:00 2020-11-06T23:00:10.329984+00:00 0:00:02.758278 5394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-06T23:00:05.897240+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-06T12:00:54.278096+00:00 PythonOperator 2020-11-06T12:01:15.499107+00:00 2020-11-06T12:01:18.405831+00:00 0:00:02.906724 5382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-06T12:01:13.782013+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-06T11:00:00+00:00 EmrJobFlowSensor 2020-11-06T12:01:15.453975+00:00 2020-11-06T12:14:18.656849+00:00 0:13:03.202874 5381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-06T12:01:13.782048+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-06T11:00:00+00:00 EmrCreateJobFlowOperator 2020-11-06T12:01:05.489806+00:00 2020-11-06T12:01:07.359622+00:00 0:00:01.869816 5380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-06T12:01:03.776692+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-06T11:00:00+00:00 PythonOperator 2020-11-06T12:00:55.396580+00:00 2020-11-06T12:00:58.163741+00:00 0:00:02.767161 5379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-06T12:00:53.776038+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-04T23:00:00+00:00 EmrJobFlowSensor 2020-11-05T23:00:24.996643+00:00 2020-11-05T23:10:27.682028+00:00 0:10:02.685385 5365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-05T23:00:23.439226+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-04T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-05T23:00:17.085158+00:00 2020-11-05T23:00:18.731839+00:00 0:00:01.646681 5364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-05T23:00:15.434792+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-04T23:00:00+00:00 PythonOperator 2020-11-05T23:00:07.040973+00:00 2020-11-05T23:00:09.848262+00:00 0:00:02.807289 5363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-05T23:00:05.421948+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-11-05T13:45:16.197719+00:00 PythonOperator 2020-11-05T13:45:19.767829+00:00 2020-11-05T13:45:22.538204+00:00 0:00:02.770375 5353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-05T13:45:17.809684+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-05T04:00:00+00:00 EmrJobFlowSensor 2020-11-05T05:00:55.220433+00:00 2020-11-05T05:11:57.867538+00:00 0:11:02.647105 5343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-05T05:00:53.600535+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-05T04:00:00+00:00 EmrCreateJobFlowOperator 2020-11-05T05:00:35.243934+00:00 2020-11-05T05:00:36.831294+00:00 0:00:01.587360 5342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-05T05:00:33.583178+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-05T04:00:00+00:00 PythonOperator 2020-11-05T05:00:17.341864+00:00 2020-11-05T05:00:20.190409+00:00 0:00:02.848545 5341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-05T05:00:15.569905+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-05T03:00:00+00:00 EmrJobFlowSensor 2020-11-05T04:07:31.766833+00:00 2020-11-05T04:20:34.757656+00:00 0:13:02.990823 5339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-05T04:07:30.246514+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-05T03:00:00+00:00 EmrCreateJobFlowOperator 2020-11-05T04:07:23.839261+00:00 2020-11-05T04:07:25.430583+00:00 0:00:01.591322 5338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-05T04:07:22.237601+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-05T03:00:00+00:00 PythonOperator 2020-11-05T04:07:13.848556+00:00 2020-11-05T04:07:16.597183+00:00 0:00:02.748627 5337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-05T04:07:12.228253+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-03T23:00:00+00:00 EmrJobFlowSensor 2020-11-04T23:00:21.100561+00:00 2020-11-04T23:11:23.857558+00:00 0:11:02.756997 5331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-04T23:00:19.567941+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-03T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-04T23:00:13.121557+00:00 2020-11-04T23:00:14.770992+00:00 0:00:01.649435 5330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-04T23:00:11.557779+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-03T23:00:00+00:00 PythonOperator 2020-11-04T23:00:03.264901+00:00 2020-11-04T23:00:06.013019+00:00 0:00:02.748118 5329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-04T23:00:01.553459+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-02T23:00:00+00:00 EmrJobFlowSensor 2020-11-03T23:00:31.398055+00:00 2020-11-03T23:10:34.215136+00:00 0:10:02.817081 5304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-03T23:00:29.694711+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-02T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-03T23:00:23.458362+00:00 2020-11-03T23:00:25.170467+00:00 0:00:01.712105 5303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-03T23:00:21.681361+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-02T23:00:00+00:00 PythonOperator 2020-11-03T23:00:13.497077+00:00 2020-11-03T23:00:16.313616+00:00 0:00:02.816539 5302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-03T23:00:11.704528+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-03T14:00:00+00:00 EmrJobFlowSensor 2020-11-03T15:00:27.654033+00:00 2020-11-03T15:09:30.377233+00:00 0:09:02.723200 5293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-03T15:00:25.871806+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-03T14:00:00+00:00 EmrCreateJobFlowOperator 2020-11-03T15:00:19.995873+00:00 2020-11-03T15:00:21.701270+00:00 0:00:01.705397 5292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-03T15:00:17.865911+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-03T14:00:00+00:00 PythonOperator 2020-11-03T15:00:09.965011+00:00 2020-11-03T15:00:12.939960+00:00 0:00:02.974949 5291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-03T15:00:07.856476+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-03T14:45:04.640146+00:00 PythonOperator 2020-11-03T14:48:43.026822+00:00 2020-11-03T14:48:44.555357+00:00 0:00:01.528535 5290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-03T14:48:41.212767+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-03T13:00:00+00:00 EmrJobFlowSensor 2020-11-03T14:44:25.151979+00:00 5288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-03T14:44:22.966221+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-03T13:00:00+00:00 EmrCreateJobFlowOperator 2020-11-03T14:44:15.135184+00:00 2020-11-03T14:44:16.768845+00:00 0:00:01.633661 5287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-03T14:44:12.956969+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-03T12:05:42.619828+00:00 EmrJobFlowSensor 2020-11-03T14:40:26.444641+00:00 5286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-03T14:40:24.730981+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-03T11:00:00+00:00 EmrJobFlowSensor 2020-11-03T14:37:16.302966+00:00 2020-11-03T14:40:18.114581+00:00 0:03:01.811615 5285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-03T14:37:14.522074+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-03T11:00:00+00:00 EmrCreateJobFlowOperator 2020-11-03T14:37:06.247004+00:00 2020-11-03T14:37:08.151370+00:00 0:00:01.904366 5284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-03T14:37:04.511020+00:00 3 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-03T13:00:00+00:00 PythonOperator 2020-11-03T14:36:58.439009+00:00 2020-11-03T14:37:01.444429+00:00 0:00:03.005420 5283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-03T14:36:56.504544+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-03T11:00:00+00:00 PythonOperator 2020-11-03T14:36:58.403589+00:00 2020-11-03T14:37:01.334968+00:00 0:00:02.931379 5282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-03T14:36:56.504575+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-03T12:05:42.619828+00:00 EmrCreateJobFlowOperator 2020-11-03T14:36:48.284650+00:00 2020-11-03T14:36:50.055289+00:00 0:00:01.770639 5281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-03T14:36:46.495521+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-11-03T13:43:56.793350+00:00 PythonOperator 2020-11-03T13:44:10.135554+00:00 2020-11-03T13:44:12.933190+00:00 0:00:02.797636 5279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-03T13:44:07.901912+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-03T12:05:42.619828+00:00 PythonOperator 2020-11-03T12:06:23.340768+00:00 2020-11-03T12:06:26.202044+00:00 0:00:02.861276 5275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-03T12:06:21.425926+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-11-03T07:31:53.867781+00:00 PythonOperator 2020-11-03T07:31:58.500091+00:00 2020-11-03T07:32:01.338809+00:00 0:00:02.838718 5268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-03T07:31:56.394577+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-11-03T05:27:35.075929+00:00 EmrJobFlowSensor 2020-11-03T05:28:00.498618+00:00 2020-11-03T05:37:03.086213+00:00 0:09:02.587595 5265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-03T05:27:58.652955+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-11-03T05:27:35.075929+00:00 EmrCreateJobFlowOperator 2020-11-03T05:27:52.735138+00:00 2020-11-03T05:27:54.412324+00:00 0:00:01.677186 5264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-03T05:27:50.553105+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-11-03T05:27:35.075929+00:00 PythonOperator 2020-11-03T05:27:42.603202+00:00 2020-11-03T05:27:45.394848+00:00 0:00:02.791646 5263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-03T05:27:40.542140+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-01T23:00:00+00:00 EmrJobFlowSensor 2020-11-02T23:00:22.918016+00:00 2020-11-02T23:10:25.720608+00:00 0:10:02.802592 5255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-02T23:00:21.214481+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-01T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-02T23:00:13.044803+00:00 2020-11-02T23:00:14.741407+00:00 0:00:01.696604 5254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-02T23:00:11.206434+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-01T23:00:00+00:00 PythonOperator 2020-11-02T23:00:04.938762+00:00 2020-11-02T23:00:07.663162+00:00 0:00:02.724400 5253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-02T23:00:03.202602+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-11-02T05:50:47.457694+00:00 EmrJobFlowSensor 2020-11-02T06:40:15.159677+00:00 2020-11-02T06:50:17.858106+00:00 0:10:02.698429 5236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-02T06:40:13.307839+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-11-02T05:50:47.457694+00:00 EmrCreateJobFlowOperator 2020-11-02T06:40:09.206000+00:00 2020-11-02T06:40:10.867873+00:00 0:00:01.661873 5235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-02T06:40:03.330019+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-11-02T05:50:47.457694+00:00 PythonOperator 2020-11-02T06:39:57.012727+00:00 2020-11-02T06:39:59.787386+00:00 0:00:02.774659 5234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-02T06:39:55.292252+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-02T04:00:00+00:00 EmrJobFlowSensor 2020-11-02T05:00:29.967626+00:00 2020-11-02T05:12:33.121168+00:00 0:12:03.153542 5230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-02T05:00:28.087797+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-02T04:00:00+00:00 EmrCreateJobFlowOperator 2020-11-02T05:00:20.161585+00:00 2020-11-02T05:00:21.886002+00:00 0:00:01.724417 5229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-02T05:00:18.058624+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-02T04:00:00+00:00 PythonOperator 2020-11-02T05:00:10.175909+00:00 2020-11-02T05:00:13.179709+00:00 0:00:03.003800 5228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-02T05:00:08.025395+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-02T03:00:00+00:00 EmrJobFlowSensor 2020-11-02T04:00:31.600818+00:00 2020-11-02T04:12:34.741564+00:00 0:12:03.140746 5226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-02T04:00:29.853132+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-02T03:00:00+00:00 EmrCreateJobFlowOperator 2020-11-02T04:00:21.891469+00:00 2020-11-02T04:00:23.622262+00:00 0:00:01.730793 5225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-02T04:00:19.963062+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-02T03:00:00+00:00 PythonOperator 2020-11-02T04:00:11.692317+00:00 2020-11-02T04:00:14.612019+00:00 0:00:02.919702 5224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-02T04:00:09.827373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-02T02:00:00+00:00 EmrJobFlowSensor 2020-11-02T03:00:28.800683+00:00 2020-11-02T03:12:31.898862+00:00 0:12:03.098179 5222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-02T03:00:27.036888+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-02T02:00:00+00:00 EmrCreateJobFlowOperator 2020-11-02T03:00:18.898095+00:00 2020-11-02T03:00:20.782555+00:00 0:00:01.884460 5221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-02T03:00:17.007770+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-02T02:00:00+00:00 PythonOperator 2020-11-02T03:00:11.215427+00:00 2020-11-02T03:00:14.224091+00:00 0:00:03.008664 5220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-02T03:00:09.009319+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-02T01:00:00+00:00 EmrJobFlowSensor 2020-11-02T02:00:28.449366+00:00 2020-11-02T02:12:31.712971+00:00 0:12:03.263605 5218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-02T02:00:26.514208+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-02T01:00:00+00:00 EmrCreateJobFlowOperator 2020-11-02T02:00:18.402296+00:00 2020-11-02T02:00:20.197590+00:00 0:00:01.795294 5217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-02T02:00:16.499581+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-02T01:00:00+00:00 PythonOperator 2020-11-02T02:00:08.521974+00:00 2020-11-02T02:00:11.376557+00:00 0:00:02.854583 5216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-02T02:00:06.498519+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-02T00:00:00+00:00 EmrJobFlowSensor 2020-11-02T01:00:26.575562+00:00 2020-11-02T01:12:29.636053+00:00 0:12:03.060491 5214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-02T01:00:24.845416+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-02T00:00:00+00:00 EmrCreateJobFlowOperator 2020-11-02T01:00:16.574813+00:00 2020-11-02T01:00:18.335073+00:00 0:00:01.760260 5213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-02T01:00:14.836962+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-02T00:00:00+00:00 PythonOperator 2020-11-02T01:00:06.656334+00:00 2020-11-02T01:00:09.532809+00:00 0:00:02.876475 5212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-02T01:00:04.824142+00:00 2 default_pool