Task Instances


  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-23T23:00:00+00:00 EmrCreateJobFlowOperator 05-24T23:01:01.711443+00:00 05-24T23:01:02.866355+00:00 0:00:01.154912 546611 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-24T23:00:58.732358+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-23T23:00:00+00:00 PythonOperator 05-24T23:00:39.196858+00:00 05-24T23:00:40.446374+00:00 0:00:01.249516 546607 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-24T23:00:36.722790+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-22T23:00:00+00:00 EmrJobFlowSensor 05-23T23:16:51.925405+00:00 05-23T23:16:52.577265+00:00 0:00:00.651860 546124 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-23T23:16:48.739699+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-22T23:00:00+00:00 EmrCreateJobFlowOperator 05-23T23:00:52.057942+00:00 05-23T23:00:52.984269+00:00 0:00:00.926327 546111 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-23T23:00:48.884250+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-22T23:00:00+00:00 PythonOperator 05-23T23:00:29.524570+00:00 05-23T23:00:30.792542+00:00 0:00:01.267972 546106 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-23T23:00:26.744581+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-21T23:00:00+00:00 EmrJobFlowSensor 05-22T23:13:13.597567+00:00 05-22T23:13:14.144693+00:00 0:00:00.547126 545617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-22T23:13:11.300156+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-21T23:00:00+00:00 EmrCreateJobFlowOperator 05-22T23:00:59.268036+00:00 05-22T23:01:00.093093+00:00 0:00:00.825057 545607 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-22T23:00:57.130340+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-21T23:00:00+00:00 PythonOperator 05-22T23:00:37.762660+00:00 05-22T23:00:39.054651+00:00 0:00:01.291991 545603 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-22T23:00:35.123866+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-20T23:00:00+00:00 EmrJobFlowSensor 05-21T23:00:59.273351+00:00 05-21T23:12:01.391042+00:00 0:11:02.117691 545107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-21T23:00:56.848662+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-20T23:00:00+00:00 EmrCreateJobFlowOperator 05-21T23:00:33.875648+00:00 05-21T23:00:34.727491+00:00 0:00:00.851843 545104 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-21T23:00:30.817103+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-20T23:00:00+00:00 PythonOperator 05-21T23:00:13.224947+00:00 05-21T23:00:14.456301+00:00 0:00:01.231354 545100 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-21T23:00:10.796079+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-19T23:00:00+00:00 EmrJobFlowSensor 05-20T23:00:59.105187+00:00 05-20T23:11:01.032988+00:00 0:10:01.927801 544580 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-20T23:00:56.799011+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-19T23:00:00+00:00 EmrCreateJobFlowOperator 05-20T23:00:35.708765+00:00 05-20T23:00:36.552529+00:00 0:00:00.843764 544577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-20T23:00:32.711548+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-19T23:00:00+00:00 PythonOperator 05-20T23:00:10.979136+00:00 05-20T23:00:12.131182+00:00 0:00:01.152046 544573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-20T23:00:08.647876+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-18T23:00:00+00:00 EmrJobFlowSensor 05-19T23:00:47.472050+00:00 05-19T23:10:49.342058+00:00 0:10:01.870008 544099 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-19T23:00:45.255663+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-18T23:00:00+00:00 EmrCreateJobFlowOperator 05-19T23:00:26.470486+00:00 05-19T23:00:27.472679+00:00 0:00:01.002193 544096 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-19T23:00:23.239521+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-18T23:00:00+00:00 PythonOperator 05-19T23:00:05.922960+00:00 05-19T23:00:07.057572+00:00 0:00:01.134612 544092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-19T23:00:03.066538+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-17T23:00:00+00:00 EmrJobFlowSensor 05-18T23:00:58.429475+00:00 05-18T23:12:00.720314+00:00 0:11:02.290839 543618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-18T23:00:55.097384+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-17T23:00:00+00:00 EmrCreateJobFlowOperator 05-18T23:00:32.166315+00:00 05-18T23:00:33.091211+00:00 0:00:00.924896 543615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-18T23:00:28.949363+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-17T23:00:00+00:00 PythonOperator 05-18T23:00:09.370366+00:00 05-18T23:00:10.519621+00:00 0:00:01.149255 543612 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-18T23:00:07.004428+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-16T23:00:00+00:00 EmrJobFlowSensor 05-17T23:00:51.040675+00:00 05-17T23:11:53.122297+00:00 0:11:02.081622 543137 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-17T23:00:48.841102+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-16T23:00:00+00:00 EmrCreateJobFlowOperator 05-17T23:00:29.033894+00:00 05-17T23:00:29.883040+00:00 0:00:00.849146 543134 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-17T23:00:26.823623+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-16T23:00:00+00:00 PythonOperator 05-17T23:00:10.108377+00:00 05-17T23:00:11.272236+00:00 0:00:01.163859 543130 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-17T23:00:06.778764+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-15T23:00:00+00:00 EmrJobFlowSensor 05-16T23:07:24.904466+00:00 05-16T23:11:26.131081+00:00 0:04:01.226615 542654 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-16T23:07:22.649448+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-15T23:00:00+00:00 EmrCreateJobFlowOperator 05-16T23:00:53.699249+00:00 05-16T23:00:54.600743+00:00 0:00:00.901494 542645 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-16T23:00:50.744539+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-15T23:00:00+00:00 PythonOperator 05-16T23:00:31.316216+00:00 05-16T23:00:32.574897+00:00 0:00:01.258681 542642 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-16T23:00:28.808673+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-14T23:00:00+00:00 EmrJobFlowSensor 05-15T23:00:59.031735+00:00 05-15T23:12:01.157832+00:00 0:11:02.126097 542159 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-15T23:00:56.592298+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-14T23:00:00+00:00 EmrCreateJobFlowOperator 05-15T23:00:36.829220+00:00 05-15T23:00:38.166131+00:00 0:00:01.336911 542156 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-15T23:00:34.504795+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-14T23:00:00+00:00 PythonOperator 05-15T23:00:14.750875+00:00 05-15T23:00:16.033943+00:00 0:00:01.283068 542152 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-15T23:00:12.499728+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-13T23:00:00+00:00 EmrJobFlowSensor 05-14T23:01:09.626595+00:00 05-14T23:11:11.532179+00:00 0:10:01.905584 541670 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-14T23:01:07.155681+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-13T23:00:00+00:00 EmrCreateJobFlowOperator 05-14T23:00:47.314834+00:00 05-14T23:00:48.170357+00:00 0:00:00.855523 541667 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-14T23:00:45.084858+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-13T23:00:00+00:00 PythonOperator 05-14T23:00:22.051704+00:00 05-14T23:00:23.283302+00:00 0:00:01.231598 541663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-14T23:00:19.130660+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-12T23:00:00+00:00 EmrJobFlowSensor 05-13T23:16:52.047928+00:00 05-13T23:16:52.595036+00:00 0:00:00.547108 541176 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-13T23:16:49.136484+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-12T23:00:00+00:00 EmrCreateJobFlowOperator 05-13T23:00:31.439709+00:00 05-13T23:00:32.336288+00:00 0:00:00.896579 541165 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-13T23:00:27.933297+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-12T23:00:00+00:00 PythonOperator 05-13T23:00:08.366054+00:00 05-13T23:00:09.575551+00:00 0:00:01.209497 541161 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-13T23:00:05.812389+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-11T23:00:00+00:00 EmrJobFlowSensor 05-12T23:00:57.086461+00:00 05-12T23:10:59.000041+00:00 0:10:01.913580 540676 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-12T23:00:54.911558+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-11T23:00:00+00:00 EmrCreateJobFlowOperator 05-12T23:00:37.228464+00:00 05-12T23:00:38.124265+00:00 0:00:00.895801 540673 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-12T23:00:34.893410+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-11T23:00:00+00:00 PythonOperator 05-12T23:00:15.137077+00:00 05-12T23:00:16.342732+00:00 0:00:01.205655 540669 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-12T23:00:12.887765+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-10T23:00:00+00:00 EmrJobFlowSensor 05-11T23:00:51.850056+00:00 05-11T23:10:53.832021+00:00 0:10:01.981965 540193 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-11T23:00:49.241696+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-10T23:00:00+00:00 EmrCreateJobFlowOperator 05-11T23:00:29.830924+00:00 05-11T23:00:30.774061+00:00 0:00:00.943137 540189 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-11T23:00:27.097501+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-10T23:00:00+00:00 PythonOperator 05-11T23:00:09.903880+00:00 05-11T23:00:11.120869+00:00 0:00:01.216989 540185 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-11T23:00:06.980057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-09T23:00:00+00:00 EmrJobFlowSensor 05-10T23:09:47.189224+00:00 05-10T23:11:48.071575+00:00 0:02:00.882351 539714 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-10T23:09:44.834183+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-09T23:00:00+00:00 EmrCreateJobFlowOperator 05-10T23:00:33.018805+00:00 05-10T23:00:33.950605+00:00 0:00:00.931800 539702 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-10T23:00:30.752900+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-09T23:00:00+00:00 PythonOperator 05-10T23:00:13.657276+00:00 05-10T23:00:14.882701+00:00 0:00:01.225425 539698 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-10T23:00:10.525696+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-08T23:00:00+00:00 EmrJobFlowSensor 05-09T23:12:31.388678+00:00 05-09T23:12:31.942307+00:00 0:00:00.553629 539218 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-09T23:12:29.041490+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-08T23:00:00+00:00 EmrCreateJobFlowOperator 05-09T23:00:46.219157+00:00 05-09T23:00:47.039009+00:00 0:00:00.819852 539208 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-09T23:00:43.989977+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-08T23:00:00+00:00 PythonOperator 05-09T23:00:24.172205+00:00 05-09T23:00:25.302843+00:00 0:00:01.130638 539205 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-09T23:00:21.969070+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-07T23:00:00+00:00 EmrJobFlowSensor 05-08T23:01:05.390341+00:00 05-08T23:10:07.154419+00:00 0:09:01.764078 538715 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-08T23:01:02.870646+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-07T23:00:00+00:00 EmrCreateJobFlowOperator 05-08T23:00:43.104477+00:00 05-08T23:00:44.081513+00:00 0:00:00.977036 538712 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-08T23:00:40.793314+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-07T23:00:00+00:00 PythonOperator 05-08T23:00:21.128940+00:00 05-08T23:00:22.330873+00:00 0:00:01.201933 538709 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-08T23:00:18.775667+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-06T23:00:00+00:00 EmrJobFlowSensor 05-07T23:13:27.660870+00:00 05-07T23:13:28.217676+00:00 0:00:00.556806 538237 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-07T23:13:25.259748+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-06T23:00:00+00:00 EmrCreateJobFlowOperator 05-07T23:01:11.027899+00:00 05-07T23:01:11.757143+00:00 0:00:00.729244 538229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-07T23:01:09.310977+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-06T23:00:00+00:00 PythonOperator 05-07T23:00:23.550956+00:00 05-07T23:00:24.550659+00:00 0:00:00.999703 538224 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-07T23:00:21.807641+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-05T23:00:00+00:00 EmrJobFlowSensor 05-06T23:01:11.644616+00:00 05-06T23:11:13.536804+00:00 0:10:01.892188 537785 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-06T23:01:09.416667+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-05T23:00:00+00:00 EmrCreateJobFlowOperator 05-06T23:00:51.580886+00:00 05-06T23:00:52.472412+00:00 0:00:00.891526 537782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-06T23:00:49.404464+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-05T23:00:00+00:00 PythonOperator 05-06T23:00:29.418962+00:00 05-06T23:00:30.371379+00:00 0:00:00.952417 537778 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-06T23:00:27.383967+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-04T23:00:00+00:00 EmrJobFlowSensor 05-05T23:01:02.895874+00:00 05-05T23:12:04.812822+00:00 0:11:01.916948 537355 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-05T23:01:01.127956+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-04T23:00:00+00:00 EmrCreateJobFlowOperator 05-05T23:00:43.512002+00:00 05-05T23:00:44.313540+00:00 0:00:00.801538 537353 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-05T23:00:41.116007+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-04T23:00:00+00:00 PythonOperator 05-05T23:00:21.318338+00:00 05-05T23:00:22.566908+00:00 0:00:01.248570 537349 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-05T23:00:19.029540+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-03T23:00:00+00:00 EmrJobFlowSensor 05-04T23:12:07.539256+00:00 05-04T23:12:08.194304+00:00 0:00:00.655048 536926 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-04T23:12:04.995458+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-03T23:00:00+00:00 EmrCreateJobFlowOperator 05-04T23:00:26.787592+00:00 05-04T23:00:27.470109+00:00 0:00:00.682517 536914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-04T23:00:25.026708+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-03T23:00:00+00:00 PythonOperator 05-04T23:00:05.395090+00:00 05-04T23:00:06.628872+00:00 0:00:01.233782 536910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-04T23:00:03.013624+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-02T23:00:00+00:00 EmrJobFlowSensor 05-03T23:01:01.678490+00:00 05-03T23:12:03.867906+00:00 0:11:02.189416 536445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-03T23:00:59.462483+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-02T23:00:00+00:00 EmrCreateJobFlowOperator 05-03T23:00:40.012250+00:00 05-03T23:00:41.512017+00:00 0:00:01.499767 536442 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-03T23:00:37.508069+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-02T23:00:00+00:00 PythonOperator 05-03T23:00:13.835598+00:00 05-03T23:00:16.418874+00:00 0:00:02.583276 536438 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-03T23:00:11.431298+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-01T23:00:00+00:00 EmrJobFlowSensor 05-02T23:13:12.223917+00:00 05-02T23:13:12.772768+00:00 0:00:00.548851 535961 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-02T23:13:09.828003+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-01T23:00:00+00:00 EmrCreateJobFlowOperator 05-02T23:00:37.210647+00:00 05-02T23:00:38.049554+00:00 0:00:00.838907 535947 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-02T23:00:35.036127+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-01T23:00:00+00:00 PythonOperator 05-02T23:00:09.362721+00:00 05-02T23:00:10.544799+00:00 0:00:01.182078 535943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-02T23:00:06.982346+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-30T23:00:00+00:00 EmrJobFlowSensor 05-01T23:01:09.127945+00:00 05-01T23:12:11.147479+00:00 0:11:02.019534 535451 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-01T23:01:06.713047+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-30T23:00:00+00:00 EmrCreateJobFlowOperator 05-01T23:00:46.981039+00:00 05-01T23:00:47.906141+00:00 0:00:00.925102 535449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-01T23:00:44.692523+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-30T23:00:00+00:00 PythonOperator 05-01T23:00:24.715696+00:00 05-01T23:00:25.883581+00:00 0:00:01.167885 535447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-01T23:00:22.457933+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-29T23:00:00+00:00 EmrJobFlowSensor 04-30T23:17:06.782806+00:00 04-30T23:17:07.332217+00:00 0:00:00.549411 534896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-30T23:17:04.134968+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-29T23:00:00+00:00 EmrCreateJobFlowOperator 04-30T23:00:32.368697+00:00 04-30T23:00:33.239660+00:00 0:00:00.870963 534883 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-30T23:00:30.190841+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-29T23:00:00+00:00 PythonOperator 04-30T23:00:10.344648+00:00 04-30T23:00:11.476131+00:00 0:00:01.131483 534881 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-30T23:00:08.166083+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-28T23:00:00+00:00 EmrJobFlowSensor 04-29T23:12:37.784121+00:00 04-29T23:12:38.332495+00:00 0:00:00.548374 534324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-29T23:12:35.248148+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-28T23:00:00+00:00 EmrCreateJobFlowOperator 04-29T23:00:27.520771+00:00 04-29T23:00:28.346397+00:00 0:00:00.825626 534311 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-29T23:00:25.229215+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-28T23:00:00+00:00 PythonOperator 04-29T23:00:05.944322+00:00 04-29T23:00:07.141456+00:00 0:00:01.197134 534308 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-29T23:00:03.204199+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-27T23:00:00+00:00 EmrJobFlowSensor 04-29T12:42:11.002116+00:00 04-29T12:51:14.055270+00:00 0:09:03.053154 534016 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-29T12:41:52.728572+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-26T23:00:00+00:00 EmrJobFlowSensor 04-29T12:41:55.548121+00:00 04-29T12:50:58.316155+00:00 0:09:02.768034 533998 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-29T12:41:52.728558+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-25T23:00:00+00:00 EmrJobFlowSensor 04-29T12:41:42.853848+00:00 04-29T12:41:45.960698+00:00 0:00:03.106850 533957 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-29T12:38:14.247423+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-27T23:00:00+00:00 EmrCreateJobFlowOperator 04-29T12:40:06.526673+00:00 04-29T12:40:13.816651+00:00 0:00:07.289978 533860 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-29T12:38:14.247408+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-26T23:00:00+00:00 EmrCreateJobFlowOperator 04-29T12:39:46.154261+00:00 04-29T12:39:53.369348+00:00 0:00:07.215087 533831 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-29T12:38:14.247377+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-25T23:00:00+00:00 EmrCreateJobFlowOperator 04-29T12:31:03.878761+00:00 04-29T12:31:10.300809+00:00 0:00:06.422048 533361 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-29T12:30:50.509341+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-27T23:00:00+00:00 PythonOperator 04-29T11:54:00.366073+00:00 04-29T11:54:32.976720+00:00 0:00:32.610647 531146 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-29T11:53:26.580300+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-26T23:00:00+00:00 PythonOperator 04-29T10:25:46.530041+00:00 04-29T10:26:02.432369+00:00 0:00:15.902328 525823 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-29T10:23:19.800276+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-25T23:00:00+00:00 PythonOperator 04-29T09:04:48.400823+00:00 04-29T09:05:06.153537+00:00 0:00:17.752714 520925 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-29T09:00:47.448047+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-24T23:00:00+00:00 EmrJobFlowSensor 04-25T23:00:58.233162+00:00 04-25T23:12:00.281852+00:00 0:11:02.048690 519622 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-25T23:00:55.813780+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-24T23:00:00+00:00 EmrCreateJobFlowOperator 04-25T23:00:38.250935+00:00 04-25T23:00:39.162415+00:00 0:00:00.911480 519619 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-25T23:00:35.732663+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-24T23:00:00+00:00 PythonOperator 04-25T23:00:17.171502+00:00 04-25T23:00:21.401617+00:00 0:00:04.230115 519615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-25T23:00:13.671637+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-23T23:00:00+00:00 EmrJobFlowSensor 04-24T23:00:51.919575+00:00 04-24T23:10:53.881557+00:00 0:10:01.961982 519136 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-24T23:00:49.713848+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-23T23:00:00+00:00 EmrCreateJobFlowOperator 04-24T23:00:32.122533+00:00 04-24T23:00:33.087510+00:00 0:00:00.964977 519133 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-24T23:00:29.636434+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-23T23:00:00+00:00 PythonOperator 04-24T23:00:03.925766+00:00 04-24T23:00:05.092308+00:00 0:00:01.166542 519129 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-24T23:00:01.559428+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-22T23:00:00+00:00 EmrJobFlowSensor 04-23T23:00:53.430034+00:00 04-23T23:10:55.252715+00:00 0:10:01.822681 518641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-23T23:00:51.250341+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-22T23:00:00+00:00 EmrCreateJobFlowOperator 04-23T23:00:31.306572+00:00 04-23T23:00:32.124886+00:00 0:00:00.818314 518638 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-23T23:00:29.158848+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-22T23:00:00+00:00 PythonOperator 04-23T23:00:11.437246+00:00 04-23T23:00:13.816571+00:00 0:00:02.379325 518634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-23T23:00:09.142155+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-21T23:00:00+00:00 EmrJobFlowSensor 04-22T23:00:48.678790+00:00 04-22T23:11:50.909115+00:00 0:11:02.230325 518141 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-22T23:00:45.144866+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-21T23:00:00+00:00 EmrCreateJobFlowOperator 04-22T23:00:33.067900+00:00 04-22T23:00:34.318966+00:00 0:00:01.251066 518139 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-22T23:00:25.041503+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-21T23:00:00+00:00 PythonOperator 04-22T23:00:06.007613+00:00 04-22T23:00:08.341933+00:00 0:00:02.334320 518135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-22T23:00:03.003763+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-20T23:00:00+00:00 EmrJobFlowSensor 04-21T23:15:37.599162+00:00 04-21T23:15:38.111235+00:00 0:00:00.512073 517658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-21T23:15:35.036458+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-20T23:00:00+00:00 EmrCreateJobFlowOperator 04-21T23:00:45.480256+00:00 04-21T23:00:46.822195+00:00 0:00:01.341939 517647 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-21T23:00:43.277208+00:00 2 default_pool