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-delta-past-delete-job_v002 create_emr_steps 2022-12-11T23:00:00+00:00 PythonOperator 2022-12-12T23:00:05.820713+00:00 2022-12-12T23:00:08.147606+00:00 0:00:02.326893 301281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-12T23:00:03.178760+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-10T23:00:00+00:00 EmrJobFlowSensor 2022-12-11T23:01:03.892031+00:00 2022-12-11T23:12:05.708488+00:00 0:11:01.816457 300763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-11T23:01:01.420152+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-10T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-11T23:00:41.520227+00:00 2022-12-11T23:00:42.277786+00:00 0:00:00.757559 300760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-11T23:00:39.336712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-10T23:00:00+00:00 PythonOperator 2022-12-11T23:00:19.521286+00:00 2022-12-11T23:00:22.004504+00:00 0:00:02.483218 300757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-11T23:00:17.312265+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-09T23:00:00+00:00 EmrJobFlowSensor 2022-12-10T23:00:48.691287+00:00 2022-12-10T23:11:51.045748+00:00 0:11:02.354461 300222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-10T23:00:45.235224+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-09T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-10T23:00:28.133391+00:00 2022-12-10T23:00:29.409051+00:00 0:00:01.275660 300220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-10T23:00:23.203422+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-09T23:00:00+00:00 PythonOperator 2022-12-10T23:00:03.981142+00:00 2022-12-10T23:00:06.348451+00:00 0:00:02.367309 300217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-10T23:00:01.091167+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-08T23:00:00+00:00 EmrJobFlowSensor 2022-12-09T23:00:48.582092+00:00 2022-12-09T23:11:50.385340+00:00 0:11:01.803248 299679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-09T23:00:46.442772+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-08T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-09T23:00:27.988177+00:00 2022-12-09T23:00:29.036970+00:00 0:00:01.048793 299676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-09T23:00:24.374566+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-08T23:00:00+00:00 PythonOperator 2022-12-09T23:00:04.946572+00:00 2022-12-09T23:00:08.519221+00:00 0:00:03.572649 299673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-09T23:00:02.376870+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-07T23:00:00+00:00 EmrJobFlowSensor 2022-12-08T23:05:54.596191+00:00 2022-12-08T23:15:56.362432+00:00 0:10:01.766241 299155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-08T23:05:52.310004+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-07T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-08T23:05:33.310271+00:00 2022-12-08T23:05:34.112005+00:00 0:00:00.801734 299151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-08T23:05:30.269788+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-07T23:00:00+00:00 PythonOperator 2022-12-08T23:05:11.350773+00:00 2022-12-08T23:05:14.080882+00:00 0:00:02.730109 299147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-08T23:05:08.251102+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-06T23:00:00+00:00 EmrJobFlowSensor 2022-12-07T23:07:50.596527+00:00 2022-12-07T23:18:53.020843+00:00 0:11:02.424316 298653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-07T23:07:48.234764+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-06T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-07T23:07:30.818801+00:00 2022-12-07T23:07:31.631846+00:00 0:00:00.813045 298650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-07T23:07:26.166149+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-06T23:00:00+00:00 PythonOperator 2022-12-07T23:07:07.600677+00:00 2022-12-07T23:07:12.548234+00:00 0:00:04.947557 298645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-07T23:07:04.137392+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-05T23:00:00+00:00 EmrJobFlowSensor 2022-12-06T23:04:53.088549+00:00 2022-12-06T23:15:54.936428+00:00 0:11:01.847879 298156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-06T23:04:50.972407+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-05T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-06T23:04:31.059445+00:00 2022-12-06T23:04:31.861250+00:00 0:00:00.801805 298153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-06T23:04:28.934195+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-05T23:00:00+00:00 PythonOperator 2022-12-06T23:04:08.994806+00:00 2022-12-06T23:04:12.908681+00:00 0:00:03.913875 298150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-06T23:04:06.893164+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-04T23:00:00+00:00 EmrJobFlowSensor 2022-12-05T23:02:05.079543+00:00 2022-12-05T23:12:06.807949+00:00 0:10:01.728406 297681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-05T23:02:02.765579+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-04T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-05T23:01:43.012557+00:00 2022-12-05T23:01:43.795774+00:00 0:00:00.783217 297678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-05T23:01:40.742661+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-04T23:00:00+00:00 PythonOperator 2022-12-05T23:00:18.805014+00:00 2022-12-05T23:00:21.187201+00:00 0:00:02.382187 297672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-05T23:00:16.565654+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-03T23:00:00+00:00 EmrJobFlowSensor 2022-12-04T23:01:07.805696+00:00 2022-12-04T23:12:09.717487+00:00 0:11:01.911791 297165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-04T23:01:05.571004+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-03T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-04T23:00:45.759437+00:00 2022-12-04T23:00:46.544045+00:00 0:00:00.784608 297162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-04T23:00:43.547750+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-03T23:00:00+00:00 PythonOperator 2022-12-04T23:00:24.040185+00:00 2022-12-04T23:00:26.955335+00:00 0:00:02.915150 297159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-04T23:00:21.594006+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-02T23:00:00+00:00 EmrJobFlowSensor 2022-12-03T23:01:01.424191+00:00 2022-12-03T23:11:03.837743+00:00 0:10:02.413552 296638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-03T23:00:58.214819+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-02T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-03T23:00:38.303980+00:00 2022-12-03T23:00:39.076200+00:00 0:00:00.772220 296635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-03T23:00:36.132515+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-02T23:00:00+00:00 PythonOperator 2022-12-03T23:00:18.519714+00:00 2022-12-03T23:00:21.079886+00:00 0:00:02.560172 296632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-03T23:00:16.053128+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-01T23:00:00+00:00 EmrJobFlowSensor 2022-12-02T23:01:01.027358+00:00 2022-12-02T23:12:02.893323+00:00 0:11:01.865965 296106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-02T23:00:57.900147+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-01T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-02T23:00:39.795233+00:00 2022-12-02T23:00:41.063022+00:00 0:00:01.267789 296103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-02T23:00:35.896410+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-01T23:00:00+00:00 PythonOperator 2022-12-02T23:00:17.931657+00:00 2022-12-02T23:00:20.095315+00:00 0:00:02.163658 296100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-02T23:00:15.761367+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-30T23:00:00+00:00 EmrJobFlowSensor 2022-12-01T23:01:06.105273+00:00 2022-12-01T23:11:07.879156+00:00 0:10:01.773883 295594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-01T23:01:03.703924+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-30T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-01T23:00:43.851543+00:00 2022-12-01T23:00:44.580253+00:00 0:00:00.728710 295591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-01T23:00:41.593249+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-30T23:00:00+00:00 PythonOperator 2022-12-01T23:00:21.891748+00:00 2022-12-01T23:00:25.336852+00:00 0:00:03.445104 295588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-01T23:00:19.609921+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-29T23:00:00+00:00 EmrJobFlowSensor 2022-11-30T23:01:38.605757+00:00 2022-11-30T23:12:40.549513+00:00 0:11:01.943756 295099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-30T23:01:36.390256+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-29T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-30T23:01:19.016737+00:00 2022-11-30T23:01:19.775701+00:00 0:00:00.758964 295096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-30T23:01:16.373156+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-29T23:00:00+00:00 PythonOperator 2022-11-30T23:00:57.270719+00:00 2022-11-30T23:00:59.557722+00:00 0:00:02.287003 295093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-30T23:00:54.353707+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-28T23:00:00+00:00 EmrJobFlowSensor 2022-11-29T23:00:48.799455+00:00 2022-11-29T23:12:51.203517+00:00 0:12:02.404062 294546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-29T23:00:46.631402+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-28T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-29T23:00:26.948497+00:00 2022-11-29T23:00:27.809632+00:00 0:00:00.861135 294543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-29T23:00:24.581572+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-28T23:00:00+00:00 PythonOperator 2022-11-29T23:00:05.360127+00:00 2022-11-29T23:00:07.579438+00:00 0:00:02.219311 294540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-29T23:00:02.587224+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-27T23:00:00+00:00 EmrJobFlowSensor 2022-11-28T23:00:51.148528+00:00 2022-11-28T23:11:52.982262+00:00 0:11:01.833734 293960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-28T23:00:48.939263+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-27T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-28T23:00:30.976855+00:00 2022-11-28T23:00:31.722413+00:00 0:00:00.745558 293957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-28T23:00:28.841127+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-27T23:00:00+00:00 PythonOperator 2022-11-28T23:00:08.917455+00:00 2022-11-28T23:00:11.931997+00:00 0:00:03.014542 293954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-28T23:00:06.761210+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-26T23:00:00+00:00 EmrJobFlowSensor 2022-11-27T23:01:15.831811+00:00 2022-11-27T23:12:17.841447+00:00 0:11:02.009636 293367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-27T23:01:13.534715+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-26T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-27T23:00:53.748054+00:00 2022-11-27T23:00:54.539175+00:00 0:00:00.791121 293364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-27T23:00:51.485736+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-26T23:00:00+00:00 PythonOperator 2022-11-27T23:00:33.619089+00:00 2022-11-27T23:00:36.891034+00:00 0:00:03.271945 293361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-27T23:00:31.473475+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-25T23:00:00+00:00 EmrJobFlowSensor 2022-11-26T23:00:52.149717+00:00 2022-11-26T23:11:54.159165+00:00 0:11:02.009448 292779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-26T23:00:49.839223+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-25T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-26T23:00:29.975334+00:00 2022-11-26T23:00:30.863293+00:00 0:00:00.887959 292776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-26T23:00:27.816855+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-25T23:00:00+00:00 PythonOperator 2022-11-26T23:00:10.106976+00:00 2022-11-26T23:00:13.215891+00:00 0:00:03.108915 292773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-26T23:00:07.741622+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-24T23:00:00+00:00 EmrJobFlowSensor 2022-11-25T23:01:04.267732+00:00 2022-11-25T23:13:06.269909+00:00 0:12:02.002177 292191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-25T23:01:02.058283+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-24T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-25T23:00:42.256552+00:00 2022-11-25T23:00:43.044243+00:00 0:00:00.787691 292188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-25T23:00:40.007162+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-24T23:00:00+00:00 PythonOperator 2022-11-25T23:00:22.238040+00:00 2022-11-25T23:00:25.493001+00:00 0:00:03.254961 292185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-25T23:00:19.987241+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-23T23:00:00+00:00 EmrJobFlowSensor 2022-11-24T23:01:08.992503+00:00 2022-11-24T23:11:10.747786+00:00 0:10:01.755283 291595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-24T23:01:06.796949+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-23T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-24T23:00:30.391809+00:00 2022-11-24T23:00:31.216681+00:00 0:00:00.824872 291592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-24T23:00:28.156101+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-23T23:00:00+00:00 PythonOperator 2022-11-24T23:00:10.294613+00:00 2022-11-24T23:00:13.053661+00:00 0:00:02.759048 291589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-24T23:00:08.135733+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-22T23:00:00+00:00 EmrJobFlowSensor 2022-11-23T23:01:09.780142+00:00 2022-11-23T23:13:11.801259+00:00 0:12:02.021117 291006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-23T23:01:07.360749+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-22T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-23T23:00:48.474036+00:00 2022-11-23T23:00:49.240568+00:00 0:00:00.766532 291003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-23T23:00:43.394148+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-22T23:00:00+00:00 PythonOperator 2022-11-23T23:00:25.359427+00:00 2022-11-23T23:00:30.350241+00:00 0:00:04.990814 291000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-23T23:00:21.390776+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-21T23:00:00+00:00 EmrJobFlowSensor 2022-11-22T23:00:59.191917+00:00 2022-11-22T23:12:01.021136+00:00 0:11:01.829219 290404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-22T23:00:56.400633+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-21T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-22T23:00:36.782156+00:00 2022-11-22T23:00:37.606621+00:00 0:00:00.824465 290401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-22T23:00:34.329443+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-21T23:00:00+00:00 PythonOperator 2022-11-22T23:00:16.939514+00:00 2022-11-22T23:00:20.844360+00:00 0:00:03.904846 290398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-22T23:00:14.259810+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-20T23:00:00+00:00 EmrJobFlowSensor 2022-11-21T23:01:02.848608+00:00 2022-11-21T23:12:04.697274+00:00 0:11:01.848666 289818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-21T23:01:00.564889+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-20T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-21T23:00:40.993325+00:00 2022-11-21T23:00:41.858696+00:00 0:00:00.865371 289815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-21T23:00:38.607116+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-20T23:00:00+00:00 PythonOperator 2022-11-21T23:00:19.671701+00:00 2022-11-21T23:00:22.002190+00:00 0:00:02.330489 289812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-21T23:00:16.530086+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-19T23:00:00+00:00 EmrJobFlowSensor 2022-11-20T23:01:05.705812+00:00 2022-11-20T23:11:07.322114+00:00 0:10:01.616302 289213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-20T23:01:03.526759+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-19T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-20T23:00:43.620185+00:00 2022-11-20T23:00:44.350843+00:00 0:00:00.730658 289210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-20T23:00:41.505037+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-19T23:00:00+00:00 PythonOperator 2022-11-20T23:00:24.277439+00:00 2022-11-20T23:00:26.525318+00:00 0:00:02.247879 289207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-20T23:00:21.488629+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-18T23:00:00+00:00 EmrJobFlowSensor 2022-11-19T23:01:07.847114+00:00 2022-11-19T23:12:09.760766+00:00 0:11:01.913652 288606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-19T23:01:05.439155+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-18T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-19T23:00:45.883723+00:00 2022-11-19T23:00:46.717796+00:00 0:00:00.834073 288603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-19T23:00:43.423545+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-18T23:00:00+00:00 PythonOperator 2022-11-19T23:00:23.837250+00:00 2022-11-19T23:00:26.548342+00:00 0:00:02.711092 288600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-19T23:00:21.419849+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-17T23:00:00+00:00 EmrJobFlowSensor 2022-11-18T23:01:20.312337+00:00 2022-11-18T23:13:22.277844+00:00 0:12:01.965507 288007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-18T23:01:18.132411+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-17T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-18T23:01:00.795948+00:00 2022-11-18T23:01:01.567090+00:00 0:00:00.771142 288005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-18T23:00:58.076500+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-17T23:00:00+00:00 PythonOperator 2022-11-18T23:00:38.269975+00:00 2022-11-18T23:00:40.373824+00:00 0:00:02.103849 288001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-18T23:00:36.041604+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-16T23:00:00+00:00 EmrJobFlowSensor 2022-11-17T23:00:58.221324+00:00 2022-11-17T23:13:00.333703+00:00 0:12:02.112379 287419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-17T23:00:55.706374+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-16T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-17T23:00:38.083550+00:00 2022-11-17T23:00:39.125079+00:00 0:00:01.041529 287417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-17T23:00:35.637946+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-16T23:00:00+00:00 PythonOperator 2022-11-17T23:00:16.073051+00:00 2022-11-17T23:00:18.282341+00:00 0:00:02.209290 287414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-17T23:00:13.602522+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-15T23:00:00+00:00 EmrJobFlowSensor 2022-11-16T23:04:47.210582+00:00 2022-11-16T23:15:49.026117+00:00 0:11:01.815535 286840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-16T23:04:44.210949+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-15T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-16T23:04:26.444762+00:00 2022-11-16T23:04:27.842711+00:00 0:00:01.397949 286837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-16T23:04:22.193859+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-15T23:00:00+00:00 PythonOperator 2022-11-16T23:04:06.200116+00:00 2022-11-16T23:04:08.515194+00:00 0:00:02.315078 286834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-16T23:04:02.084057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-14T23:00:00+00:00 EmrJobFlowSensor 2022-11-15T23:00:57.744847+00:00 2022-11-15T23:11:59.693941+00:00 0:11:01.949094 286249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-15T23:00:55.379576+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-14T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-15T23:00:37.524269+00:00 2022-11-15T23:00:38.243210+00:00 0:00:00.718941 286246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-15T23:00:35.362403+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-14T23:00:00+00:00 PythonOperator 2022-11-15T23:00:16.397681+00:00 2022-11-15T23:00:18.648340+00:00 0:00:02.250659 286243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-15T23:00:13.350308+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-13T23:00:00+00:00 EmrJobFlowSensor 2022-11-14T23:00:59.302264+00:00 2022-11-14T23:12:01.105933+00:00 0:11:01.803669 285658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-14T23:00:57.150582+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-13T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-14T23:00:40.100802+00:00 2022-11-14T23:00:40.846524+00:00 0:00:00.745722 285655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-14T23:00:35.144299+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-13T23:00:00+00:00 PythonOperator 2022-11-14T23:00:16.702986+00:00 2022-11-14T23:00:18.886374+00:00 0:00:02.183388 285652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-14T23:00:13.100922+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-12T23:00:00+00:00 EmrJobFlowSensor 2022-11-13T23:00:55.783163+00:00 2022-11-13T23:12:57.833763+00:00 0:12:02.050600 285054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-13T23:00:53.097028+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-12T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-13T23:00:33.592022+00:00 2022-11-13T23:00:34.405927+00:00 0:00:00.813905 285050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-13T23:00:31.011660+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-12T23:00:00+00:00 PythonOperator 2022-11-13T23:00:13.003503+00:00 2022-11-13T23:00:16.225588+00:00 0:00:03.222085 285048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-13T23:00:10.890659+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-11T23:00:00+00:00 EmrJobFlowSensor 2022-11-12T23:01:35.704151+00:00 2022-11-12T23:11:37.651498+00:00 0:10:01.947347 284460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-12T23:01:33.023365+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-11T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-12T23:00:46.724798+00:00 2022-11-12T23:00:47.512306+00:00 0:00:00.787508 284456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-12T23:00:43.806773+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-11T23:00:00+00:00 PythonOperator 2022-11-12T23:00:23.859651+00:00 2022-11-12T23:00:28.522417+00:00 0:00:04.662766 284453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-12T23:00:21.729893+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-10T23:00:00+00:00 EmrJobFlowSensor 2022-11-11T23:00:59.796454+00:00 2022-11-11T23:13:01.834452+00:00 0:12:02.037998 283877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-11T23:00:57.089478+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-10T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-11T23:00:37.274263+00:00 2022-11-11T23:00:38.013503+00:00 0:00:00.739240 283874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-11T23:00:35.048554+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-10T23:00:00+00:00 PythonOperator 2022-11-11T23:00:17.231558+00:00 2022-11-11T23:00:20.430523+00:00 0:00:03.198965 283871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-11T23:00:15.038586+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-09T23:00:00+00:00 EmrJobFlowSensor 2022-11-10T23:01:00.943464+00:00 2022-11-10T23:12:02.832316+00:00 0:11:01.888852 283290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-10T23:00:58.593737+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-09T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-10T23:00:40.849843+00:00 2022-11-10T23:00:41.617865+00:00 0:00:00.768022 283287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-10T23:00:38.518081+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-09T23:00:00+00:00 PythonOperator 2022-11-10T23:00:18.871718+00:00 2022-11-10T23:00:21.062279+00:00 0:00:02.190561 283284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-10T23:00:16.501026+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-08T23:00:00+00:00 EmrJobFlowSensor 2022-11-09T23:00:54.472041+00:00 2022-11-09T23:11:56.383897+00:00 0:11:01.911856 282656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-09T23:00:52.118063+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-08T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-09T23:00:32.278657+00:00 2022-11-09T23:00:33.199013+00:00 0:00:00.920356 282653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-09T23:00:30.075061+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-08T23:00:00+00:00 PythonOperator 2022-11-09T23:00:12.216283+00:00 2022-11-09T23:00:16.994941+00:00 0:00:04.778658 282650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-09T23:00:09.978192+00:00 2 default_pool