Task Instances


  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-19T23:00:00+00:00 EmrJobFlowSensor 2023-07-20T23:00:51.324409+00:00 2023-07-20T23:10:53.038172+00:00 0:10:01.713763 406424 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-20T23:00:49.328214+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-20T23:00:31.209986+00:00 2023-07-20T23:00:32.190651+00:00 0:00:00.980665 406423 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-20T23:00:29.273050+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-19T23:00:00+00:00 PythonOperator 2023-07-20T23:00:09.352136+00:00 2023-07-20T23:00:10.232379+00:00 0:00:00.880243 406422 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-20T23:00:07.253816+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-18T23:00:00+00:00 EmrJobFlowSensor 2023-07-19T23:01:03.624363+00:00 2023-07-19T23:12:05.676326+00:00 0:11:02.051963 406049 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-19T23:01:01.549519+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-19T23:00:41.585757+00:00 2023-07-19T23:00:42.340891+00:00 0:00:00.755134 406048 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-19T23:00:39.537751+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-18T23:00:00+00:00 PythonOperator 2023-07-19T23:00:21.944254+00:00 2023-07-19T23:00:22.937936+00:00 0:00:00.993682 406047 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-19T23:00:19.473083+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-17T23:00:00+00:00 EmrJobFlowSensor 2023-07-18T23:01:28.213122+00:00 2023-07-18T23:11:29.939781+00:00 0:10:01.726659 405679 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-18T23:01:26.336251+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-18T23:01:06.238328+00:00 2023-07-18T23:01:07.050688+00:00 0:00:00.812360 405678 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-18T23:01:04.316682+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-17T23:00:00+00:00 PythonOperator 2023-07-18T23:00:46.586748+00:00 2023-07-18T23:00:47.476044+00:00 0:00:00.889296 405677 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-18T23:00:44.343223+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-16T23:00:00+00:00 EmrJobFlowSensor 2023-07-17T23:00:53.562907+00:00 2023-07-17T23:10:55.273594+00:00 0:10:01.710687 405307 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-17T23:00:51.548858+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-17T23:00:33.447374+00:00 2023-07-17T23:00:34.313832+00:00 0:00:00.866458 405306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-17T23:00:31.504280+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-16T23:00:00+00:00 PythonOperator 2023-07-17T23:00:11.408065+00:00 2023-07-17T23:00:12.397610+00:00 0:00:00.989545 405305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-17T23:00:09.485375+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-15T23:00:00+00:00 EmrJobFlowSensor 2023-07-16T23:01:12.034184+00:00 2023-07-16T23:11:13.832871+00:00 0:10:01.798687 404934 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-16T23:01:09.752515+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-16T23:00:36.435710+00:00 2023-07-16T23:00:37.351744+00:00 0:00:00.916034 404932 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-16T23:00:34.434113+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-15T23:00:00+00:00 PythonOperator 2023-07-16T23:00:14.455012+00:00 2023-07-16T23:00:15.847457+00:00 0:00:01.392445 404930 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-16T23:00:12.351500+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-14T23:00:00+00:00 EmrJobFlowSensor 2023-07-15T23:01:17.563663+00:00 2023-07-15T23:10:19.066612+00:00 0:09:01.502949 404562 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-15T23:01:15.409305+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-15T23:00:38.108797+00:00 2023-07-15T23:00:38.871503+00:00 0:00:00.762706 404560 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-15T23:00:36.044310+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-14T23:00:00+00:00 PythonOperator 2023-07-15T23:00:17.888690+00:00 2023-07-15T23:00:18.834646+00:00 0:00:00.945956 404559 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-15T23:00:15.964642+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-13T23:00:00+00:00 EmrJobFlowSensor 2023-07-14T23:00:47.323562+00:00 2023-07-14T23:11:49.123438+00:00 0:11:01.799876 404189 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-14T23:00:45.345109+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-14T23:00:25.389021+00:00 2023-07-14T23:00:26.311701+00:00 0:00:00.922680 404188 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-14T23:00:23.344571+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-13T23:00:00+00:00 PythonOperator 2023-07-14T23:00:05.557802+00:00 2023-07-14T23:00:06.493668+00:00 0:00:00.935866 404186 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-14T23:00:03.319203+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-12T23:00:00+00:00 EmrJobFlowSensor 2023-07-13T23:00:59.043603+00:00 2023-07-13T23:11:00.725978+00:00 0:10:01.682375 403827 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-13T23:00:57.032215+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-13T23:00:36.931150+00:00 2023-07-13T23:00:37.895464+00:00 0:00:00.964314 403826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-13T23:00:34.954191+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-12T23:00:00+00:00 PythonOperator 2023-07-13T23:00:17.048503+00:00 2023-07-13T23:00:17.974230+00:00 0:00:00.925727 403824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-13T23:00:14.935472+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-11T23:00:00+00:00 EmrJobFlowSensor 2023-07-12T23:00:49.369022+00:00 2023-07-12T23:10:51.102451+00:00 0:10:01.733429 403463 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-12T23:00:47.439349+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-12T23:00:29.324927+00:00 2023-07-12T23:00:30.215065+00:00 0:00:00.890138 403462 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-12T23:00:27.417550+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-11T23:00:00+00:00 PythonOperator 2023-07-12T23:00:07.427868+00:00 2023-07-12T23:00:08.294686+00:00 0:00:00.866818 403460 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-12T23:00:05.397625+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-10T23:00:00+00:00 EmrJobFlowSensor 2023-07-11T23:01:06.543005+00:00 2023-07-11T23:11:08.454005+00:00 0:10:01.911000 403099 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-11T23:01:04.614916+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-11T23:00:46.486129+00:00 2023-07-11T23:00:47.517127+00:00 0:00:01.030998 403098 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-11T23:00:44.593449+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-10T23:00:00+00:00 PythonOperator 2023-07-11T23:00:24.515031+00:00 2023-07-11T23:00:25.442433+00:00 0:00:00.927402 403097 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-11T23:00:22.572170+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-09T23:00:00+00:00 EmrJobFlowSensor 2023-07-10T23:00:55.538318+00:00 2023-07-10T23:10:57.763076+00:00 0:10:02.224758 402728 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-10T23:00:53.619377+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-10T23:00:33.499913+00:00 2023-07-10T23:00:34.275872+00:00 0:00:00.775959 402727 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-10T23:00:31.536617+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-09T23:00:00+00:00 PythonOperator 2023-07-10T23:00:13.524946+00:00 2023-07-10T23:00:14.429016+00:00 0:00:00.904070 402725 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-10T23:00:11.464134+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-08T23:00:00+00:00 EmrJobFlowSensor 2023-07-09T23:01:03.121163+00:00 2023-07-09T23:11:04.918301+00:00 0:10:01.797138 402382 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-09T23:01:01.178269+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-09T23:00:43.013541+00:00 2023-07-09T23:00:44.056253+00:00 0:00:01.042712 402380 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-09T23:00:41.164426+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-08T23:00:00+00:00 PythonOperator 2023-07-09T23:00:03.652230+00:00 2023-07-09T23:00:04.586036+00:00 0:00:00.933806 402376 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-09T23:00:01.570293+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-07T23:00:00+00:00 EmrJobFlowSensor 2023-07-08T23:00:50.372096+00:00 2023-07-08T23:10:52.220358+00:00 0:10:01.848262 402020 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-08T23:00:48.292245+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-08T23:00:30.378403+00:00 2023-07-08T23:00:31.134745+00:00 0:00:00.756342 402018 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-08T23:00:28.273631+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-07T23:00:00+00:00 PythonOperator 2023-07-08T23:00:08.478733+00:00 2023-07-08T23:00:09.411091+00:00 0:00:00.932358 402016 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-08T23:00:06.305277+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-06T23:00:00+00:00 EmrJobFlowSensor 2023-07-07T23:00:55.408912+00:00 2023-07-07T23:10:57.182636+00:00 0:10:01.773724 401665 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-07T23:00:53.535873+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-07T23:00:33.618314+00:00 2023-07-07T23:00:34.447847+00:00 0:00:00.829533 401663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-07T23:00:31.536255+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-06T23:00:00+00:00 PythonOperator 2023-07-07T23:00:13.656915+00:00 2023-07-07T23:00:14.557467+00:00 0:00:00.900552 401661 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-07T23:00:11.475264+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-05T23:00:00+00:00 EmrJobFlowSensor 2023-07-06T23:00:53.287897+00:00 2023-07-06T23:11:55.171206+00:00 0:11:01.883309 401315 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-06T23:00:51.151794+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-06T23:00:33.483610+00:00 2023-07-06T23:00:34.376539+00:00 0:00:00.892929 401313 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-06T23:00:31.110495+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-05T23:00:00+00:00 PythonOperator 2023-07-06T23:00:11.139070+00:00 2023-07-06T23:00:12.039028+00:00 0:00:00.899958 401310 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-06T23:00:09.092088+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-04T23:00:00+00:00 EmrJobFlowSensor 2023-07-05T23:00:53.501679+00:00 2023-07-05T23:11:55.384040+00:00 0:11:01.882361 400961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-05T23:00:51.426743+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-05T23:00:33.203967+00:00 2023-07-05T23:00:34.249742+00:00 0:00:01.045775 400960 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-05T23:00:31.408214+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-04T23:00:00+00:00 PythonOperator 2023-07-05T23:00:11.536083+00:00 2023-07-05T23:00:12.458174+00:00 0:00:00.922091 400959 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-05T23:00:09.387919+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-03T23:00:00+00:00 EmrJobFlowSensor 2023-07-04T23:01:06.096456+00:00 2023-07-04T23:11:07.969800+00:00 0:10:01.873344 400611 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-04T23:01:04.052109+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-04T23:00:43.982509+00:00 2023-07-04T23:00:45.026997+00:00 0:00:01.044488 400610 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-04T23:00:42.038792+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-03T23:00:00+00:00 PythonOperator 2023-07-04T23:00:22.274715+00:00 2023-07-04T23:00:23.190334+00:00 0:00:00.915619 400609 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-04T23:00:20.037837+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-02T23:00:00+00:00 EmrJobFlowSensor 2023-07-03T23:00:49.919886+00:00 2023-07-03T23:10:51.705101+00:00 0:10:01.785215 400254 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-03T23:00:47.871025+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-03T23:00:27.749207+00:00 2023-07-03T23:00:28.742505+00:00 0:00:00.993298 400252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-03T23:00:25.849379+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-02T23:00:00+00:00 PythonOperator 2023-07-03T23:00:07.881153+00:00 2023-07-03T23:00:08.846092+00:00 0:00:00.964939 400250 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-03T23:00:05.834800+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-07-01T23:00:00+00:00 EmrJobFlowSensor 2023-07-02T23:01:03.866991+00:00 2023-07-02T23:11:05.925649+00:00 0:10:02.058658 399898 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-02T23:01:01.644848+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-07-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-02T23:00:41.627103+00:00 2023-07-02T23:00:42.731550+00:00 0:00:01.104447 399896 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-02T23:00:39.643706+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-07-01T23:00:00+00:00 PythonOperator 2023-07-02T23:00:21.816402+00:00 2023-07-02T23:00:22.894020+00:00 0:00:01.077618 399894 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-02T23:00:19.565025+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-30T23:00:00+00:00 EmrJobFlowSensor 2023-07-01T23:00:57.652462+00:00 2023-07-01T23:10:59.535763+00:00 0:10:01.883301 399532 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-07-01T23:00:55.322389+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-07-01T23:00:37.285104+00:00 2023-07-01T23:00:38.436780+00:00 0:00:01.151676 399530 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-07-01T23:00:35.248494+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-30T23:00:00+00:00 PythonOperator 2023-07-01T23:00:15.197066+00:00 2023-07-01T23:00:16.196591+00:00 0:00:00.999525 399528 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-07-01T23:00:13.238104+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-29T23:00:00+00:00 EmrJobFlowSensor 2023-06-30T23:01:01.509733+00:00 2023-06-30T23:11:03.322105+00:00 0:10:01.812372 399171 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-30T23:00:59.529248+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-30T23:00:41.675817+00:00 2023-06-30T23:00:42.800825+00:00 0:00:01.125008 399169 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-30T23:00:39.461986+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-29T23:00:00+00:00 PythonOperator 2023-06-30T23:00:19.699766+00:00 2023-06-30T23:00:20.767254+00:00 0:00:01.067488 399167 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-30T23:00:17.438703+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-28T23:00:00+00:00 EmrJobFlowSensor 2023-06-29T23:01:03.798977+00:00 2023-06-29T23:11:05.667681+00:00 0:10:01.868704 398807 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-29T23:01:01.611316+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-29T23:00:43.504077+00:00 2023-06-29T23:00:44.460149+00:00 0:00:00.956072 398805 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-29T23:00:41.594020+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-28T23:00:00+00:00 PythonOperator 2023-06-29T23:00:19.495626+00:00 2023-06-29T23:00:20.464878+00:00 0:00:00.969252 398803 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-29T23:00:17.569107+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-27T23:00:00+00:00 EmrJobFlowSensor 2023-06-28T23:00:57.740298+00:00 2023-06-28T23:10:59.334968+00:00 0:10:01.594670 398441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-28T23:00:55.817998+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-28T23:00:35.772622+00:00 2023-06-28T23:00:36.744864+00:00 0:00:00.972242 398439 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-28T23:00:33.797936+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-27T23:00:00+00:00 PythonOperator 2023-06-28T23:00:16.370472+00:00 2023-06-28T23:00:17.427065+00:00 0:00:01.056593 398437 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-28T23:00:13.836474+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-26T23:00:00+00:00 EmrJobFlowSensor 2023-06-27T23:01:17.598483+00:00 2023-06-27T23:11:19.657269+00:00 0:10:02.058786 398079 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-27T23:01:15.618595+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-27T23:00:45.971942+00:00 2023-06-27T23:00:46.951262+00:00 0:00:00.979320 398076 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-27T23:00:43.536153+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-26T23:00:00+00:00 PythonOperator 2023-06-27T23:00:23.473050+00:00 2023-06-27T23:00:24.888295+00:00 0:00:01.415245 398074 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-27T23:00:21.531086+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-25T23:00:00+00:00 EmrJobFlowSensor 2023-06-26T23:00:49.548998+00:00 2023-06-26T23:10:51.354056+00:00 0:10:01.805058 397719 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-26T23:00:47.331115+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-26T23:00:29.531929+00:00 2023-06-26T23:00:30.611444+00:00 0:00:01.079515 397718 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-26T23:00:27.312752+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-25T23:00:00+00:00 PythonOperator 2023-06-26T23:00:07.400096+00:00 2023-06-26T23:00:08.342902+00:00 0:00:00.942806 397716 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-26T23:00:05.335730+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-24T23:00:00+00:00 EmrJobFlowSensor 2023-06-25T23:00:53.532317+00:00 2023-06-25T23:10:55.210505+00:00 0:10:01.678188 397368 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-25T23:00:51.539513+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-25T23:00:32.204518+00:00 2023-06-25T23:00:33.099993+00:00 0:00:00.895475 397366 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-25T23:00:29.520466+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-24T23:00:00+00:00 PythonOperator 2023-06-25T23:00:11.452282+00:00 2023-06-25T23:00:12.415399+00:00 0:00:00.963117 397364 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-25T23:00:09.447728+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-23T23:00:00+00:00 EmrJobFlowSensor 2023-06-24T23:01:32.420038+00:00 2023-06-24T23:11:34.170037+00:00 0:10:01.749999 397010 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-24T23:01:30.214784+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-24T23:01:10.434004+00:00 2023-06-24T23:01:11.520627+00:00 0:00:01.086623 397008 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-24T23:01:08.192551+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-23T23:00:00+00:00 PythonOperator 2023-06-24T23:00:48.109502+00:00 2023-06-24T23:00:49.122031+00:00 0:00:01.012529 397006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-24T23:00:46.172821+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-22T23:00:00+00:00 EmrJobFlowSensor 2023-06-23T23:00:56.911240+00:00 2023-06-23T23:10:58.774796+00:00 0:10:01.863556 396647 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-23T23:00:54.539798+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-23T23:00:34.749452+00:00 2023-06-23T23:00:35.778262+00:00 0:00:01.028810 396645 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-23T23:00:32.529552+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-22T23:00:00+00:00 PythonOperator 2023-06-23T23:00:12.742910+00:00 2023-06-23T23:00:13.810846+00:00 0:00:01.067936 396643 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-23T23:00:10.459811+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-21T23:00:00+00:00 EmrJobFlowSensor 2023-06-22T23:00:56.170406+00:00 2023-06-22T23:11:58.222266+00:00 0:11:02.051860 396286 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-22T23:00:53.869772+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-22T23:00:34.101977+00:00 2023-06-22T23:00:35.089291+00:00 0:00:00.987314 396284 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-22T23:00:31.845863+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-21T23:00:00+00:00 PythonOperator 2023-06-22T23:00:14.023284+00:00 2023-06-22T23:00:14.964518+00:00 0:00:00.941234 396282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-22T23:00:11.830346+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-22T06:28:18.414770+00:00 EmrJobFlowSensor 2023-06-22T10:23:09.100935+00:00 2023-06-22T10:35:11.055396+00:00 0:12:01.954461 396099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-22T10:23:07.245120+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-22T06:28:18.414770+00:00 EmrCreateJobFlowOperator 2023-06-22T10:22:49.421741+00:00 2023-06-22T10:22:50.550535+00:00 0:00:01.128794 396098 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-22T10:22:47.227093+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-22T06:28:18.414770+00:00 PythonOperator 2023-06-22T10:22:27.381573+00:00 2023-06-22T10:22:28.414282+00:00 0:00:01.032709 396097 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-22T10:22:25.208430+00:00 15 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-20T23:00:00+00:00 PythonOperator 2023-06-22T06:25:21.396227+00:00 2023-06-22T06:25:21.865052+00:00 0:00:00.468825 396006 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-22T06:25:18.771961+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-20T23:00:00+00:00 EmrJobFlowSensor 2023-06-21T23:01:06.582306+00:00 2023-06-21T23:12:08.424696+00:00 0:11:01.842390 395831 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-21T23:01:04.632852+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-21T23:00:44.415933+00:00 2023-06-21T23:00:45.326936+00:00 0:00:00.911003 395828 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-21T23:00:42.560382+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-19T23:00:00+00:00 EmrJobFlowSensor 2023-06-20T23:00:57.078428+00:00 2023-06-20T23:10:58.787504+00:00 0:10:01.709076 395276 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T23:00:54.973370+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T23:00:37.103532+00:00 2023-06-20T23:00:37.991118+00:00 0:00:00.887586 395273 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-20T23:00:34.953979+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-19T23:00:00+00:00 PythonOperator 2023-06-20T23:00:15.122834+00:00 2023-06-20T23:00:16.118496+00:00 0:00:00.995662 395270 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T23:00:12.950278+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-18T23:00:00+00:00 EmrJobFlowSensor 2023-06-19T23:00:51.210852+00:00 2023-06-19T23:10:52.839426+00:00 0:10:01.628574 394679 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T23:00:49.334142+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-06-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T23:00:29.498460+00:00 2023-06-19T23:00:30.406745+00:00 0:00:00.908285 394677 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-06-19T23:00:27.314994+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-06-18T23:00:00+00:00 PythonOperator 2023-06-19T23:00:09.419009+00:00 2023-06-19T23:00:10.318717+00:00 0:00:00.899708 394673 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T23:00:07.295384+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-06-17T23:00:00+00:00 EmrJobFlowSensor 2023-06-18T23:01:03.445362+00:00 2023-06-18T23:12:05.383987+00:00 0:11:01.938625 394182 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-18T23:01:01.585356+00:00 2 default_pool