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 check_cluster_status 11-19T23:00:00+00:00 EmrJobFlowSensor 11-20T23:00:55.876362+00:00 11-20T23:08:57.805835+00:00 0:08:01.929473 639647 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-20T23:00:52.181469+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-19T23:00:00+00:00 EmrCreateJobFlowOperator 11-20T23:00:34.679939+00:00 11-20T23:00:35.766752+00:00 0:00:01.086813 639643 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-20T23:00:30.169191+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-19T23:00:00+00:00 PythonOperator 11-20T23:00:07.687727+00:00 11-20T23:00:08.676502+00:00 0:00:00.988775 639637 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-20T23:00:04.013825+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-18T23:00:00+00:00 EmrJobFlowSensor 11-19T23:01:03.599203+00:00 11-19T23:08:05.403008+00:00 0:07:01.803805 639085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-19T23:00:59.621939+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-18T23:00:00+00:00 EmrCreateJobFlowOperator 11-19T23:00:39.669397+00:00 11-19T23:00:40.863196+00:00 0:00:01.193799 639082 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-19T23:00:35.567387+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-18T23:00:00+00:00 PythonOperator 11-19T23:00:17.537645+00:00 11-19T23:00:18.617119+00:00 0:00:01.079474 639078 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-19T23:00:13.512931+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-17T23:00:00+00:00 EmrJobFlowSensor 11-18T23:01:08.874949+00:00 11-18T23:09:10.737617+00:00 0:08:01.862668 638518 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-18T23:01:03.131368+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-17T23:00:00+00:00 EmrCreateJobFlowOperator 11-18T23:00:44.953456+00:00 11-18T23:00:45.982247+00:00 0:00:01.028791 638512 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-18T23:00:40.800122+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-17T23:00:00+00:00 PythonOperator 11-18T23:00:12.869309+00:00 11-18T23:00:14.101367+00:00 0:00:01.232058 638509 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-18T23:00:08.606346+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-16T23:00:00+00:00 EmrJobFlowSensor 11-17T23:00:57.619246+00:00 11-17T23:08:59.482555+00:00 0:08:01.863309 637928 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-17T23:00:54.232218+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-16T23:00:00+00:00 EmrCreateJobFlowOperator 11-17T23:00:33.706297+00:00 11-17T23:00:34.665854+00:00 0:00:00.959557 637924 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-17T23:00:30.316372+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-16T23:00:00+00:00 PythonOperator 11-17T23:00:12.426590+00:00 11-17T23:00:14.316237+00:00 0:00:01.889647 637920 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-17T23:00:08.186918+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-15T23:00:00+00:00 EmrJobFlowSensor 11-16T23:13:03.192608+00:00 11-16T23:13:03.896210+00:00 0:00:00.703602 637362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-16T23:12:59.882248+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-15T23:00:00+00:00 EmrCreateJobFlowOperator 11-16T23:00:32.723806+00:00 11-16T23:00:33.778180+00:00 0:00:01.054374 637347 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-16T23:00:26.625033+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-15T23:00:00+00:00 PythonOperator 11-16T23:00:06.537528+00:00 11-16T23:00:07.463993+00:00 0:00:00.926465 637342 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-16T23:00:02.517070+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-14T23:00:00+00:00 EmrJobFlowSensor 11-15T23:12:58.124712+00:00 11-15T23:12:58.923371+00:00 0:00:00.798659 636767 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-15T23:12:54.059789+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-14T23:00:00+00:00 EmrCreateJobFlowOperator 11-15T23:00:37.693025+00:00 11-15T23:00:38.830461+00:00 0:00:01.137436 636753 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-15T23:00:34.258053+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-14T23:00:00+00:00 PythonOperator 11-15T23:00:16.347682+00:00 11-15T23:00:17.325745+00:00 0:00:00.978063 636749 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-15T23:00:12.221661+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-13T23:00:00+00:00 EmrJobFlowSensor 11-14T23:01:06.569916+00:00 11-14T23:09:08.504423+00:00 0:08:01.934507 636180 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-14T23:01:02.921260+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-13T23:00:00+00:00 EmrCreateJobFlowOperator 11-14T23:00:44.570071+00:00 11-14T23:00:45.527275+00:00 0:00:00.957204 636176 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-14T23:00:40.804926+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-13T23:00:00+00:00 PythonOperator 11-14T23:00:22.555488+00:00 11-14T23:00:23.436866+00:00 0:00:00.881378 636172 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-14T23:00:18.789637+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-12T23:00:00+00:00 EmrJobFlowSensor 11-13T23:01:06.809051+00:00 11-13T23:09:08.711871+00:00 0:08:01.902820 635597 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-13T23:01:03.488258+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-12T23:00:00+00:00 EmrCreateJobFlowOperator 11-13T23:00:44.851209+00:00 11-13T23:00:45.891911+00:00 0:00:01.040702 635593 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-13T23:00:41.439348+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-12T23:00:00+00:00 PythonOperator 11-13T23:00:23.219236+00:00 11-13T23:00:24.160370+00:00 0:00:00.941134 635588 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-13T23:00:19.559884+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-11T23:00:00+00:00 EmrJobFlowSensor 11-12T23:01:16.609077+00:00 11-12T23:09:18.489651+00:00 0:08:01.880574 635019 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-12T23:01:12.373773+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-11T23:00:00+00:00 EmrCreateJobFlowOperator 11-12T23:00:53.540302+00:00 11-12T23:00:54.472539+00:00 0:00:00.932237 635017 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-12T23:00:49.743070+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-11T23:00:00+00:00 PythonOperator 11-12T23:00:23.540020+00:00 11-12T23:00:24.608744+00:00 0:00:01.068724 635011 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-12T23:00:19.658512+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-10T23:00:00+00:00 EmrJobFlowSensor 11-11T23:01:30.485587+00:00 11-11T23:08:32.231050+00:00 0:07:01.745463 634440 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-11T23:01:26.855513+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-10T23:00:00+00:00 EmrCreateJobFlowOperator 11-11T23:00:35.078789+00:00 11-11T23:00:37.474016+00:00 0:00:02.395227 634434 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-11T23:00:30.165319+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-10T23:00:00+00:00 PythonOperator 11-11T23:00:12.886341+00:00 11-11T23:00:14.412361+00:00 0:00:01.526020 634429 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-11T23:00:06.022367+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-09T23:00:00+00:00 EmrJobFlowSensor 11-10T23:01:12.432545+00:00 11-10T23:09:14.391375+00:00 0:08:01.958830 633838 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-10T23:01:08.878683+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-09T23:00:00+00:00 EmrCreateJobFlowOperator 11-10T23:00:45.396390+00:00 11-10T23:00:47.267297+00:00 0:00:01.870907 633833 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-10T23:00:26.839349+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-09T23:00:00+00:00 PythonOperator 11-10T23:00:15.081680+00:00 11-10T23:00:21.374437+00:00 0:00:06.292757 633828 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-10T23:00:04.821325+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-08T23:00:00+00:00 EmrJobFlowSensor 11-09T23:01:16.624012+00:00 11-09T23:09:18.594903+00:00 0:08:01.970891 633240 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-09T23:01:12.870109+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-08T23:00:00+00:00 EmrCreateJobFlowOperator 11-09T23:01:05.602086+00:00 11-09T23:01:08.407407+00:00 0:00:02.805321 633237 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-09T23:00:52.863998+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-08T23:00:00+00:00 PythonOperator 11-09T23:00:26.609231+00:00 11-09T23:00:31.191638+00:00 0:00:04.582407 633232 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-09T23:00:08.863118+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-07T23:00:00+00:00 EmrJobFlowSensor 11-08T23:13:22.002779+00:00 11-08T23:13:24.089424+00:00 0:00:02.086645 632653 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-08T23:13:10.587643+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-07T23:00:00+00:00 EmrCreateJobFlowOperator 11-08T23:00:56.088079+00:00 11-08T23:00:58.280353+00:00 0:00:02.192274 632640 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-08T23:00:44.955705+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-07T23:00:00+00:00 PythonOperator 11-08T23:00:34.892952+00:00 11-08T23:00:40.010287+00:00 0:00:05.117335 632637 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-08T23:00:18.899997+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-06T23:00:00+00:00 EmrJobFlowSensor 11-07T23:12:50.237518+00:00 11-07T23:12:51.078822+00:00 0:00:00.841304 632053 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-07T23:12:46.719108+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-06T23:00:00+00:00 EmrCreateJobFlowOperator 11-07T23:01:06.223720+00:00 11-07T23:01:07.377968+00:00 0:00:01.154248 632042 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-07T23:00:58.978475+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-06T23:00:00+00:00 PythonOperator 11-07T23:00:34.711377+00:00 11-07T23:00:37.803582+00:00 0:00:03.092205 632037 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-07T23:00:16.915692+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-05T23:00:00+00:00 EmrJobFlowSensor 11-06T23:01:56.864108+00:00 11-06T23:09:58.486831+00:00 0:08:01.622723 631452 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-06T23:01:54.616320+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-05T23:00:00+00:00 EmrCreateJobFlowOperator 11-06T23:00:50.316817+00:00 11-06T23:00:51.234561+00:00 0:00:00.917744 631447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-06T23:00:46.917569+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-05T23:00:00+00:00 PythonOperator 11-06T23:00:26.135291+00:00 11-06T23:00:27.077950+00:00 0:00:00.942659 631444 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-06T23:00:22.778994+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-04T23:00:00+00:00 EmrJobFlowSensor 11-05T23:02:15.915317+00:00 11-05T23:08:17.431576+00:00 0:06:01.516259 630914 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-05T23:02:12.519566+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-04T23:00:00+00:00 EmrCreateJobFlowOperator 11-05T23:01:53.939940+00:00 11-05T23:01:54.887632+00:00 0:00:00.947692 630912 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-05T23:01:50.469368+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-04T23:00:00+00:00 PythonOperator 11-05T23:00:25.379346+00:00 11-05T23:00:26.126058+00:00 0:00:00.746712 630905 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-05T23:00:23.015137+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-03T23:00:00+00:00 EmrJobFlowSensor 11-04T23:13:06.855351+00:00 11-04T23:13:07.471220+00:00 0:00:00.615869 630343 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-04T23:13:03.008903+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-03T23:00:00+00:00 EmrCreateJobFlowOperator 11-04T23:00:46.773752+00:00 11-04T23:00:47.559158+00:00 0:00:00.785406 630332 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-04T23:00:44.506352+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-03T23:00:00+00:00 PythonOperator 11-04T23:00:23.131403+00:00 11-04T23:00:24.198274+00:00 0:00:01.066871 630329 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-04T23:00:16.429065+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-02T23:00:00+00:00 EmrJobFlowSensor 11-03T23:12:49.849542+00:00 11-03T23:12:50.425102+00:00 0:00:00.575560 629812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-03T23:12:46.909688+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-02T23:00:00+00:00 EmrCreateJobFlowOperator 11-03T23:00:36.531324+00:00 11-03T23:00:37.365148+00:00 0:00:00.833824 629802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-03T23:00:34.404602+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-02T23:00:00+00:00 PythonOperator 11-03T23:00:16.016162+00:00 11-03T23:00:16.955638+00:00 0:00:00.939476 629799 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-03T23:00:12.424944+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 11-01T23:00:00+00:00 EmrJobFlowSensor 11-02T23:01:15.274159+00:00 11-02T23:10:16.948744+00:00 0:09:01.674585 629312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-02T23:01:12.637437+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 11-01T23:00:00+00:00 EmrCreateJobFlowOperator 11-02T23:00:53.116105+00:00 11-02T23:00:53.944649+00:00 0:00:00.828544 629309 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-02T23:00:50.556027+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 11-01T23:00:00+00:00 PythonOperator 11-02T23:00:25.781192+00:00 11-02T23:00:26.576452+00:00 0:00:00.795260 629306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-02T23:00:22.518068+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-31T23:00:00+00:00 EmrJobFlowSensor 11-01T23:00:57.051814+00:00 11-01T23:08:58.747007+00:00 0:08:01.695193 628824 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 11-01T23:00:54.866177+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-31T23:00:00+00:00 EmrCreateJobFlowOperator 11-01T23:00:33.361197+00:00 11-01T23:00:34.341297+00:00 0:00:00.980100 628821 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 11-01T23:00:30.920174+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-31T23:00:00+00:00 PythonOperator 11-01T23:00:14.670183+00:00 11-01T23:00:15.655218+00:00 0:00:00.985035 628818 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 11-01T23:00:10.713471+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-30T23:00:00+00:00 EmrJobFlowSensor 10-31T23:00:58.373915+00:00 10-31T23:09:00.247347+00:00 0:08:01.873432 628339 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-31T23:00:54.694422+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-30T23:00:00+00:00 EmrCreateJobFlowOperator 10-31T23:00:34.735395+00:00 10-31T23:00:35.829845+00:00 0:00:01.094450 628335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-31T23:00:32.554090+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-30T23:00:00+00:00 PythonOperator 10-31T23:00:16.916520+00:00 10-31T23:00:18.665777+00:00 0:00:01.749257 628333 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-31T23:00:12.466960+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-29T23:00:00+00:00 EmrJobFlowSensor 10-30T23:00:53.136719+00:00 10-30T23:06:54.493095+00:00 0:06:01.356376 627848 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-30T23:00:50.920845+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-29T23:00:00+00:00 EmrCreateJobFlowOperator 10-30T23:00:30.262957+00:00 10-30T23:00:31.217915+00:00 0:00:00.954958 627845 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-30T23:00:26.906113+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-29T23:00:00+00:00 PythonOperator 10-30T23:00:08.551707+00:00 10-30T23:00:09.594402+00:00 0:00:01.042695 627841 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-30T23:00:04.715146+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-28T23:00:00+00:00 EmrJobFlowSensor 10-29T23:12:43.278715+00:00 10-29T23:12:43.812707+00:00 0:00:00.533992 627365 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-29T23:12:40.514714+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-28T23:00:00+00:00 EmrCreateJobFlowOperator 10-29T23:00:50.911339+00:00 10-29T23:00:52.231178+00:00 0:00:01.319839 627355 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-29T23:00:45.827913+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-28T23:00:00+00:00 PythonOperator 10-29T23:00:26.572067+00:00 10-29T23:00:27.332079+00:00 0:00:00.760012 627352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-29T23:00:23.640251+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-27T23:00:00+00:00 EmrJobFlowSensor 10-28T23:01:17.436656+00:00 10-28T23:09:19.054518+00:00 0:08:01.617862 626865 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-28T23:01:15.120673+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-27T23:00:00+00:00 EmrCreateJobFlowOperator 10-28T23:00:51.215029+00:00 10-28T23:00:52.000918+00:00 0:00:00.785889 626862 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-28T23:00:49.014267+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-27T23:00:00+00:00 PythonOperator 10-28T23:00:32.239956+00:00 10-28T23:00:33.110918+00:00 0:00:00.870962 626859 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-28T23:00:28.965158+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-26T23:00:00+00:00 EmrJobFlowSensor 10-27T23:12:45.294051+00:00 10-27T23:12:45.811739+00:00 0:00:00.517688 626378 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-27T23:12:42.821848+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-26T23:00:00+00:00 EmrCreateJobFlowOperator 10-27T23:00:58.822764+00:00 10-27T23:00:59.759290+00:00 0:00:00.936526 626366 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-27T23:00:55.313633+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-26T23:00:00+00:00 PythonOperator 10-27T23:00:35.237567+00:00 10-27T23:00:35.922878+00:00 0:00:00.685311 626363 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-27T23:00:33.152407+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-25T23:00:00+00:00 EmrJobFlowSensor 10-26T23:07:54.106080+00:00 10-26T23:07:54.753327+00:00 0:00:00.647247 625883 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-26T23:07:50.500235+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-25T23:00:00+00:00 EmrCreateJobFlowOperator 10-26T23:00:34.953707+00:00 10-26T23:00:36.042515+00:00 0:00:01.088808 625873 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-26T23:00:32.622354+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-25T23:00:00+00:00 PythonOperator 10-26T23:00:13.891027+00:00 10-26T23:00:14.820957+00:00 0:00:00.929930 625869 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-26T23:00:10.545439+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-24T23:00:00+00:00 EmrJobFlowSensor 10-25T23:01:00.431316+00:00 10-25T23:08:02.038259+00:00 0:07:01.606943 625384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-25T23:00:58.289763+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-24T23:00:00+00:00 EmrCreateJobFlowOperator 10-25T23:00:36.772823+00:00 10-25T23:00:37.607424+00:00 0:00:00.834601 625381 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-25T23:00:34.403794+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-24T23:00:00+00:00 PythonOperator 10-25T23:00:16.174760+00:00 10-25T23:00:17.057811+00:00 0:00:00.883051 625377 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-25T23:00:12.327313+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-23T23:00:00+00:00 EmrJobFlowSensor 10-24T23:00:58.880629+00:00 10-24T23:08:00.421150+00:00 0:07:01.540521 624894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-24T23:00:56.636897+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-23T23:00:00+00:00 EmrCreateJobFlowOperator 10-24T23:00:36.088001+00:00 10-24T23:00:37.040989+00:00 0:00:00.952988 624891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-24T23:00:32.610125+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-23T23:00:00+00:00 PythonOperator 10-24T23:00:13.990992+00:00 10-24T23:00:14.889255+00:00 0:00:00.898263 624887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-24T23:00:10.524941+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-22T23:00:00+00:00 EmrJobFlowSensor 10-23T23:01:12.448963+00:00 10-23T23:08:14.207335+00:00 0:07:01.758372 624392 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-23T23:01:09.103074+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-22T23:00:00+00:00 EmrCreateJobFlowOperator 10-23T23:00:43.387180+00:00 10-23T23:00:44.224753+00:00 0:00:00.837573 624390 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-23T23:00:41.142826+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-22T23:00:00+00:00 PythonOperator 10-23T23:00:20.311918+00:00 10-23T23:00:21.029188+00:00 0:00:00.717270 624387 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-23T23:00:17.041270+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-21T23:00:00+00:00 EmrJobFlowSensor 10-22T23:00:55.340997+00:00 10-22T23:06:56.950153+00:00 0:06:01.609156 623881 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-22T23:00:51.971172+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-21T23:00:00+00:00 EmrCreateJobFlowOperator 10-22T23:00:31.666243+00:00 10-22T23:00:32.649219+00:00 0:00:00.982976 623879 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-22T23:00:28.035836+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-21T23:00:00+00:00 PythonOperator 10-22T23:00:12.606715+00:00 10-22T23:00:14.455142+00:00 0:00:01.848427 623875 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-22T23:00:07.383047+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-20T23:00:00+00:00 EmrJobFlowSensor 10-21T23:01:06.764304+00:00 10-21T23:08:08.229042+00:00 0:07:01.464738 623374 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-21T23:01:04.569207+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-20T23:00:00+00:00 EmrCreateJobFlowOperator 10-21T23:00:40.438686+00:00 10-21T23:00:41.344086+00:00 0:00:00.905400 623372 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-21T23:00:38.428689+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-20T23:00:00+00:00 PythonOperator 10-21T23:00:18.657218+00:00 10-21T23:00:19.343501+00:00 0:00:00.686283 623370 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-21T23:00:16.468440+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-19T23:00:00+00:00 EmrJobFlowSensor 10-20T23:01:12.248780+00:00 10-20T23:08:13.720019+00:00 0:07:01.471239 622873 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-20T23:01:10.082404+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-19T23:00:00+00:00 EmrCreateJobFlowOperator 10-20T23:00:51.934575+00:00 10-20T23:00:52.751070+00:00 0:00:00.816495 622871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-20T23:00:49.998567+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-19T23:00:00+00:00 PythonOperator 10-20T23:00:31.513344+00:00 10-20T23:00:32.397365+00:00 0:00:00.884021 622869 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-20T23:00:28.060366+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-18T23:00:00+00:00 EmrJobFlowSensor 10-19T23:01:17.972263+00:00 10-19T23:09:19.556213+00:00 0:08:01.583950 622371 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-19T23:01:15.777312+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-18T23:00:00+00:00 EmrCreateJobFlowOperator 10-19T23:00:57.774391+00:00 10-19T23:00:58.593088+00:00 0:00:00.818697 622369 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-19T23:00:55.663986+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-18T23:00:00+00:00 PythonOperator 10-19T23:00:36.973815+00:00 10-19T23:00:37.804821+00:00 0:00:00.831006 622367 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-19T23:00:33.620693+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-17T23:00:00+00:00 EmrJobFlowSensor 10-18T23:00:53.391551+00:00 10-18T23:06:54.742821+00:00 0:06:01.351270 621865 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-18T23:00:51.252821+00:00 2 default_pool