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 07-29T23:00:00+00:00 PythonOperator 07-30T23:00:13.594564+00:00 07-30T23:00:14.861199+00:00 0:00:01.266635 580869 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-30T23:00:10.534362+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-28T23:00:00+00:00 EmrJobFlowSensor 07-29T23:13:14.967998+00:00 07-29T23:13:15.387039+00:00 0:00:00.419041 580413 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-29T23:13:13.197556+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-28T23:00:00+00:00 EmrCreateJobFlowOperator 07-29T23:00:33.862021+00:00 07-29T23:00:34.848005+00:00 0:00:00.985984 580402 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-29T23:00:31.275020+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-28T23:00:00+00:00 PythonOperator 07-29T23:00:10.796591+00:00 07-29T23:00:11.665755+00:00 0:00:00.869164 580399 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-29T23:00:09.256849+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-27T23:00:00+00:00 EmrJobFlowSensor 07-28T23:12:35.913945+00:00 07-28T23:12:36.706250+00:00 0:00:00.792305 579953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-28T23:12:33.275618+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-27T23:00:00+00:00 EmrCreateJobFlowOperator 07-28T23:00:38.336944+00:00 07-28T23:00:39.106844+00:00 0:00:00.769900 579943 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-28T23:00:36.708923+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-27T23:00:00+00:00 PythonOperator 07-28T23:00:17.479689+00:00 07-28T23:00:18.727548+00:00 0:00:01.247859 579940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-28T23:00:14.702484+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-26T23:00:00+00:00 EmrJobFlowSensor 07-27T23:07:29.954618+00:00 07-27T23:09:30.862308+00:00 0:02:00.907690 579494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-27T23:07:27.332785+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-26T23:00:00+00:00 EmrCreateJobFlowOperator 07-27T23:00:45.399440+00:00 07-27T23:00:46.278658+00:00 0:00:00.879218 579484 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-27T23:00:42.731227+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-26T23:00:00+00:00 PythonOperator 07-27T23:00:23.386444+00:00 07-27T23:00:24.601531+00:00 0:00:01.215087 579481 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-27T23:00:20.715764+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-25T23:00:00+00:00 EmrJobFlowSensor 07-26T23:01:02.235624+00:00 07-26T23:09:04.027392+00:00 0:08:01.791768 579018 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-26T23:00:59.452649+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-25T23:00:00+00:00 EmrCreateJobFlowOperator 07-26T23:00:40.104083+00:00 07-26T23:00:41.007250+00:00 0:00:00.903167 579015 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-26T23:00:37.431895+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-25T23:00:00+00:00 PythonOperator 07-26T23:00:18.098646+00:00 07-26T23:00:19.310682+00:00 0:00:01.212036 579012 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-26T23:00:15.414070+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-24T23:00:00+00:00 EmrJobFlowSensor 07-25T23:01:01.768571+00:00 07-25T23:09:03.439605+00:00 0:08:01.671034 578553 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-25T23:00:59.194024+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-24T23:00:00+00:00 EmrCreateJobFlowOperator 07-25T23:00:39.788471+00:00 07-25T23:00:40.691654+00:00 0:00:00.903183 578550 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-25T23:00:37.183482+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-24T23:00:00+00:00 PythonOperator 07-25T23:00:17.806340+00:00 07-25T23:00:19.025761+00:00 0:00:01.219421 578547 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-25T23:00:15.111760+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-23T23:00:00+00:00 EmrJobFlowSensor 07-24T23:12:52.128495+00:00 07-24T23:12:52.724876+00:00 0:00:00.596381 578087 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-24T23:12:49.271891+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-23T23:00:00+00:00 EmrCreateJobFlowOperator 07-24T23:00:59.680877+00:00 07-24T23:01:00.581399+00:00 0:00:00.900522 578076 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-24T23:00:57.089363+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-23T23:00:00+00:00 PythonOperator 07-24T23:00:27.397249+00:00 07-24T23:00:28.200900+00:00 0:00:00.803651 578071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-24T23:00:25.813431+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-22T23:00:00+00:00 EmrJobFlowSensor 07-23T23:00:48.107866+00:00 07-23T23:08:49.757769+00:00 0:08:01.649903 577610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-23T23:00:45.350693+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-22T23:00:00+00:00 EmrCreateJobFlowOperator 07-23T23:00:26.901118+00:00 07-23T23:00:28.101668+00:00 0:00:01.200550 577606 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-23T23:00:23.266911+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-22T23:00:00+00:00 PythonOperator 07-23T23:00:05.923804+00:00 07-23T23:00:07.123981+00:00 0:00:01.200177 577603 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-23T23:00:03.247077+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-21T23:00:00+00:00 EmrJobFlowSensor 07-22T23:00:53.475338+00:00 07-22T23:08:55.034882+00:00 0:08:01.559544 577166 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-22T23:00:51.632392+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-21T23:00:00+00:00 EmrCreateJobFlowOperator 07-22T23:00:33.495100+00:00 07-22T23:00:34.420108+00:00 0:00:00.925008 577163 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-22T23:00:31.680256+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-21T23:00:00+00:00 PythonOperator 07-22T23:00:09.610205+00:00 07-22T23:00:10.621461+00:00 0:00:01.011256 577159 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-22T23:00:07.655008+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-20T23:00:00+00:00 EmrJobFlowSensor 07-21T23:00:56.877126+00:00 07-21T23:06:58.131385+00:00 0:06:01.254259 576664 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-21T23:00:55.215311+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-20T23:00:00+00:00 EmrCreateJobFlowOperator 07-21T23:00:35.603869+00:00 07-21T23:00:36.792917+00:00 0:00:01.189048 576661 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-21T23:00:33.206749+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-20T23:00:00+00:00 PythonOperator 07-21T23:00:13.248726+00:00 07-21T23:00:14.194676+00:00 0:00:00.945950 576657 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-21T23:00:11.176877+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-19T23:00:00+00:00 EmrJobFlowSensor 07-20T23:01:26.828819+00:00 07-20T23:07:28.047581+00:00 0:06:01.218762 576164 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-20T23:01:25.310626+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-19T23:00:00+00:00 EmrCreateJobFlowOperator 07-20T23:01:04.883572+00:00 07-20T23:01:05.665429+00:00 0:00:00.781857 576161 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-20T23:01:03.291121+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-19T23:00:00+00:00 PythonOperator 07-20T23:00:17.501977+00:00 07-20T23:00:18.407403+00:00 0:00:00.905426 576154 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-20T23:00:15.877560+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-18T23:00:00+00:00 EmrJobFlowSensor 07-19T23:00:55.272698+00:00 07-19T23:08:56.966100+00:00 0:08:01.693402 575657 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-19T23:00:53.304498+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-18T23:00:00+00:00 EmrCreateJobFlowOperator 07-19T23:00:29.406222+00:00 07-19T23:00:30.176710+00:00 0:00:00.770488 575654 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-19T23:00:27.713478+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-18T23:00:00+00:00 PythonOperator 07-19T23:00:05.644322+00:00 07-19T23:00:06.671953+00:00 0:00:01.027631 575649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-19T23:00:03.692180+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-17T23:00:00+00:00 EmrJobFlowSensor 07-18T23:00:57.115144+00:00 07-18T23:07:58.467636+00:00 0:07:01.352492 575131 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-18T23:00:55.390042+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-17T23:00:00+00:00 EmrCreateJobFlowOperator 07-18T23:00:31.259865+00:00 07-18T23:00:31.978682+00:00 0:00:00.718817 575129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-18T23:00:29.691161+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-17T23:00:00+00:00 PythonOperator 07-18T23:00:05.537256+00:00 07-18T23:00:06.410824+00:00 0:00:00.873568 575124 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-18T23:00:03.672251+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-16T23:00:00+00:00 EmrJobFlowSensor 07-17T23:00:47.169351+00:00 07-17T23:07:48.566676+00:00 0:07:01.397325 574610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-17T23:00:45.447310+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-16T23:00:00+00:00 EmrCreateJobFlowOperator 07-17T23:00:27.235159+00:00 07-17T23:00:27.914920+00:00 0:00:00.679761 574606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-17T23:00:25.370535+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-16T23:00:00+00:00 PythonOperator 07-17T23:00:03.049668+00:00 07-17T23:00:04.490379+00:00 0:00:01.440711 574601 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-17T23:00:01.335176+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-15T23:00:00+00:00 EmrJobFlowSensor 07-16T23:00:49.324907+00:00 07-16T23:07:50.832024+00:00 0:07:01.507117 574095 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-16T23:00:47.601845+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-15T23:00:00+00:00 EmrCreateJobFlowOperator 07-16T23:00:30.654359+00:00 07-16T23:00:31.847571+00:00 0:00:01.193212 574092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-16T23:00:27.584450+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-15T23:00:00+00:00 PythonOperator 07-16T23:00:08.100205+00:00 07-16T23:00:09.984620+00:00 0:00:01.884415 574086 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-16T23:00:05.575711+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-14T23:00:00+00:00 EmrJobFlowSensor 07-15T23:01:07.257525+00:00 07-15T23:12:09.183595+00:00 0:11:01.926070 573614 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-15T23:01:05.507613+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-14T23:00:00+00:00 EmrCreateJobFlowOperator 07-15T23:00:47.246962+00:00 07-15T23:00:47.995969+00:00 0:00:00.749007 573611 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-15T23:00:45.489802+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-14T23:00:00+00:00 PythonOperator 07-15T23:00:25.132242+00:00 07-15T23:00:26.203809+00:00 0:00:01.071567 573608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-15T23:00:23.469057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-13T23:00:00+00:00 EmrJobFlowSensor 07-14T23:01:03.137965+00:00 07-14T23:12:05.089054+00:00 0:11:01.951089 573181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-14T23:01:01.535635+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-13T23:00:00+00:00 EmrCreateJobFlowOperator 07-14T23:00:41.278498+00:00 07-14T23:00:42.002980+00:00 0:00:00.724482 573178 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-14T23:00:39.513960+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-13T23:00:00+00:00 PythonOperator 07-14T23:00:21.394052+00:00 07-14T23:00:23.100650+00:00 0:00:01.706598 573174 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-14T23:00:19.498131+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-12T23:00:00+00:00 EmrJobFlowSensor 07-13T23:01:03.124692+00:00 07-13T23:11:04.963007+00:00 0:10:01.838315 572761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-13T23:01:01.380102+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-12T23:00:00+00:00 EmrCreateJobFlowOperator 07-13T23:00:41.215172+00:00 07-13T23:00:41.951633+00:00 0:00:00.736461 572758 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-13T23:00:39.380139+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-12T23:00:00+00:00 PythonOperator 07-13T23:00:18.971029+00:00 07-13T23:00:20.066810+00:00 0:00:01.095781 572754 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-13T23:00:17.333722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-11T23:00:00+00:00 EmrJobFlowSensor 07-12T23:00:59.827256+00:00 07-12T23:12:01.716525+00:00 0:11:01.889269 572337 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-12T23:00:57.579254+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-11T23:00:00+00:00 EmrCreateJobFlowOperator 07-12T23:00:39.106515+00:00 07-12T23:00:39.903957+00:00 0:00:00.797442 572334 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-12T23:00:37.532479+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-11T23:00:00+00:00 PythonOperator 07-12T23:00:17.183066+00:00 07-12T23:00:18.092046+00:00 0:00:00.908980 572331 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-12T23:00:15.512840+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-10T23:00:00+00:00 EmrJobFlowSensor 07-11T23:00:53.134177+00:00 07-11T23:10:54.871721+00:00 0:10:01.737544 571855 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-11T23:00:51.356197+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-10T23:00:00+00:00 EmrCreateJobFlowOperator 07-11T23:00:33.149403+00:00 07-11T23:00:33.918305+00:00 0:00:00.768902 571853 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-11T23:00:31.275989+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-10T23:00:00+00:00 PythonOperator 07-11T23:00:11.178500+00:00 07-11T23:00:12.109675+00:00 0:00:00.931175 571851 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-11T23:00:09.261382+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-09T23:00:00+00:00 EmrJobFlowSensor 07-10T23:00:57.122441+00:00 07-10T23:10:58.966221+00:00 0:10:01.843780 571324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-10T23:00:55.474722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-09T23:00:00+00:00 EmrCreateJobFlowOperator 07-10T23:00:30.940552+00:00 07-10T23:00:31.698786+00:00 0:00:00.758234 571322 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-10T23:00:29.389230+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-09T23:00:00+00:00 PythonOperator 07-10T23:00:08.991791+00:00 07-10T23:00:09.915069+00:00 0:00:00.923278 571319 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-10T23:00:07.369080+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-08T23:00:00+00:00 EmrJobFlowSensor 07-09T23:00:49.007852+00:00 07-09T23:10:50.730032+00:00 0:10:01.722180 570847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-09T23:00:47.403065+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-08T23:00:00+00:00 EmrCreateJobFlowOperator 07-09T23:00:27.022409+00:00 07-09T23:00:27.810747+00:00 0:00:00.788338 570845 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-09T23:00:25.387170+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-08T23:00:00+00:00 PythonOperator 07-09T23:00:07.369226+00:00 07-09T23:00:08.359022+00:00 0:00:00.989796 570842 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-09T23:00:05.368268+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-07T23:00:00+00:00 EmrJobFlowSensor 07-08T23:01:06.516897+00:00 07-08T23:12:08.575936+00:00 0:11:02.059039 570444 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-08T23:01:03.913996+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-07T23:00:00+00:00 EmrCreateJobFlowOperator 07-08T23:00:42.585085+00:00 07-08T23:00:43.539775+00:00 0:00:00.954690 570442 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-08T23:00:39.904071+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-07T23:00:00+00:00 PythonOperator 07-08T23:00:22.692834+00:00 07-08T23:00:24.985028+00:00 0:00:02.292194 570439 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-08T23:00:19.882774+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-06T23:00:00+00:00 EmrJobFlowSensor 07-07T23:01:20.268198+00:00 07-07T23:12:22.273029+00:00 0:11:02.004831 570071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-07T23:01:17.639704+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-06T23:00:00+00:00 EmrCreateJobFlowOperator 07-07T23:00:58.155779+00:00 07-07T23:00:59.058280+00:00 0:00:00.902501 570068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-07T23:00:55.623619+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-06T23:00:00+00:00 PythonOperator 07-07T23:00:10.837855+00:00 07-07T23:00:12.129879+00:00 0:00:01.292024 570065 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-07T23:00:08.239646+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-05T23:00:00+00:00 EmrJobFlowSensor 07-06T23:00:58.176409+00:00 07-06T23:12:00.178929+00:00 0:11:02.002520 569605 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-06T23:00:56.002836+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-05T23:00:00+00:00 EmrCreateJobFlowOperator 07-06T23:00:36.134310+00:00 07-06T23:00:37.192019+00:00 0:00:01.057709 569602 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-06T23:00:33.893844+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-05T23:00:00+00:00 PythonOperator 07-06T23:00:15.267237+00:00 07-06T23:00:16.994342+00:00 0:00:01.727105 569599 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-06T23:00:11.851712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-04T23:00:00+00:00 EmrJobFlowSensor 07-05T23:00:54.319314+00:00 07-05T23:11:56.562552+00:00 0:11:02.243238 569142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-05T23:00:52.098473+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-04T23:00:00+00:00 EmrCreateJobFlowOperator 07-05T23:00:35.500534+00:00 07-05T23:00:36.305171+00:00 0:00:00.804637 569140 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-05T23:00:32.081739+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-04T23:00:00+00:00 PythonOperator 07-05T23:00:11.321536+00:00 07-05T23:00:12.617193+00:00 0:00:01.295657 569136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-05T23:00:08.060285+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-03T23:00:00+00:00 EmrJobFlowSensor 07-04T23:12:30.103528+00:00 07-04T23:12:30.622432+00:00 0:00:00.518904 568692 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-04T23:12:27.477105+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-03T23:00:00+00:00 EmrCreateJobFlowOperator 07-04T23:00:42.488523+00:00 07-04T23:00:43.418453+00:00 0:00:00.929930 568681 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-04T23:00:40.132124+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-03T23:00:00+00:00 PythonOperator 07-04T23:00:18.809523+00:00 07-04T23:00:20.027452+00:00 0:00:01.217929 568678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-04T23:00:16.115755+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-02T23:00:00+00:00 EmrJobFlowSensor 07-03T23:00:54.857798+00:00 07-03T23:11:56.865428+00:00 0:11:02.007630 568204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-03T23:00:52.153900+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-02T23:00:00+00:00 EmrCreateJobFlowOperator 07-03T23:00:30.448849+00:00 07-03T23:00:31.376411+00:00 0:00:00.927562 568201 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-03T23:00:28.133345+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-02T23:00:00+00:00 PythonOperator 07-03T23:00:08.837819+00:00 07-03T23:00:11.035680+00:00 0:00:02.197861 568197 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-03T23:00:06.115663+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-01T23:00:00+00:00 EmrJobFlowSensor 07-02T23:00:54.151253+00:00 07-02T23:11:56.148760+00:00 0:11:01.997507 567746 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-02T23:00:51.879406+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-01T23:00:00+00:00 EmrCreateJobFlowOperator 07-02T23:00:28.385410+00:00 07-02T23:00:29.217247+00:00 0:00:00.831837 567743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-02T23:00:25.858073+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-01T23:00:00+00:00 PythonOperator 07-02T23:00:06.243994+00:00 07-02T23:00:07.608408+00:00 0:00:01.364414 567739 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-02T23:00:03.838021+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-30T23:00:00+00:00 EmrJobFlowSensor 07-01T23:13:01.055388+00:00 07-01T23:13:01.723279+00:00 0:00:00.667891 567282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-01T23:12:58.266786+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-30T23:00:00+00:00 EmrCreateJobFlowOperator 07-01T23:00:37.659579+00:00 07-01T23:00:39.002936+00:00 0:00:01.343357 567269 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-01T23:00:34.251327+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-30T23:00:00+00:00 PythonOperator 07-01T23:00:14.982080+00:00 07-01T23:00:16.228939+00:00 0:00:01.246859 567265 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-01T23:00:12.271076+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-29T23:00:00+00:00 EmrJobFlowSensor 06-30T23:13:03.864466+00:00 06-30T23:13:04.429727+00:00 0:00:00.565261 566815 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-30T23:13:01.557469+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-29T23:00:00+00:00 EmrCreateJobFlowOperator 06-30T23:00:38.212605+00:00 06-30T23:00:39.074890+00:00 0:00:00.862285 566804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-30T23:00:35.881832+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-29T23:00:00+00:00 PythonOperator 06-30T23:00:19.268884+00:00 06-30T23:00:21.601984+00:00 0:00:02.333100 566801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-30T23:00:15.865395+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-28T23:00:00+00:00 EmrJobFlowSensor 06-29T23:00:56.777084+00:00 06-29T23:11:59.250813+00:00 0:11:02.473729 566338 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-29T23:00:54.299361+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-28T23:00:00+00:00 EmrCreateJobFlowOperator 06-29T23:00:31.258095+00:00 06-29T23:00:32.083453+00:00 0:00:00.825358 566335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-29T23:00:28.274250+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-28T23:00:00+00:00 PythonOperator 06-29T23:00:10.740262+00:00 06-29T23:00:11.992326+00:00 0:00:01.252064 566331 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-29T23:00:08.246564+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-27T23:00:00+00:00 EmrJobFlowSensor 06-28T23:01:10.512178+00:00 06-28T23:12:12.702055+00:00 0:11:02.189877 565863 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-28T23:01:07.786129+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-27T23:00:00+00:00 EmrCreateJobFlowOperator 06-28T23:00:49.482038+00:00 06-28T23:00:50.487344+00:00 0:00:01.005306 565860 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-28T23:00:45.767557+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-27T23:00:00+00:00 PythonOperator 06-28T23:00:26.008562+00:00 06-28T23:00:27.302275+00:00 0:00:01.293713 565857 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-28T23:00:23.746697+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-26T23:00:00+00:00 EmrJobFlowSensor 06-27T23:00:57.379510+00:00 06-27T23:10:59.384203+00:00 0:10:02.004693 565364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-27T23:00:54.543683+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-26T23:00:00+00:00 EmrCreateJobFlowOperator 06-27T23:00:35.274512+00:00 06-27T23:00:36.114180+00:00 0:00:00.839668 565361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-27T23:00:32.568791+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-26T23:00:00+00:00 PythonOperator 06-27T23:00:10.878088+00:00 06-27T23:00:12.139550+00:00 0:00:01.261462 565357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-27T23:00:08.476301+00:00 2 default_pool