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 04-20T23:00:00+00:00 PythonOperator 04-21T23:00:25.160615+00:00 04-21T23:00:27.508685+00:00 0:00:02.348070 517644 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-21T23:00:21.237723+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-19T23:00:00+00:00 EmrJobFlowSensor 04-20T23:13:21.785906+00:00 04-20T23:13:22.339292+00:00 0:00:00.553386 517166 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-20T23:13:19.350875+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-19T23:00:00+00:00 EmrCreateJobFlowOperator 04-20T23:00:41.745822+00:00 04-20T23:00:42.613060+00:00 0:00:00.867238 517154 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-20T23:00:39.287890+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-19T23:00:00+00:00 PythonOperator 04-20T23:00:19.716803+00:00 04-20T23:00:20.888202+00:00 0:00:01.171399 517150 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-20T23:00:17.276563+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-18T23:00:00+00:00 EmrJobFlowSensor 04-19T23:00:51.195592+00:00 04-19T23:11:53.195886+00:00 0:11:02.000294 516673 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-19T23:00:48.888077+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-18T23:00:00+00:00 EmrCreateJobFlowOperator 04-19T23:00:33.980968+00:00 04-19T23:00:34.817404+00:00 0:00:00.836436 516671 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-19T23:00:28.873942+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-18T23:00:00+00:00 PythonOperator 04-19T23:00:07.115395+00:00 04-19T23:00:08.273710+00:00 0:00:01.158315 516666 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-19T23:00:04.818288+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-17T23:00:00+00:00 EmrJobFlowSensor 04-18T23:14:57.614651+00:00 04-18T23:14:58.142346+00:00 0:00:00.527695 516181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-18T23:14:55.448117+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-17T23:00:00+00:00 EmrCreateJobFlowOperator 04-18T23:00:25.108196+00:00 04-18T23:00:26.094125+00:00 0:00:00.985929 516168 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-18T23:00:22.856814+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-17T23:00:00+00:00 PythonOperator 04-18T23:00:05.397063+00:00 04-18T23:00:06.561443+00:00 0:00:01.164380 516164 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-18T23:00:02.780766+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-16T23:00:00+00:00 EmrJobFlowSensor 04-17T23:00:56.030110+00:00 04-17T23:11:58.068818+00:00 0:11:02.038708 515657 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-17T23:00:53.733086+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-16T23:00:00+00:00 EmrCreateJobFlowOperator 04-17T23:00:33.934037+00:00 04-17T23:00:34.834948+00:00 0:00:00.900911 515654 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-17T23:00:31.713352+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-16T23:00:00+00:00 PythonOperator 04-17T23:00:10.369853+00:00 04-17T23:00:11.709512+00:00 0:00:01.339659 515651 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-17T23:00:07.760102+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-15T23:00:00+00:00 EmrJobFlowSensor 04-16T23:00:57.821467+00:00 04-16T23:10:59.478341+00:00 0:10:01.656874 515172 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-16T23:00:56.029069+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-15T23:00:00+00:00 EmrCreateJobFlowOperator 04-16T23:00:35.774768+00:00 04-16T23:00:36.492855+00:00 0:00:00.718087 515170 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-16T23:00:33.962171+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-15T23:00:00+00:00 PythonOperator 04-16T23:00:14.374901+00:00 04-16T23:00:15.475631+00:00 0:00:01.100730 515167 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-16T23:00:11.926651+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-14T23:00:00+00:00 EmrJobFlowSensor 04-16T10:14:21.201928+00:00 04-16T10:24:23.132413+00:00 0:10:01.930485 514778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-16T10:14:18.628616+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-14T23:00:00+00:00 EmrCreateJobFlowOperator 04-16T10:14:12.594673+00:00 04-16T10:14:14.185016+00:00 0:00:01.590343 514772 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-16T10:13:33.856310+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-14T23:00:00+00:00 PythonOperator 04-16T10:13:17.022852+00:00 04-16T10:13:26.855826+00:00 0:00:09.832974 514740 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-16T10:12:25.696061+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-13T23:00:00+00:00 EmrJobFlowSensor 04-14T23:13:03.695089+00:00 04-14T23:13:04.159520+00:00 0:00:00.464431 514177 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-14T23:13:01.911369+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-13T23:00:00+00:00 EmrCreateJobFlowOperator 04-14T23:00:38.172842+00:00 04-14T23:00:38.884666+00:00 0:00:00.711824 514167 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-14T23:00:36.078866+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-13T23:00:00+00:00 PythonOperator 04-14T23:00:18.163168+00:00 04-14T23:00:19.419640+00:00 0:00:01.256472 514164 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-14T23:00:16.067490+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-12T23:00:00+00:00 EmrJobFlowSensor 04-13T23:00:49.068191+00:00 04-13T23:10:50.906485+00:00 0:10:01.838294 513693 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-13T23:00:46.811362+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-12T23:00:00+00:00 EmrCreateJobFlowOperator 04-13T23:00:27.844417+00:00 04-13T23:00:28.574803+00:00 0:00:00.730386 513690 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-13T23:00:24.767466+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-12T23:00:00+00:00 PythonOperator 04-13T23:00:06.438543+00:00 04-13T23:00:07.394781+00:00 0:00:00.956238 513686 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-13T23:00:04.725089+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-11T23:00:00+00:00 EmrJobFlowSensor 04-12T23:01:02.032805+00:00 04-12T23:12:04.001445+00:00 0:11:01.968640 513206 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-12T23:01:00.251473+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-11T23:00:00+00:00 EmrCreateJobFlowOperator 04-12T23:00:40.375345+00:00 04-12T23:00:41.416234+00:00 0:00:01.040889 513204 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-12T23:00:38.223604+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-11T23:00:00+00:00 PythonOperator 04-12T23:00:17.916035+00:00 04-12T23:00:18.859535+00:00 0:00:00.943500 513200 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-12T23:00:16.191452+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-10T23:00:00+00:00 EmrJobFlowSensor 04-11T23:00:56.976010+00:00 04-11T23:10:58.801183+00:00 0:10:01.825173 512715 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-11T23:00:54.918958+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-10T23:00:00+00:00 EmrCreateJobFlowOperator 04-11T23:00:37.141358+00:00 04-11T23:00:37.957031+00:00 0:00:00.815673 512713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-11T23:00:34.904096+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-10T23:00:00+00:00 PythonOperator 04-11T23:00:15.185850+00:00 04-11T23:00:16.410412+00:00 0:00:01.224562 512711 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-11T23:00:12.937295+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-08T23:00:00+00:00 EmrJobFlowSensor 04-09T23:01:30.184611+00:00 04-09T23:11:31.859515+00:00 0:10:01.674904 511289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-09T23:01:28.153257+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-08T23:00:00+00:00 EmrCreateJobFlowOperator 04-09T23:01:04.011813+00:00 04-09T23:01:04.825241+00:00 0:00:00.813428 511286 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-09T23:01:02.133105+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-08T23:00:00+00:00 PythonOperator 04-09T23:00:42.565343+00:00 04-09T23:00:43.594367+00:00 0:00:01.029024 511283 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-09T23:00:40.114111+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-07T23:00:00+00:00 EmrJobFlowSensor 04-08T23:00:53.573662+00:00 04-08T23:10:55.239900+00:00 0:10:01.666238 510827 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-08T23:00:51.603588+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-07T23:00:00+00:00 EmrCreateJobFlowOperator 04-08T23:00:29.385401+00:00 04-08T23:00:30.230596+00:00 0:00:00.845195 510824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-08T23:00:27.507698+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-07T23:00:00+00:00 PythonOperator 04-08T23:00:07.547287+00:00 04-08T23:00:08.570615+00:00 0:00:01.023328 510820 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-08T23:00:05.488801+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-06T23:00:00+00:00 EmrJobFlowSensor 04-07T23:00:58.027533+00:00 04-07T23:10:59.887929+00:00 0:10:01.860396 510351 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-07T23:00:56.131699+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-06T23:00:00+00:00 EmrCreateJobFlowOperator 04-07T23:00:36.513662+00:00 04-07T23:00:37.355645+00:00 0:00:00.841983 510348 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-07T23:00:34.115026+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-06T23:00:00+00:00 PythonOperator 04-07T23:00:18.159260+00:00 04-07T23:00:19.161436+00:00 0:00:01.002176 510346 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-07T23:00:16.148229+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-05T23:00:00+00:00 EmrJobFlowSensor 04-06T23:01:09.228579+00:00 04-06T23:11:11.099211+00:00 0:10:01.870632 510008 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-06T23:01:06.756775+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-05T23:00:00+00:00 EmrCreateJobFlowOperator 04-06T23:00:42.496388+00:00 04-06T23:00:43.300097+00:00 0:00:00.803709 510005 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-06T23:00:40.457506+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-05T23:00:00+00:00 PythonOperator 04-06T23:00:20.404785+00:00 04-06T23:00:21.483517+00:00 0:00:01.078732 510002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-06T23:00:18.418615+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-04T23:00:00+00:00 EmrJobFlowSensor 04-05T23:00:48.816660+00:00 04-05T23:10:50.708846+00:00 0:10:01.892186 509517 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-05T23:00:46.744553+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-04T23:00:00+00:00 EmrCreateJobFlowOperator 04-05T23:00:26.810000+00:00 04-05T23:00:27.666354+00:00 0:00:00.856354 509514 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-05T23:00:24.731344+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-04T23:00:00+00:00 PythonOperator 04-05T23:00:06.908831+00:00 04-05T23:00:07.960812+00:00 0:00:01.051981 509510 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-05T23:00:04.702466+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-03T23:00:00+00:00 EmrJobFlowSensor 04-04T23:12:45.610738+00:00 04-04T23:12:46.142143+00:00 0:00:00.531405 509032 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-04T23:12:43.645683+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-03T23:00:00+00:00 EmrCreateJobFlowOperator 04-04T23:00:28.021631+00:00 04-04T23:00:28.719973+00:00 0:00:00.698342 509019 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-04T23:00:25.811484+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-03T23:00:00+00:00 PythonOperator 04-04T23:00:08.253613+00:00 04-04T23:00:09.299439+00:00 0:00:01.045826 509016 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-04T23:00:05.786788+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-02T23:00:00+00:00 EmrJobFlowSensor 04-03T23:01:03.030819+00:00 04-03T23:12:04.968822+00:00 0:11:01.938003 508616 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-03T23:01:01.424343+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-02T23:00:00+00:00 EmrCreateJobFlowOperator 04-03T23:00:44.482942+00:00 04-03T23:00:45.481691+00:00 0:00:00.998749 508614 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-03T23:00:41.402058+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-02T23:00:00+00:00 PythonOperator 04-03T23:00:21.048362+00:00 04-03T23:00:22.174909+00:00 0:00:01.126547 508610 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-03T23:00:19.382025+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-01T23:00:00+00:00 EmrJobFlowSensor 04-02T23:00:58.042617+00:00 04-02T23:12:00.000734+00:00 0:11:01.958117 508298 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T23:00:56.102521+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-01T23:00:00+00:00 EmrCreateJobFlowOperator 04-02T23:00:36.795238+00:00 04-02T23:00:37.503282+00:00 0:00:00.708044 508295 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T23:00:34.084108+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-01T23:00:00+00:00 PythonOperator 04-02T23:00:15.785397+00:00 04-02T23:00:17.640123+00:00 0:00:01.854726 508291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T23:00:14.070180+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-31T23:00:00+00:00 EmrJobFlowSensor 04-01T23:12:37.568762+00:00 04-01T23:12:38.263677+00:00 0:00:00.694915 507972 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T23:12:34.347503+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-31T23:00:00+00:00 EmrCreateJobFlowOperator 04-01T23:00:29.613595+00:00 04-01T23:00:30.369927+00:00 0:00:00.756332 507961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T23:00:27.710764+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-31T23:00:00+00:00 PythonOperator 04-01T23:00:09.004996+00:00 04-01T23:00:10.742546+00:00 0:00:01.737550 507957 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T23:00:05.691460+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-30T23:00:00+00:00 EmrJobFlowSensor 03-31T23:12:33.922901+00:00 03-31T23:12:34.352233+00:00 0:00:00.429332 507628 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-31T23:12:31.933075+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-30T23:00:00+00:00 EmrCreateJobFlowOperator 03-31T23:00:30.304815+00:00 03-31T23:00:31.073658+00:00 0:00:00.768843 507618 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-31T23:00:27.306456+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-30T23:00:00+00:00 PythonOperator 03-31T23:00:09.232484+00:00 03-31T23:00:10.377934+00:00 0:00:01.145450 507614 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-31T23:00:07.291570+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-29T23:00:00+00:00 EmrJobFlowSensor 03-30T23:12:20.832768+00:00 03-30T23:12:21.557482+00:00 0:00:00.724714 507289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-30T23:12:17.507036+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-29T23:00:00+00:00 EmrCreateJobFlowOperator 03-30T23:00:30.043741+00:00 03-30T23:00:30.908818+00:00 0:00:00.865077 507279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-30T23:00:26.891887+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-29T23:00:00+00:00 PythonOperator 03-30T23:00:08.563526+00:00 03-30T23:00:10.824320+00:00 0:00:02.260794 507276 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-30T23:00:04.872995+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-28T23:00:00+00:00 EmrJobFlowSensor 03-29T23:00:51.765356+00:00 03-29T23:10:53.473942+00:00 0:10:01.708586 506946 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-29T23:00:49.861223+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-28T23:00:00+00:00 EmrCreateJobFlowOperator 03-29T23:00:29.820371+00:00 03-29T23:00:30.875456+00:00 0:00:01.055085 506942 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-29T23:00:27.841565+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-28T23:00:00+00:00 PythonOperator 03-29T23:00:07.902131+00:00 03-29T23:00:09.834312+00:00 0:00:01.932181 506938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-29T23:00:05.824181+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-27T23:00:00+00:00 EmrJobFlowSensor 03-28T23:01:05.459905+00:00 03-28T23:12:07.315621+00:00 0:11:01.855716 506615 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-28T23:01:03.618969+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-27T23:00:00+00:00 EmrCreateJobFlowOperator 03-28T23:00:43.868943+00:00 03-28T23:00:44.577648+00:00 0:00:00.708705 506612 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-28T23:00:41.613168+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-27T23:00:00+00:00 PythonOperator 03-28T23:00:22.466230+00:00 03-28T23:00:23.601027+00:00 0:00:01.134797 506609 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-28T23:00:19.584189+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-26T23:00:00+00:00 EmrJobFlowSensor 03-27T23:12:57.211275+00:00 03-27T23:12:57.634414+00:00 0:00:00.423139 506287 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-27T23:12:55.261971+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-26T23:00:00+00:00 EmrCreateJobFlowOperator 03-27T23:00:38.296802+00:00 03-27T23:00:39.346017+00:00 0:00:01.049215 506277 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-27T23:00:34.610482+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-26T23:00:00+00:00 PythonOperator 03-27T23:00:17.177053+00:00 03-27T23:00:19.523665+00:00 0:00:02.346612 506273 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-27T23:00:12.593382+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-25T23:00:00+00:00 EmrJobFlowSensor 03-26T23:00:50.715355+00:00 03-26T23:11:52.657831+00:00 0:11:01.942476 505946 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-26T23:00:48.749808+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-25T23:00:00+00:00 EmrCreateJobFlowOperator 03-26T23:00:30.423074+00:00 03-26T23:00:31.458574+00:00 0:00:01.035500 505943 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-26T23:00:26.733266+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-25T23:00:00+00:00 PythonOperator 03-26T23:00:09.113592+00:00 03-26T23:00:10.178961+00:00 0:00:01.065369 505940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-26T23:00:06.714004+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-24T23:00:00+00:00 EmrJobFlowSensor 03-25T23:00:53.000787+00:00 03-25T23:11:54.789097+00:00 0:11:01.788310 505636 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-25T23:00:51.056668+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-24T23:00:00+00:00 EmrCreateJobFlowOperator 03-25T23:00:34.262535+00:00 03-25T23:00:35.285528+00:00 0:00:01.022993 505634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-25T23:00:31.029953+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-24T23:00:00+00:00 PythonOperator 03-25T23:00:11.309924+00:00 03-25T23:00:12.480645+00:00 0:00:01.170721 505631 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-25T23:00:09.008968+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-23T23:00:00+00:00 EmrJobFlowSensor 03-24T23:01:03.137480+00:00 03-24T23:11:04.890616+00:00 0:10:01.753136 505393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-24T23:01:01.170444+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-23T23:00:00+00:00 EmrCreateJobFlowOperator 03-24T23:00:41.099984+00:00 03-24T23:00:41.788543+00:00 0:00:00.688559 505391 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-24T23:00:39.150288+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-23T23:00:00+00:00 PythonOperator 03-24T23:00:19.120795+00:00 03-24T23:00:20.301548+00:00 0:00:01.180753 505389 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-24T23:00:17.130894+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-22T23:00:00+00:00 EmrJobFlowSensor 03-23T23:12:22.482292+00:00 03-23T23:12:22.913770+00:00 0:00:00.431478 505107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-23T23:12:20.543026+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-22T23:00:00+00:00 EmrCreateJobFlowOperator 03-23T23:00:40.838265+00:00 03-23T23:00:41.571305+00:00 0:00:00.733040 505097 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-23T23:00:38.847772+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-22T23:00:00+00:00 PythonOperator 03-23T23:00:18.816879+00:00 03-23T23:00:19.873762+00:00 0:00:01.056883 505093 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-23T23:00:16.829260+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-21T23:00:00+00:00 EmrJobFlowSensor 03-22T23:01:05.853376+00:00 03-22T23:11:07.938783+00:00 0:10:02.085407 504761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-22T23:01:02.685701+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-21T23:00:00+00:00 EmrCreateJobFlowOperator 03-22T23:00:43.854771+00:00 03-22T23:00:44.835280+00:00 0:00:00.980509 504757 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-22T23:00:40.661712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-21T23:00:00+00:00 PythonOperator 03-22T23:00:23.769131+00:00 03-22T23:00:25.417637+00:00 0:00:01.648506 504755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-22T23:00:20.647638+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-20T23:00:00+00:00 EmrJobFlowSensor 03-21T23:01:02.256022+00:00 03-21T23:11:03.982295+00:00 0:10:01.726273 504434 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-21T23:01:00.219591+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-20T23:00:00+00:00 EmrCreateJobFlowOperator 03-21T23:00:41.460479+00:00 03-21T23:00:42.474933+00:00 0:00:01.014454 504431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-21T23:00:38.200171+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-20T23:00:00+00:00 PythonOperator 03-21T23:00:18.090004+00:00 03-21T23:00:19.131137+00:00 0:00:01.041133 504428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-21T23:00:16.183087+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-19T23:00:00+00:00 EmrJobFlowSensor 03-20T23:01:06.499707+00:00 03-20T23:12:08.297344+00:00 0:11:01.797637 504101 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-20T23:01:04.610093+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-19T23:00:00+00:00 EmrCreateJobFlowOperator 03-20T23:00:42.527842+00:00 03-20T23:00:43.200868+00:00 0:00:00.673026 504098 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-20T23:00:40.584722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-19T23:00:00+00:00 PythonOperator 03-20T23:00:22.508922+00:00 03-20T23:00:23.567793+00:00 0:00:01.058871 504095 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-20T23:00:20.574090+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-18T23:00:00+00:00 EmrJobFlowSensor 03-19T23:01:22.769115+00:00 03-19T23:12:24.728897+00:00 0:11:01.959782 503767 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-19T23:01:20.858879+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-18T23:00:00+00:00 EmrCreateJobFlowOperator 03-19T23:00:41.586348+00:00 03-19T23:00:42.468965+00:00 0:00:00.882617 503761 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-19T23:00:39.648209+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-18T23:00:00+00:00 PythonOperator 03-19T23:00:19.659170+00:00 03-19T23:00:20.789114+00:00 0:00:01.129944 503757 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-19T23:00:17.631367+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-17T23:00:00+00:00 EmrJobFlowSensor 03-18T23:00:59.304696+00:00 03-18T23:12:01.168570+00:00 0:11:01.863874 503437 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-18T23:00:57.324215+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-17T23:00:00+00:00 EmrCreateJobFlowOperator 03-18T23:00:39.165506+00:00 03-18T23:00:39.890279+00:00 0:00:00.724773 503434 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-18T23:00:37.306214+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-17T23:00:00+00:00 PythonOperator 03-18T23:00:17.210722+00:00 03-18T23:00:18.382976+00:00 0:00:01.172254 503431 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-18T23:00:15.286429+00:00 2 default_pool