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 create_emr_steps 2021-11-11T23:00:00+00:00 PythonOperator 2021-11-12T23:00:22.608288+00:00 2021-11-12T23:00:26.430937+00:00 0:00:03.822649 102958 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-12T23:00:19.967640+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-10T23:00:00+00:00 EmrJobFlowSensor 2021-11-11T23:01:18.356630+00:00 2021-11-11T23:09:21.034184+00:00 0:08:02.677554 102487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-11T23:01:16.201067+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-11T23:00:56.702602+00:00 2021-11-11T23:00:58.503763+00:00 0:00:01.801161 102485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-11T23:00:54.255954+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-10T23:00:00+00:00 PythonOperator 2021-11-11T23:00:34.515968+00:00 2021-11-11T23:00:37.947037+00:00 0:00:03.431069 102482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-11T23:00:32.155926+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-09T23:00:00+00:00 EmrJobFlowSensor 2021-11-10T23:04:44.751339+00:00 2021-11-10T23:13:47.576009+00:00 0:09:02.824670 102131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-10T23:04:42.262118+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-10T23:04:22.538548+00:00 2021-11-10T23:04:24.429268+00:00 0:00:01.890720 102128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-10T23:04:20.181310+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-09T23:00:00+00:00 PythonOperator 2021-11-10T23:04:02.360139+00:00 2021-11-10T23:04:06.261331+00:00 0:00:03.901192 102125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-10T23:03:58.127672+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-08T23:00:00+00:00 EmrJobFlowSensor 2021-11-09T23:03:46.962784+00:00 2021-11-09T23:13:49.907315+00:00 0:10:02.944531 101677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-09T23:03:44.580653+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-09T23:03:25.509961+00:00 2021-11-09T23:03:27.392694+00:00 0:00:01.882733 101674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-09T23:03:22.558564+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-08T23:00:00+00:00 PythonOperator 2021-11-09T23:03:05.315207+00:00 2021-11-09T23:03:08.882903+00:00 0:00:03.567696 101671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-09T23:03:02.539495+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-07T23:00:00+00:00 EmrJobFlowSensor 2021-11-08T23:01:07.536945+00:00 2021-11-08T23:12:10.801283+00:00 0:11:03.264338 101260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-08T23:01:05.195766+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-08T23:00:47.607957+00:00 2021-11-08T23:00:49.672131+00:00 0:00:02.064174 101257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-08T23:00:45.150845+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-07T23:00:00+00:00 PythonOperator 2021-11-08T23:00:25.593710+00:00 2021-11-08T23:00:30.081009+00:00 0:00:04.487299 101254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-08T23:00:23.159945+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-06T23:00:00+00:00 EmrJobFlowSensor 2021-11-07T23:00:54.823290+00:00 2021-11-07T23:11:58.039451+00:00 0:11:03.216161 100822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-07T23:00:52.607053+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-07T23:00:30.838294+00:00 2021-11-07T23:00:32.600585+00:00 0:00:01.762291 100821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-07T23:00:28.584527+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-06T23:00:00+00:00 PythonOperator 2021-11-07T23:00:09.120909+00:00 2021-11-07T23:00:12.673262+00:00 0:00:03.552353 100820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-07T23:00:06.520851+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-05T23:00:00+00:00 EmrJobFlowSensor 2021-11-06T23:00:47.009190+00:00 2021-11-06T23:11:50.130161+00:00 0:11:03.120971 100725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-06T23:00:44.715042+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-06T23:00:27.171209+00:00 2021-11-06T23:00:28.994036+00:00 0:00:01.822827 100724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-06T23:00:24.696797+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-05T23:00:00+00:00 PythonOperator 2021-11-06T23:00:05.419760+00:00 2021-11-06T23:00:09.007939+00:00 0:00:03.588179 100723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-06T23:00:02.687200+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-04T23:00:00+00:00 EmrJobFlowSensor 2021-11-05T23:01:06.072513+00:00 2021-11-05T23:11:09.338564+00:00 0:10:03.266051 100627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-05T23:01:03.762740+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-05T23:00:44.067343+00:00 2021-11-05T23:00:45.854820+00:00 0:00:01.787477 100626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-05T23:00:41.745046+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-04T23:00:00+00:00 PythonOperator 2021-11-05T23:00:16.276951+00:00 2021-11-05T23:00:19.560098+00:00 0:00:03.283147 100625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-05T23:00:13.728447+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-03T23:00:00+00:00 EmrJobFlowSensor 2021-11-04T23:01:03.778888+00:00 2021-11-04T23:12:07.124755+00:00 0:11:03.345867 100529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-04T23:01:01.358161+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-04T23:00:41.996030+00:00 2021-11-04T23:00:43.772262+00:00 0:00:01.776232 100528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-04T23:00:39.355559+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-03T23:00:00+00:00 PythonOperator 2021-11-04T23:00:19.687677+00:00 2021-11-04T23:00:23.270065+00:00 0:00:03.582388 100527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-04T23:00:17.161639+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-02T23:00:00+00:00 EmrJobFlowSensor 2021-11-03T23:00:57.359376+00:00 2021-11-03T23:12:00.573742+00:00 0:11:03.214366 100378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-03T23:00:55.059619+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-03T23:00:35.351278+00:00 2021-11-03T23:00:37.139915+00:00 0:00:01.788637 100376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-03T23:00:32.990386+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-02T23:00:00+00:00 PythonOperator 2021-11-03T23:00:16.087053+00:00 2021-11-03T23:00:21.045213+00:00 0:00:04.958160 100373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-03T23:00:12.976941+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-11-01T23:00:00+00:00 EmrJobFlowSensor 2021-11-02T23:00:50.051006+00:00 2021-11-02T23:10:53.098469+00:00 0:10:03.047463 100004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-02T23:00:47.266353+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-11-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-02T23:00:30.016267+00:00 2021-11-02T23:00:31.870073+00:00 0:00:01.853806 100001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-02T23:00:27.185571+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-11-01T23:00:00+00:00 PythonOperator 2021-11-02T23:00:07.626941+00:00 2021-11-02T23:00:11.174201+00:00 0:00:03.547260 99998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-02T23:00:05.115129+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-31T23:00:00+00:00 EmrJobFlowSensor 2021-11-01T23:00:50.066989+00:00 2021-11-01T23:11:53.353967+00:00 0:11:03.286978 99570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-11-01T23:00:47.330421+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-11-01T23:00:29.788893+00:00 2021-11-01T23:00:31.743494+00:00 0:00:01.954601 99567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-11-01T23:00:27.312232+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-31T23:00:00+00:00 PythonOperator 2021-11-01T23:00:07.994210+00:00 2021-11-01T23:00:11.427242+00:00 0:00:03.433032 99564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-11-01T23:00:05.291722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-30T23:00:00+00:00 EmrJobFlowSensor 2021-10-31T23:00:56.931295+00:00 2021-10-31T23:12:00.195136+00:00 0:11:03.263841 99156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-31T23:00:54.503758+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-31T23:00:34.789710+00:00 2021-10-31T23:00:36.608339+00:00 0:00:01.818629 99153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-31T23:00:32.483566+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-30T23:00:00+00:00 PythonOperator 2021-10-31T23:00:13.224754+00:00 2021-10-31T23:00:16.767749+00:00 0:00:03.542995 99150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-31T23:00:10.398567+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-29T23:00:00+00:00 EmrJobFlowSensor 2021-10-30T23:01:05.914692+00:00 2021-10-30T23:11:09.340877+00:00 0:10:03.426185 98720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-30T23:01:03.645813+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-30T23:00:39.761691+00:00 2021-10-30T23:00:41.497937+00:00 0:00:01.736246 98717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-30T23:00:37.550879+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-29T23:00:00+00:00 PythonOperator 2021-10-30T23:00:17.979769+00:00 2021-10-30T23:00:21.474978+00:00 0:00:03.495209 98714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-30T23:00:15.527211+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-28T23:00:00+00:00 EmrJobFlowSensor 2021-10-29T23:01:04.055200+00:00 2021-10-29T23:12:07.308174+00:00 0:11:03.252974 98287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-29T23:01:01.745219+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-28T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-29T23:00:34.005420+00:00 2021-10-29T23:00:35.783282+00:00 0:00:01.777862 98284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-29T23:00:31.720225+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-28T23:00:00+00:00 PythonOperator 2021-10-29T23:00:12.100514+00:00 2021-10-29T23:00:15.261947+00:00 0:00:03.161433 98281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-29T23:00:09.768028+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-27T23:00:00+00:00 EmrJobFlowSensor 2021-10-28T23:01:28.318183+00:00 2021-10-28T23:11:31.445353+00:00 0:10:03.127170 97851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-28T23:01:26.063313+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-27T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-28T23:01:08.206836+00:00 2021-10-28T23:01:10.035829+00:00 0:00:01.828993 97848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-28T23:01:05.981208+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-27T23:00:00+00:00 PythonOperator 2021-10-28T23:00:46.525494+00:00 2021-10-28T23:00:49.921652+00:00 0:00:03.396158 97846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-28T23:00:43.955881+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-26T23:00:00+00:00 EmrJobFlowSensor 2021-10-27T23:00:57.525768+00:00 2021-10-27T23:11:00.903692+00:00 0:10:03.377924 97416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-27T23:00:54.986428+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-26T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-27T23:00:35.431823+00:00 2021-10-27T23:00:37.277865+00:00 0:00:01.846042 97413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-27T23:00:32.882576+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-26T23:00:00+00:00 PythonOperator 2021-10-27T23:00:15.250676+00:00 2021-10-27T23:00:19.487031+00:00 0:00:04.236355 97410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-27T23:00:12.833114+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-25T23:00:00+00:00 EmrJobFlowSensor 2021-10-26T23:00:51.047602+00:00 2021-10-26T23:10:54.212741+00:00 0:10:03.165139 96844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-26T23:00:48.459275+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-26T23:00:29.268657+00:00 2021-10-26T23:00:31.230056+00:00 0:00:01.961399 96841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-26T23:00:26.288370+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-25T23:00:00+00:00 PythonOperator 2021-10-26T23:00:06.914100+00:00 2021-10-26T23:00:10.320960+00:00 0:00:03.406860 96838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-26T23:00:04.282478+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-24T23:00:00+00:00 EmrJobFlowSensor 2021-10-25T23:00:57.706488+00:00 2021-10-25T23:10:00.627614+00:00 0:09:02.921126 96320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-25T23:00:55.399370+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-25T23:00:36.302486+00:00 2021-10-25T23:00:38.155930+00:00 0:00:01.853444 96319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-25T23:00:33.385412+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-24T23:00:00+00:00 PythonOperator 2021-10-25T23:00:14.456447+00:00 2021-10-25T23:00:17.740974+00:00 0:00:03.284527 96316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-25T23:00:11.367912+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-23T23:00:00+00:00 EmrJobFlowSensor 2021-10-24T23:00:53.830715+00:00 2021-10-24T23:09:56.930992+00:00 0:09:03.100277 95966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-24T23:00:51.615163+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-24T23:00:32.235541+00:00 2021-10-24T23:00:34.070099+00:00 0:00:01.834558 95963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-24T23:00:29.661002+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-23T23:00:00+00:00 PythonOperator 2021-10-24T23:00:12.100651+00:00 2021-10-24T23:00:15.606692+00:00 0:00:03.506041 95960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-24T23:00:09.583675+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-22T23:00:00+00:00 EmrJobFlowSensor 2021-10-23T23:00:57.257054+00:00 2021-10-23T23:10:00.252529+00:00 0:09:02.995475 95602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-23T23:00:54.809755+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-23T23:00:35.237280+00:00 2021-10-23T23:00:37.070535+00:00 0:00:01.833255 95599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-23T23:00:32.787521+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-22T23:00:00+00:00 PythonOperator 2021-10-23T23:00:13.559684+00:00 2021-10-23T23:00:17.021415+00:00 0:00:03.461731 95596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-23T23:00:10.685121+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-21T23:00:00+00:00 EmrJobFlowSensor 2021-10-22T23:00:55.529492+00:00 2021-10-22T23:09:59.125546+00:00 0:09:03.596054 95239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-22T23:00:52.744411+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-22T23:00:33.235615+00:00 2021-10-22T23:00:35.149954+00:00 0:00:01.914339 95236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-22T23:00:30.722827+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-21T23:00:00+00:00 PythonOperator 2021-10-22T23:00:11.569919+00:00 2021-10-22T23:00:14.837004+00:00 0:00:03.267085 95232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-22T23:00:08.424636+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-20T23:00:00+00:00 EmrJobFlowSensor 2021-10-21T23:00:50.334825+00:00 2021-10-21T23:09:53.478859+00:00 0:09:03.144034 94927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-21T23:00:47.869894+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-21T23:00:28.235343+00:00 2021-10-21T23:00:30.089093+00:00 0:00:01.853750 94926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-21T23:00:25.789895+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-20T23:00:00+00:00 PythonOperator 2021-10-21T23:00:08.148199+00:00 2021-10-21T23:00:11.441520+00:00 0:00:03.293321 94925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-21T23:00:05.770441+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-19T23:00:00+00:00 EmrJobFlowSensor 2021-10-20T23:01:02.233397+00:00 2021-10-20T23:09:05.160298+00:00 0:08:02.926901 94785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-20T23:00:59.592278+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-20T23:00:40.208797+00:00 2021-10-20T23:00:42.049055+00:00 0:00:01.840258 94784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-20T23:00:37.584735+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-19T23:00:00+00:00 PythonOperator 2021-10-20T23:00:17.810052+00:00 2021-10-20T23:00:21.048831+00:00 0:00:03.238779 94783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-20T23:00:15.502775+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-18T23:00:00+00:00 EmrJobFlowSensor 2021-10-19T23:00:50.799573+00:00 2021-10-19T23:09:53.889504+00:00 0:09:03.089931 94684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-19T23:00:48.267791+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-18T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-19T23:00:30.406096+00:00 2021-10-19T23:00:32.300060+00:00 0:00:01.893964 94683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-19T23:00:28.082557+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-18T23:00:00+00:00 PythonOperator 2021-10-19T23:00:08.411661+00:00 2021-10-19T23:00:11.866122+00:00 0:00:03.454461 94682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-19T23:00:06.038466+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-17T23:00:00+00:00 EmrJobFlowSensor 2021-10-18T23:00:54.565239+00:00 2021-10-18T23:10:57.869357+00:00 0:10:03.304118 94579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-18T23:00:52.154565+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-17T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-18T23:00:32.147893+00:00 2021-10-18T23:00:33.959590+00:00 0:00:01.811697 94578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-18T23:00:29.959140+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-17T23:00:00+00:00 PythonOperator 2021-10-18T23:00:10.475735+00:00 2021-10-18T23:00:13.841514+00:00 0:00:03.365779 94577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-18T23:00:07.941802+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-16T23:00:00+00:00 EmrJobFlowSensor 2021-10-17T23:01:03.093243+00:00 2021-10-17T23:10:06.147957+00:00 0:09:03.054714 94479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-17T23:01:00.709241+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-17T23:00:38.862504+00:00 2021-10-17T23:00:40.682223+00:00 0:00:01.819719 94478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-17T23:00:36.695089+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-16T23:00:00+00:00 PythonOperator 2021-10-17T23:00:18.965683+00:00 2021-10-17T23:00:22.237456+00:00 0:00:03.271773 94477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-17T23:00:16.662417+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-15T23:00:00+00:00 EmrJobFlowSensor 2021-10-16T23:01:01.541731+00:00 2021-10-16T23:11:04.709464+00:00 0:10:03.167733 94284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-16T23:00:59.193806+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-15T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-16T23:00:41.493520+00:00 2021-10-16T23:00:43.501347+00:00 0:00:02.007827 94281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-16T23:00:39.176482+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-15T23:00:00+00:00 PythonOperator 2021-10-16T23:00:19.385520+00:00 2021-10-16T23:00:22.577376+00:00 0:00:03.191856 94278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-16T23:00:17.158218+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-14T23:00:00+00:00 EmrJobFlowSensor 2021-10-15T23:02:28.388209+00:00 2021-10-15T23:12:31.435903+00:00 0:10:03.047694 93848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-15T23:02:26.186773+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-15T23:01:58.423395+00:00 2021-10-15T23:02:00.325636+00:00 0:00:01.902241 93847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-15T23:01:56.135621+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-14T23:00:00+00:00 PythonOperator 2021-10-15T23:01:20.818025+00:00 2021-10-15T23:01:24.064311+00:00 0:00:03.246286 93846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-15T23:01:18.259955+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-13T23:00:00+00:00 EmrJobFlowSensor 2021-10-14T23:00:54.074371+00:00 2021-10-14T23:08:56.775237+00:00 0:08:02.700866 93410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-14T23:00:51.752386+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-14T23:00:32.184041+00:00 2021-10-14T23:00:34.007330+00:00 0:00:01.823289 93407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-14T23:00:29.685566+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-13T23:00:00+00:00 PythonOperator 2021-10-14T23:00:10.096372+00:00 2021-10-14T23:00:13.352825+00:00 0:00:03.256453 93404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-14T23:00:07.606144+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-12T23:00:00+00:00 EmrJobFlowSensor 2021-10-13T23:01:25.402803+00:00 2021-10-13T23:10:28.269282+00:00 0:09:02.866479 92976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-13T23:01:23.047822+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-13T23:00:47.670791+00:00 2021-10-13T23:00:49.438541+00:00 0:00:01.767750 92973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-13T23:00:45.065204+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-12T23:00:00+00:00 PythonOperator 2021-10-13T23:00:25.502586+00:00 2021-10-13T23:00:29.172128+00:00 0:00:03.669542 92969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-13T23:00:23.062588+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-11T23:00:00+00:00 EmrJobFlowSensor 2021-10-12T23:00:49.977902+00:00 2021-10-12T23:09:52.813413+00:00 0:09:02.835511 92538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-12T23:00:47.583361+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-12T23:00:29.889917+00:00 2021-10-12T23:00:31.708016+00:00 0:00:01.818099 92535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-12T23:00:27.538434+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-11T23:00:00+00:00 PythonOperator 2021-10-12T23:00:07.938502+00:00 2021-10-12T23:00:11.177610+00:00 0:00:03.239108 92532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-12T23:00:05.518949+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-10T23:00:00+00:00 EmrJobFlowSensor 2021-10-11T23:00:51.287013+00:00 2021-10-11T23:09:54.173325+00:00 0:09:02.886312 92102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-11T23:00:48.679571+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-11T23:00:29.157718+00:00 2021-10-11T23:00:31.021059+00:00 0:00:01.863341 92099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-11T23:00:26.659699+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-10T23:00:00+00:00 PythonOperator 2021-10-11T23:00:07.178193+00:00 2021-10-11T23:00:10.431450+00:00 0:00:03.253257 92096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-11T23:00:04.536461+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-10-09T23:00:00+00:00 EmrJobFlowSensor 2021-10-10T23:00:50.866886+00:00 2021-10-10T23:10:54.249894+00:00 0:10:03.383008 91665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-10-10T23:00:48.373916+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-10-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-10-10T23:00:28.968874+00:00 2021-10-10T23:00:30.887405+00:00 0:00:01.918531 91662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-10-10T23:00:26.359663+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-10-09T23:00:00+00:00 PythonOperator 2021-10-10T23:00:08.698220+00:00 2021-10-10T23:00:11.872667+00:00 0:00:03.174447 91660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-10-10T23:00:06.287796+00:00 2 default_pool