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 2023-11-19T23:00:00+00:00 PythonOperator 2023-11-20T23:00:12.702384+00:00 2023-11-20T23:00:13.625352+00:00 0:00:00.922968 448533 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T23:00:10.992192+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-18T23:00:00+00:00 EmrJobFlowSensor 2023-11-19T23:01:04.205052+00:00 2023-11-19T23:11:06.072887+00:00 0:10:01.867835 448153 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-19T23:01:01.853144+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-19T23:00:27.713892+00:00 2023-11-19T23:00:28.620287+00:00 0:00:00.906395 448151 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-19T23:00:25.853269+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-18T23:00:00+00:00 PythonOperator 2023-11-19T23:00:06.300403+00:00 2023-11-19T23:00:07.474588+00:00 0:00:01.174185 448150 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-19T23:00:03.833082+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-17T23:00:00+00:00 EmrJobFlowSensor 2023-11-18T23:01:03.111520+00:00 2023-11-18T23:11:05.042137+00:00 0:10:01.930617 447881 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T23:01:01.207194+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T23:00:41.067955+00:00 2023-11-18T23:00:42.191234+00:00 0:00:01.123279 447879 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T23:00:39.141777+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-17T23:00:00+00:00 PythonOperator 2023-11-18T23:00:18.744314+00:00 2023-11-18T23:00:19.649021+00:00 0:00:00.904707 447877 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T23:00:17.123516+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-16T23:00:00+00:00 EmrJobFlowSensor 2023-11-17T23:00:46.520854+00:00 2023-11-17T23:10:48.467826+00:00 0:10:01.946972 447541 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T23:00:44.488796+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T23:00:26.418489+00:00 2023-11-17T23:00:27.342510+00:00 0:00:00.924021 447539 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T23:00:24.474355+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-16T23:00:00+00:00 PythonOperator 2023-11-17T23:00:04.479931+00:00 2023-11-17T23:00:05.613299+00:00 0:00:01.133368 447537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T23:00:02.402330+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-15T23:00:00+00:00 EmrJobFlowSensor 2023-11-16T23:01:05.269452+00:00 2023-11-16T23:12:07.354575+00:00 0:11:02.085123 447201 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T23:01:03.348917+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T23:00:45.412215+00:00 2023-11-16T23:00:46.279128+00:00 0:00:00.866913 447200 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T23:00:43.329164+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-15T23:00:00+00:00 PythonOperator 2023-11-16T23:00:24.278823+00:00 2023-11-16T23:00:25.479706+00:00 0:00:01.200883 447198 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T23:00:21.362504+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-14T23:00:00+00:00 EmrJobFlowSensor 2023-11-15T23:01:21.421910+00:00 2023-11-15T23:11:23.182336+00:00 0:10:01.760426 446857 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T23:01:19.570945+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T23:00:59.411104+00:00 2023-11-15T23:01:00.298637+00:00 0:00:00.887533 446855 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T23:00:57.553042+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-14T23:00:00+00:00 PythonOperator 2023-11-15T23:00:39.700394+00:00 2023-11-15T23:00:40.826421+00:00 0:00:01.126027 446853 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T23:00:37.582055+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-13T23:00:00+00:00 EmrJobFlowSensor 2023-11-14T23:01:03.993481+00:00 2023-11-14T23:11:05.776735+00:00 0:10:01.783254 446517 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T23:01:01.983195+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T23:00:43.870841+00:00 2023-11-14T23:00:44.938117+00:00 0:00:01.067276 446515 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T23:00:41.955825+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-13T23:00:00+00:00 PythonOperator 2023-11-14T23:00:21.806293+00:00 2023-11-14T23:00:22.905604+00:00 0:00:01.099311 446513 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T23:00:19.934535+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-12T23:00:00+00:00 EmrJobFlowSensor 2023-11-13T23:00:56.704901+00:00 2023-11-13T23:10:58.447817+00:00 0:10:01.742916 446187 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T23:00:54.772251+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T23:00:36.701129+00:00 2023-11-13T23:00:37.606588+00:00 0:00:00.905459 446185 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T23:00:34.751289+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-12T23:00:00+00:00 PythonOperator 2023-11-13T23:00:14.718128+00:00 2023-11-13T23:00:15.836955+00:00 0:00:01.118827 446183 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T23:00:12.761425+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-11T23:00:00+00:00 EmrJobFlowSensor 2023-11-12T23:01:00.824423+00:00 2023-11-12T23:11:02.835841+00:00 0:10:02.011418 445865 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T23:00:57.215931+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T23:00:39.298015+00:00 2023-11-12T23:00:40.068109+00:00 0:00:00.770094 445864 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T23:00:37.195760+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-11T23:00:00+00:00 PythonOperator 2023-11-12T23:00:18.844310+00:00 2023-11-12T23:00:20.146480+00:00 0:00:01.302170 445861 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T23:00:15.175992+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-10T23:00:00+00:00 EmrJobFlowSensor 2023-11-11T23:01:03.411836+00:00 2023-11-11T23:11:05.351975+00:00 0:10:01.940139 445554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T23:01:01.490249+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T23:00:43.458022+00:00 2023-11-11T23:00:44.471316+00:00 0:00:01.013294 445552 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T23:00:41.484533+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-10T23:00:00+00:00 PythonOperator 2023-11-11T23:00:21.425521+00:00 2023-11-11T23:00:23.005214+00:00 0:00:01.579693 445550 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T23:00:19.442482+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-09T23:00:00+00:00 EmrJobFlowSensor 2023-11-10T23:01:03.731012+00:00 2023-11-10T23:11:05.449924+00:00 0:10:01.718912 445248 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T23:01:01.768212+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T23:00:41.644125+00:00 2023-11-10T23:00:42.423993+00:00 0:00:00.779868 445246 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T23:00:39.748360+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-09T23:00:00+00:00 PythonOperator 2023-11-10T23:00:21.697156+00:00 2023-11-10T23:00:22.717278+00:00 0:00:01.020122 445244 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T23:00:19.732108+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-08T23:00:00+00:00 EmrJobFlowSensor 2023-11-09T23:02:24.708426+00:00 2023-11-09T23:12:26.432368+00:00 0:10:01.723942 444940 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-09T23:02:22.813917+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-09T23:02:02.732565+00:00 2023-11-09T23:02:03.646463+00:00 0:00:00.913898 444939 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-09T23:02:00.793499+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-08T23:00:00+00:00 PythonOperator 2023-11-09T23:01:40.813137+00:00 2023-11-09T23:01:41.868770+00:00 0:00:01.055633 444938 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-09T23:01:38.771772+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-07T23:00:00+00:00 EmrJobFlowSensor 2023-11-08T23:01:33.343939+00:00 2023-11-08T23:11:35.110829+00:00 0:10:01.766890 444645 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T23:01:31.402687+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T23:01:11.299476+00:00 2023-11-08T23:01:12.318175+00:00 0:00:01.018699 444644 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T23:01:09.382755+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-07T23:00:00+00:00 PythonOperator 2023-11-08T23:00:51.712132+00:00 2023-11-08T23:00:53.486029+00:00 0:00:01.773897 444642 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T23:00:49.368128+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-06T23:00:00+00:00 EmrJobFlowSensor 2023-11-07T23:01:03.033441+00:00 2023-11-07T23:12:04.905134+00:00 0:11:01.871693 444227 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T23:01:00.987100+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T23:00:40.889340+00:00 2023-11-07T23:00:41.756944+00:00 0:00:00.867604 444225 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T23:00:38.964206+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-06T23:00:00+00:00 PythonOperator 2023-11-07T23:00:22.303294+00:00 2023-11-07T23:00:23.480509+00:00 0:00:01.177215 444223 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T23:00:18.899742+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-05T23:00:00+00:00 EmrJobFlowSensor 2023-11-06T23:00:49.999363+00:00 2023-11-06T23:10:51.703781+00:00 0:10:01.704418 443735 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T23:00:47.958955+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T23:00:29.960912+00:00 2023-11-06T23:00:30.980302+00:00 0:00:01.019390 443733 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T23:00:27.941940+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-05T23:00:00+00:00 PythonOperator 2023-11-06T23:00:08.089818+00:00 2023-11-06T23:00:09.139951+00:00 0:00:01.050133 443730 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T23:00:05.927418+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-04T23:00:00+00:00 EmrJobFlowSensor 2023-11-05T23:00:48.745636+00:00 2023-11-05T23:10:50.799742+00:00 0:10:02.054106 443233 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T23:00:45.248010+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T23:00:27.322698+00:00 2023-11-05T23:00:28.239250+00:00 0:00:00.916552 443232 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T23:00:25.229641+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-04T23:00:00+00:00 PythonOperator 2023-11-05T23:00:06.168414+00:00 2023-11-05T23:00:07.328295+00:00 0:00:01.159881 443229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T23:00:03.264749+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-03T23:00:00+00:00 EmrJobFlowSensor 2023-11-04T23:01:05.487815+00:00 2023-11-04T23:11:07.203387+00:00 0:10:01.715572 442785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T23:01:03.595802+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T23:00:43.684774+00:00 2023-11-04T23:00:44.514032+00:00 0:00:00.829258 442783 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T23:00:41.641635+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-03T23:00:00+00:00 PythonOperator 2023-11-04T23:00:23.506828+00:00 2023-11-04T23:00:24.539355+00:00 0:00:01.032527 442781 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T23:00:21.559315+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-02T23:00:00+00:00 EmrJobFlowSensor 2023-11-03T23:01:02.554751+00:00 2023-11-03T23:11:04.381647+00:00 0:10:01.826896 442344 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T23:01:00.433174+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T23:00:40.215242+00:00 2023-11-03T23:00:41.143102+00:00 0:00:00.927860 442342 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T23:00:38.339533+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-02T23:00:00+00:00 PythonOperator 2023-11-03T23:00:20.236818+00:00 2023-11-03T23:00:21.278849+00:00 0:00:01.042031 442339 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T23:00:18.323567+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-01T23:00:00+00:00 EmrJobFlowSensor 2023-11-02T23:00:51.898455+00:00 2023-11-02T23:10:53.575884+00:00 0:10:01.677429 441877 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T23:00:49.836603+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T23:00:31.350900+00:00 2023-11-02T23:00:32.533945+00:00 0:00:01.183045 441874 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T23:00:27.815864+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-01T23:00:00+00:00 PythonOperator 2023-11-02T23:00:10.617958+00:00 2023-11-02T23:00:11.669350+00:00 0:00:01.051392 441872 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T23:00:07.798299+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-31T23:00:00+00:00 EmrJobFlowSensor 2023-11-01T23:00:47.911464+00:00 2023-11-01T23:10:49.721251+00:00 0:10:01.809787 441407 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-01T23:00:45.955200+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-31T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-01T23:00:27.838752+00:00 2023-11-01T23:00:28.688432+00:00 0:00:00.849680 441406 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-01T23:00:25.945108+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-31T23:00:00+00:00 PythonOperator 2023-11-01T23:00:05.932668+00:00 2023-11-01T23:00:06.999449+00:00 0:00:01.066781 441404 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-01T23:00:03.918301+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-30T23:00:00+00:00 EmrJobFlowSensor 2023-10-31T23:00:48.425485+00:00 2023-10-31T23:11:50.207476+00:00 0:11:01.781991 441054 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-31T23:00:46.472813+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-31T23:00:28.310698+00:00 2023-10-31T23:00:29.056469+00:00 0:00:00.745771 441053 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-31T23:00:26.453451+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-30T23:00:00+00:00 PythonOperator 2023-10-31T23:00:06.428100+00:00 2023-10-31T23:00:07.403912+00:00 0:00:00.975812 441051 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-31T23:00:04.432345+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-29T23:00:00+00:00 EmrJobFlowSensor 2023-10-30T23:00:58.552594+00:00 2023-10-30T23:11:00.258405+00:00 0:10:01.705811 440696 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-30T23:00:56.460236+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T23:00:38.503781+00:00 2023-10-30T23:00:39.375192+00:00 0:00:00.871411 440695 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-30T23:00:36.530370+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-29T23:00:00+00:00 PythonOperator 2023-10-30T23:00:16.423775+00:00 2023-10-30T23:00:17.423458+00:00 0:00:00.999683 440693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-30T23:00:14.375849+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-28T23:00:00+00:00 EmrJobFlowSensor 2023-10-29T23:00:48.326767+00:00 2023-10-29T23:10:50.073144+00:00 0:10:01.746377 440344 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-29T23:00:46.402872+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-29T23:00:28.400193+00:00 2023-10-29T23:00:29.219929+00:00 0:00:00.819736 440343 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-29T23:00:26.387734+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-28T23:00:00+00:00 PythonOperator 2023-10-29T23:00:06.545117+00:00 2023-10-29T23:00:07.634297+00:00 0:00:01.089180 440341 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-29T23:00:04.368484+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-27T23:00:00+00:00 EmrJobFlowSensor 2023-10-28T23:00:56.304438+00:00 2023-10-28T23:10:57.964949+00:00 0:10:01.660511 439988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-28T23:00:54.455177+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-28T23:00:36.366206+00:00 2023-10-28T23:00:37.194099+00:00 0:00:00.827893 439987 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-28T23:00:34.436444+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-27T23:00:00+00:00 PythonOperator 2023-10-28T23:00:16.355452+00:00 2023-10-28T23:00:17.430818+00:00 0:00:01.075366 439986 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-28T23:00:12.420811+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-26T23:00:00+00:00 EmrJobFlowSensor 2023-10-27T23:01:55.622590+00:00 2023-10-27T23:11:57.381330+00:00 0:10:01.758740 439647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-27T23:01:53.685028+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-27T23:01:33.552022+00:00 2023-10-27T23:01:34.457510+00:00 0:00:00.905488 439646 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-27T23:01:31.663904+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-26T23:00:00+00:00 PythonOperator 2023-10-27T23:01:13.529890+00:00 2023-10-27T23:01:14.508068+00:00 0:00:00.978178 439645 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-27T23:01:11.648226+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-25T23:00:00+00:00 EmrJobFlowSensor 2023-10-26T23:00:52.788150+00:00 2023-10-26T23:11:54.727160+00:00 0:11:01.939010 439289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-26T23:00:50.936908+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-26T23:00:30.998065+00:00 2023-10-26T23:00:32.165966+00:00 0:00:01.167901 439288 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-26T23:00:28.962067+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-25T23:00:00+00:00 PythonOperator 2023-10-26T23:00:09.030895+00:00 2023-10-26T23:00:10.054348+00:00 0:00:01.023453 439286 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-26T23:00:06.901223+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-24T23:00:00+00:00 EmrJobFlowSensor 2023-10-25T23:01:18.204180+00:00 2023-10-25T23:11:19.977118+00:00 0:10:01.772938 438939 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-25T23:01:16.240294+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-25T23:00:58.152229+00:00 2023-10-25T23:00:59.068986+00:00 0:00:00.916757 438938 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-25T23:00:56.220652+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-24T23:00:00+00:00 PythonOperator 2023-10-25T23:00:36.346770+00:00 2023-10-25T23:00:37.447070+00:00 0:00:01.100300 438936 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-25T23:00:34.201848+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-23T23:00:00+00:00 EmrJobFlowSensor 2023-10-24T23:00:56.797857+00:00 2023-10-24T23:11:58.709150+00:00 0:11:01.911293 438587 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-24T23:00:54.849892+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-24T23:00:34.699124+00:00 2023-10-24T23:00:35.476741+00:00 0:00:00.777617 438586 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-24T23:00:32.775217+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-23T23:00:00+00:00 PythonOperator 2023-10-24T23:00:14.727610+00:00 2023-10-24T23:00:15.694398+00:00 0:00:00.966788 438585 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-24T23:00:12.755383+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-22T23:00:00+00:00 EmrJobFlowSensor 2023-10-23T23:01:03.129248+00:00 2023-10-23T23:11:04.822243+00:00 0:10:01.692995 438241 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-23T23:01:01.234027+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-23T23:00:43.110881+00:00 2023-10-23T23:00:43.915221+00:00 0:00:00.804340 438240 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-23T23:00:41.213885+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-22T23:00:00+00:00 PythonOperator 2023-10-23T23:00:21.136246+00:00 2023-10-23T23:00:22.090741+00:00 0:00:00.954495 438239 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-23T23:00:19.195055+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-21T23:00:00+00:00 EmrJobFlowSensor 2023-10-22T23:00:48.719858+00:00 2023-10-22T23:10:50.445387+00:00 0:10:01.725529 437888 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-22T23:00:46.764629+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-22T23:00:28.738165+00:00 2023-10-22T23:00:29.607166+00:00 0:00:00.869001 437887 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-22T23:00:26.744582+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-21T23:00:00+00:00 PythonOperator 2023-10-22T23:00:06.708999+00:00 2023-10-22T23:00:07.748028+00:00 0:00:01.039029 437886 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-22T23:00:04.733210+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-20T23:00:00+00:00 EmrJobFlowSensor 2023-10-21T23:00:51.605254+00:00 2023-10-21T23:11:53.466260+00:00 0:11:01.861006 437539 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-21T23:00:49.629164+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-21T23:00:31.383532+00:00 2023-10-21T23:00:32.118173+00:00 0:00:00.734641 437538 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-21T23:00:29.527280+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-20T23:00:00+00:00 PythonOperator 2023-10-21T23:00:09.616699+00:00 2023-10-21T23:00:10.627407+00:00 0:00:01.010708 437537 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-21T23:00:07.500320+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-19T23:00:00+00:00 EmrJobFlowSensor 2023-10-20T23:00:59.877611+00:00 2023-10-20T23:11:01.685295+00:00 0:10:01.807684 437194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-20T23:00:58.020206+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-20T23:00:39.908980+00:00 2023-10-20T23:00:40.779744+00:00 0:00:00.870764 437193 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-20T23:00:38.004720+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-19T23:00:00+00:00 PythonOperator 2023-10-20T23:00:18.432159+00:00 2023-10-20T23:00:19.451570+00:00 0:00:01.019411 437191 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-20T23:00:15.986664+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-18T23:00:00+00:00 EmrJobFlowSensor 2023-10-19T23:01:05.841498+00:00 2023-10-19T23:11:07.600218+00:00 0:10:01.758720 436840 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-19T23:01:03.913237+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-19T23:00:43.775981+00:00 2023-10-19T23:00:44.570237+00:00 0:00:00.794256 436839 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-19T23:00:41.888784+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-18T23:00:00+00:00 PythonOperator 2023-10-19T23:00:24.156332+00:00 2023-10-19T23:00:25.140466+00:00 0:00:00.984134 436838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-19T23:00:21.871899+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-17T23:00:00+00:00 EmrJobFlowSensor 2023-10-18T23:02:02.373142+00:00 2023-10-18T23:12:04.201862+00:00 0:10:01.828720 436481 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-18T23:02:00.383390+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-18T23:01:40.320581+00:00 2023-10-18T23:01:41.167027+00:00 0:00:00.846446 436480 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-18T23:01:38.364953+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-17T23:00:00+00:00 PythonOperator 2023-10-18T23:01:20.710738+00:00 2023-10-18T23:01:21.835909+00:00 0:00:01.125171 436478 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-18T23:01:18.347076+00:00 2 default_pool