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 2021-04-22T23:00:00+00:00 EmrJobFlowSensor 2021-04-23T23:01:08.461015+00:00 2021-04-23T23:09:10.934744+00:00 0:08:02.473729 20535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:01:05.810640+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T23:00:45.974750+00:00 2021-04-23T23:00:47.711978+00:00 0:00:01.737228 20533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T23:00:43.785726+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-22T23:00:00+00:00 PythonOperator 2021-04-23T23:00:24.168089+00:00 2021-04-23T23:00:27.207821+00:00 0:00:03.039732 20531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T23:00:21.761426+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-21T23:00:00+00:00 EmrJobFlowSensor 2021-04-22T23:00:55.950335+00:00 2021-04-22T23:09:58.453649+00:00 0:09:02.503314 20172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:00:53.750576+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T23:00:36.261888+00:00 2021-04-22T23:00:37.986739+00:00 0:00:01.724851 20170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T23:00:33.885532+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-21T23:00:00+00:00 PythonOperator 2021-04-22T23:00:14.131646+00:00 2021-04-22T23:00:17.380638+00:00 0:00:03.248992 20168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T23:00:11.702960+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-20T23:00:00+00:00 EmrJobFlowSensor 2021-04-22T09:11:05.770982+00:00 2021-04-22T09:20:08.528883+00:00 0:09:02.757901 19964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:11:03.437715+00:00 8 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T09:10:45.813508+00:00 2021-04-22T09:10:47.557311+00:00 0:00:01.743803 19963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T09:10:43.424936+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-20T23:00:00+00:00 PythonOperator 2021-04-22T09:10:23.826897+00:00 2021-04-22T09:10:27.011936+00:00 0:00:03.185039 19962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T09:10:21.409315+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-16T23:00:00+00:00 EmrJobFlowSensor 2020-11-17T23:00:23.678482+00:00 2020-11-17T23:09:26.199196+00:00 0:09:02.520714 5703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-17T23:00:22.130517+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-16T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-17T23:00:13.799650+00:00 2020-11-17T23:00:15.471026+00:00 0:00:01.671376 5702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-17T23:00:12.161855+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-16T23:00:00+00:00 PythonOperator 2020-11-17T23:00:05.687852+00:00 2020-11-17T23:00:08.501452+00:00 0:00:02.813600 5701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-17T23:00:04.116341+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-15T23:00:00+00:00 EmrJobFlowSensor 2020-11-16T23:00:31.659528+00:00 2020-11-16T23:10:34.359678+00:00 0:10:02.700150 5676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-16T23:00:30.060413+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-15T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-16T23:00:21.625158+00:00 2020-11-16T23:00:23.220487+00:00 0:00:01.595329 5675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-16T23:00:20.050530+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-15T23:00:00+00:00 PythonOperator 2020-11-16T23:00:11.686325+00:00 2020-11-16T23:00:14.482720+00:00 0:00:02.796395 5674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-16T23:00:10.044342+00:00 2 default_pool
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 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 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 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 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 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-past-delete-job_v002 check_cluster_status 2020-10-31T23:00:00+00:00 EmrJobFlowSensor 2020-11-01T23:00:30.467164+00:00 2020-11-01T23:10:33.254662+00:00 0:10:02.787498 5206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-01T23:00:28.411643+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-31T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-01T23:00:20.434740+00:00 2020-11-01T23:00:22.067449+00:00 0:00:01.632709 5204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-01T23:00:18.406367+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-31T23:00:00+00:00 PythonOperator 2020-11-01T23:00:10.643119+00:00 2020-11-01T23:00:13.399859+00:00 0:00:02.756740 5202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-01T23:00:08.388080+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-10-30T23:00:00+00:00 EmrJobFlowSensor 2020-10-31T23:00:28.197480+00:00 2020-10-31T23:10:31.198512+00:00 0:10:03.001032 5104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-31T23:00:26.212590+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-30T23:00:00+00:00 EmrCreateJobFlowOperator 2020-10-31T23:00:18.096742+00:00 2020-10-31T23:00:19.949591+00:00 0:00:01.852849 5102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-31T23:00:16.200490+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-30T23:00:00+00:00 PythonOperator 2020-10-31T23:00:08.459722+00:00 2020-10-31T23:00:11.302711+00:00 0:00:02.842989 5100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-31T23:00:06.176996+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-10-29T23:00:00+00:00 EmrJobFlowSensor 2020-10-30T23:00:31.293488+00:00 2020-10-30T23:10:34.125510+00:00 0:10:02.832022 5003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-30T23:00:29.524362+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-29T23:00:00+00:00 EmrCreateJobFlowOperator 2020-10-30T23:00:21.325933+00:00 2020-10-30T23:00:22.933914+00:00 0:00:01.607981 5001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-30T23:00:19.511403+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-29T23:00:00+00:00 PythonOperator 2020-10-30T23:00:11.329411+00:00 2020-10-30T23:00:14.093549+00:00 0:00:02.764138 4999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-30T23:00:09.501534+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-10-28T23:00:00+00:00 EmrJobFlowSensor 2020-10-29T23:00:25.046447+00:00 2020-10-29T23:09:27.791420+00:00 0:09:02.744973 4900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T23:00:23.293920+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-28T23:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T23:00:15.348892+00:00 2020-10-29T23:00:16.994555+00:00 0:00:01.645663 4898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T23:00:13.290830+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-28T23:00:00+00:00 PythonOperator 2020-10-29T23:00:05.014847+00:00 2020-10-29T23:00:07.756383+00:00 0:00:02.741536 4896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T23:00:03.271394+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-10-27T23:00:00+00:00 EmrJobFlowSensor 2020-10-28T23:00:31.864178+00:00 2020-10-28T23:10:34.620961+00:00 0:10:02.756783 4803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T23:00:30.072958+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-27T23:00:00+00:00 EmrCreateJobFlowOperator 2020-10-28T23:00:21.755394+00:00 2020-10-28T23:00:23.443007+00:00 0:00:01.687613 4802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T23:00:20.068179+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-27T23:00:00+00:00 PythonOperator 2020-10-28T23:00:12.106323+00:00 2020-10-28T23:00:14.944953+00:00 0:00:02.838630 4801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T23:00:10.058337+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-10-28T05:53:08.161941+00:00 EmrJobFlowSensor 2020-10-28T05:53:33.183854+00:00 2020-10-28T06:03:35.852089+00:00 0:10:02.668235 4747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T05:53:31.567302+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-28T05:53:08.161941+00:00 EmrCreateJobFlowOperator 2020-10-28T05:53:23.440565+00:00 2020-10-28T05:53:25.083576+00:00 0:00:01.643011 4746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T05:53:21.559233+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-28T05:53:08.161941+00:00 PythonOperator 2020-10-28T05:53:13.224286+00:00 2020-10-28T05:53:16.029749+00:00 0:00:02.805463 4745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T05:53:11.547974+00:00 2 default_pool