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 2023-12-24T23:00:00+00:00 EmrJobFlowSensor 2023-12-25T23:01:02.657351+00:00 2023-12-25T23:12:04.527703+00:00 0:11:01.870352 462075 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T23:01:00.486042+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T23:00:42.092690+00:00 2023-12-25T23:00:42.841756+00:00 0:00:00.749066 462072 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T23:00:40.483045+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-24T23:00:00+00:00 PythonOperator 2023-12-25T23:00:20.021526+00:00 2023-12-25T23:00:21.049212+00:00 0:00:01.027686 462069 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T23:00:18.412671+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-23T23:00:00+00:00 EmrJobFlowSensor 2023-12-24T23:00:58.319903+00:00 2023-12-24T23:11:00.108934+00:00 0:10:01.789031 461645 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T23:00:56.721590+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T23:00:36.811215+00:00 2023-12-24T23:00:37.570713+00:00 0:00:00.759498 461642 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T23:00:34.768048+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-23T23:00:00+00:00 PythonOperator 2023-12-24T23:00:14.691599+00:00 2023-12-24T23:00:16.235925+00:00 0:00:01.544326 461639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T23:00:12.680807+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-22T23:00:00+00:00 EmrJobFlowSensor 2023-12-23T23:00:48.849224+00:00 2023-12-23T23:10:50.685230+00:00 0:10:01.836006 461209 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T23:00:46.739180+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T23:00:28.294986+00:00 2023-12-23T23:00:29.090971+00:00 0:00:00.795985 461206 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T23:00:26.720947+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-22T23:00:00+00:00 PythonOperator 2023-12-23T23:00:06.740175+00:00 2023-12-23T23:00:07.764149+00:00 0:00:01.023974 461203 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T23:00:04.700772+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-21T23:00:00+00:00 EmrJobFlowSensor 2023-12-22T23:00:51.111345+00:00 2023-12-22T23:10:52.823403+00:00 0:10:01.712058 460791 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T23:00:49.485805+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T23:00:29.447733+00:00 2023-12-22T23:00:30.185214+00:00 0:00:00.737481 460788 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T23:00:27.442049+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-21T23:00:00+00:00 PythonOperator 2023-12-22T23:00:09.724193+00:00 2023-12-22T23:00:10.761146+00:00 0:00:01.036953 460785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T23:00:07.419618+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-20T23:00:00+00:00 EmrJobFlowSensor 2023-12-21T23:00:56.240700+00:00 2023-12-21T23:11:58.200289+00:00 0:11:01.959589 460367 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T23:00:54.618497+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T23:00:34.325414+00:00 2023-12-21T23:00:35.095792+00:00 0:00:00.770378 460364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T23:00:32.649720+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-20T23:00:00+00:00 PythonOperator 2023-12-21T23:00:12.953993+00:00 2023-12-21T23:00:13.933876+00:00 0:00:00.979883 460361 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T23:00:10.584180+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-19T23:00:00+00:00 EmrJobFlowSensor 2023-12-20T23:00:56.591281+00:00 2023-12-20T23:10:58.425335+00:00 0:10:01.834054 459927 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T23:00:54.517930+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T23:00:34.444015+00:00 2023-12-20T23:00:35.272754+00:00 0:00:00.828739 459924 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T23:00:32.497778+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-19T23:00:00+00:00 PythonOperator 2023-12-20T23:00:12.542616+00:00 2023-12-20T23:00:14.212900+00:00 0:00:01.670284 459921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T23:00:10.475314+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-18T23:00:00+00:00 EmrJobFlowSensor 2023-12-19T23:01:04.167843+00:00 2023-12-19T23:12:06.133801+00:00 0:11:01.965958 459489 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T23:01:02.474749+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T23:00:42.546893+00:00 2023-12-19T23:00:43.290050+00:00 0:00:00.743157 459486 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T23:00:40.457389+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-18T23:00:00+00:00 PythonOperator 2023-12-19T23:00:22.028868+00:00 2023-12-19T23:00:23.028046+00:00 0:00:00.999178 459483 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T23:00:20.436976+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-17T23:00:00+00:00 EmrJobFlowSensor 2023-12-18T23:00:55.444839+00:00 2023-12-18T23:10:57.368414+00:00 0:10:01.923575 459060 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T23:00:53.368693+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T23:00:35.337931+00:00 2023-12-18T23:00:36.453226+00:00 0:00:01.115295 459057 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T23:00:33.286683+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-17T23:00:00+00:00 PythonOperator 2023-12-18T23:00:13.011174+00:00 2023-12-18T23:00:14.012641+00:00 0:00:01.001467 459054 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T23:00:11.260893+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-16T23:00:00+00:00 EmrJobFlowSensor 2023-12-17T23:00:50.195277+00:00 2023-12-17T23:11:52.117112+00:00 0:11:01.921835 458623 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T23:00:48.593917+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T23:00:28.194937+00:00 2023-12-17T23:00:28.975603+00:00 0:00:00.780666 458620 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T23:00:26.536839+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-16T23:00:00+00:00 PythonOperator 2023-12-17T23:00:08.238135+00:00 2023-12-17T23:00:09.236494+00:00 0:00:00.998359 458617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T23:00:06.515947+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-15T23:00:00+00:00 EmrJobFlowSensor 2023-12-16T23:00:54.232886+00:00 2023-12-16T23:10:56.010684+00:00 0:10:01.777798 458192 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T23:00:52.383983+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T23:00:34.458845+00:00 2023-12-16T23:00:35.229928+00:00 0:00:00.771083 458190 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T23:00:32.363516+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-15T23:00:00+00:00 PythonOperator 2023-12-16T23:00:12.739882+00:00 2023-12-16T23:00:13.725608+00:00 0:00:00.985726 458187 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T23:00:10.359850+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-14T23:00:00+00:00 EmrJobFlowSensor 2023-12-15T23:01:06.555322+00:00 2023-12-15T23:11:08.432279+00:00 0:10:01.876957 457773 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T23:01:04.559596+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T23:00:46.231926+00:00 2023-12-15T23:00:47.037282+00:00 0:00:00.805356 457770 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T23:00:44.541015+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-14T23:00:00+00:00 PythonOperator 2023-12-15T23:00:24.887507+00:00 2023-12-15T23:00:25.832873+00:00 0:00:00.945366 457767 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T23:00:22.523874+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-13T23:00:00+00:00 EmrJobFlowSensor 2023-12-14T23:13:36.636348+00:00 2023-12-14T23:13:37.053578+00:00 0:00:00.417230 457340 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T23:13:34.459441+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T23:00:48.829375+00:00 2023-12-14T23:00:49.740144+00:00 0:00:00.910769 457328 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T23:00:46.779404+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-13T23:00:00+00:00 PythonOperator 2023-12-14T23:00:30.403274+00:00 2023-12-14T23:00:32.205879+00:00 0:00:01.802605 457325 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T23:00:26.758167+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-12T23:00:00+00:00 EmrJobFlowSensor 2023-12-13T23:01:02.495875+00:00 2023-12-13T23:11:04.317201+00:00 0:10:01.821326 456832 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T23:01:00.866288+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T23:00:43.374268+00:00 2023-12-13T23:00:44.127333+00:00 0:00:00.753065 456829 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T23:00:40.847644+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-12T23:00:00+00:00 PythonOperator 2023-12-13T23:00:20.869435+00:00 2023-12-13T23:00:21.827016+00:00 0:00:00.957581 456826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T23:00:18.826547+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-11T23:00:00+00:00 EmrJobFlowSensor 2023-12-12T23:01:07.101328+00:00 2023-12-12T23:11:08.936531+00:00 0:10:01.835203 456279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T23:01:05.120541+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T23:00:25.711702+00:00 2023-12-12T23:00:26.582768+00:00 0:00:00.871066 456275 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T23:00:23.690016+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-11T23:00:00+00:00 PythonOperator 2023-12-12T23:00:05.860648+00:00 2023-12-12T23:00:06.842332+00:00 0:00:00.981684 456272 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T23:00:03.671410+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-10T23:00:00+00:00 EmrJobFlowSensor 2023-12-11T23:00:51.291523+00:00 2023-12-11T23:10:53.150639+00:00 0:10:01.859116 455742 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T23:00:49.549572+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T23:00:31.620203+00:00 2023-12-11T23:00:32.373432+00:00 0:00:00.753229 455740 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T23:00:29.483590+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-10T23:00:00+00:00 PythonOperator 2023-12-11T23:00:09.411028+00:00 2023-12-11T23:00:10.331889+00:00 0:00:00.920861 455736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T23:00:07.483238+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-09T23:00:00+00:00 EmrJobFlowSensor 2023-12-10T23:01:05.948517+00:00 2023-12-10T23:11:08.027276+00:00 0:10:02.078759 455203 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T23:01:03.964847+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T23:00:43.715310+00:00 2023-12-10T23:00:44.728716+00:00 0:00:01.013406 455200 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T23:00:41.865626+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-09T23:00:00+00:00 PythonOperator 2023-12-10T23:00:23.762003+00:00 2023-12-10T23:00:25.169868+00:00 0:00:01.407865 455197 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T23:00:21.846339+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-08T23:00:00+00:00 EmrJobFlowSensor 2023-12-09T23:01:04.532756+00:00 2023-12-09T23:11:06.236604+00:00 0:10:01.703848 454668 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T23:01:01.962125+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T23:00:41.494216+00:00 2023-12-09T23:00:42.284901+00:00 0:00:00.790685 454665 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T23:00:39.886595+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-08T23:00:00+00:00 PythonOperator 2023-12-09T23:00:21.760413+00:00 2023-12-09T23:00:22.769855+00:00 0:00:01.009442 454662 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T23:00:19.865226+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-07T23:00:00+00:00 EmrJobFlowSensor 2023-12-08T23:00:48.026190+00:00 2023-12-08T23:11:49.891869+00:00 0:11:01.865679 454216 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T23:00:46.306903+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T23:00:28.423776+00:00 2023-12-08T23:00:29.173508+00:00 0:00:00.749732 454214 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T23:00:26.299813+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-07T23:00:00+00:00 PythonOperator 2023-12-08T23:00:06.387602+00:00 2023-12-08T23:00:07.332558+00:00 0:00:00.944956 454211 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T23:00:04.242190+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-06T23:00:00+00:00 EmrJobFlowSensor 2023-12-07T23:00:53.503913+00:00 2023-12-07T23:10:55.303346+00:00 0:10:01.799433 453725 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T23:00:51.477376+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T23:00:31.251111+00:00 2023-12-07T23:00:32.316271+00:00 0:00:01.065160 453722 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T23:00:29.320635+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-06T23:00:00+00:00 PythonOperator 2023-12-07T23:00:10.916660+00:00 2023-12-07T23:00:11.907123+00:00 0:00:00.990463 453719 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T23:00:09.306470+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-05T23:00:00+00:00 EmrJobFlowSensor 2023-12-06T23:00:48.519973+00:00 2023-12-06T23:11:50.439212+00:00 0:11:01.919239 453138 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-06T23:00:46.549893+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-06T23:00:29.017605+00:00 2023-12-06T23:00:30.137549+00:00 0:00:01.119944 453136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-06T23:00:26.530304+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-05T23:00:00+00:00 PythonOperator 2023-12-06T23:00:06.321393+00:00 2023-12-06T23:00:07.292736+00:00 0:00:00.971343 453133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-06T23:00:04.515208+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-04T23:00:00+00:00 EmrJobFlowSensor 2023-12-05T23:00:52.029070+00:00 2023-12-05T23:10:53.777256+00:00 0:10:01.748186 452696 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-05T23:00:50.090505+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-05T23:00:31.724086+00:00 2023-12-05T23:00:32.458225+00:00 0:00:00.734139 452695 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-05T23:00:30.078134+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-04T23:00:00+00:00 PythonOperator 2023-12-05T23:00:10.108566+00:00 2023-12-05T23:00:11.200670+00:00 0:00:01.092104 452694 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-05T23:00:08.010340+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-03T23:00:00+00:00 EmrJobFlowSensor 2023-12-04T23:01:04.780190+00:00 2023-12-04T23:12:06.648268+00:00 0:11:01.868078 452427 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-04T23:01:03.117576+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-04T23:00:43.008642+00:00 2023-12-04T23:00:43.907425+00:00 0:00:00.898783 452426 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-04T23:00:41.094472+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-03T23:00:00+00:00 PythonOperator 2023-12-04T23:00:21.119651+00:00 2023-12-04T23:00:22.291162+00:00 0:00:01.171511 452425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-04T23:00:19.076479+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-02T23:00:00+00:00 EmrJobFlowSensor 2023-12-03T23:00:52.493357+00:00 2023-12-03T23:10:54.256229+00:00 0:10:01.762872 452162 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-03T23:00:50.586513+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-03T23:00:30.104477+00:00 2023-12-03T23:00:30.912363+00:00 0:00:00.807886 452161 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-03T23:00:28.514982+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-02T23:00:00+00:00 PythonOperator 2023-12-03T23:00:08.247295+00:00 2023-12-03T23:00:09.156980+00:00 0:00:00.909685 452160 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-03T23:00:06.494330+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-01T23:00:00+00:00 EmrJobFlowSensor 2023-12-02T23:01:26.190824+00:00 2023-12-02T23:12:28.159452+00:00 0:11:01.968628 451898 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-02T23:01:24.593000+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-02T23:01:04.186136+00:00 2023-12-02T23:01:05.057464+00:00 0:00:00.871328 451897 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-02T23:01:02.572179+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-01T23:00:00+00:00 PythonOperator 2023-12-02T23:00:44.521038+00:00 2023-12-02T23:00:45.447703+00:00 0:00:00.926665 451896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-02T23:00:42.603165+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-30T23:00:00+00:00 EmrJobFlowSensor 2023-12-01T23:00:48.144149+00:00 2023-12-01T23:11:50.145428+00:00 0:11:02.001279 451636 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-01T23:00:46.517893+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-01T23:00:26.459877+00:00 2023-12-01T23:00:27.331500+00:00 0:00:00.871623 451635 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-01T23:00:24.500436+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-30T23:00:00+00:00 PythonOperator 2023-12-01T23:00:04.507269+00:00 2023-12-01T23:00:05.714157+00:00 0:00:01.206888 451634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-01T23:00:02.458575+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-29T23:00:00+00:00 EmrJobFlowSensor 2023-11-30T23:00:48.241447+00:00 2023-11-30T23:11:50.181504+00:00 0:11:01.940057 451367 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-30T23:00:46.622361+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-30T23:00:28.188511+00:00 2023-11-30T23:00:29.035656+00:00 0:00:00.847145 451366 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-30T23:00:26.600797+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-29T23:00:00+00:00 PythonOperator 2023-11-30T23:00:06.412977+00:00 2023-11-30T23:00:07.386676+00:00 0:00:00.973699 451365 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-30T23:00:04.581301+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-28T23:00:00+00:00 EmrJobFlowSensor 2023-11-29T23:00:50.697529+00:00 2023-11-29T23:10:52.600307+00:00 0:10:01.902778 451090 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-29T23:00:48.806434+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-29T23:00:30.406387+00:00 2023-11-29T23:00:31.155240+00:00 0:00:00.748853 451089 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-29T23:00:28.787383+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-28T23:00:00+00:00 PythonOperator 2023-11-29T23:00:08.603273+00:00 2023-11-29T23:00:09.529405+00:00 0:00:00.926132 451088 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-29T23:00:06.767333+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-27T23:00:00+00:00 EmrJobFlowSensor 2023-11-28T23:00:57.254470+00:00 2023-11-28T23:10:59.083937+00:00 0:10:01.829467 450820 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-28T23:00:55.497412+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-28T23:00:35.276802+00:00 2023-11-28T23:00:36.206280+00:00 0:00:00.929478 450819 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-28T23:00:33.483756+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-27T23:00:00+00:00 PythonOperator 2023-11-28T23:00:13.241807+00:00 2023-11-28T23:00:14.197284+00:00 0:00:00.955477 450818 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-28T23:00:11.456981+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-26T23:00:00+00:00 EmrJobFlowSensor 2023-11-27T23:01:00.233938+00:00 2023-11-27T23:12:02.293545+00:00 0:11:02.059607 450549 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-27T23:00:58.554303+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-27T23:00:40.416270+00:00 2023-11-27T23:00:41.252668+00:00 0:00:00.836398 450548 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-27T23:00:38.539068+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-26T23:00:00+00:00 PythonOperator 2023-11-27T23:00:18.817549+00:00 2023-11-27T23:00:19.914402+00:00 0:00:01.096853 450547 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-27T23:00:16.581335+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-25T23:00:00+00:00 EmrJobFlowSensor 2023-11-26T23:00:57.250372+00:00 2023-11-26T23:11:59.187869+00:00 0:11:01.937497 450274 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-26T23:00:55.341037+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-26T23:00:35.240055+00:00 2023-11-26T23:00:36.155239+00:00 0:00:00.915184 450273 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-26T23:00:33.322041+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-25T23:00:00+00:00 PythonOperator 2023-11-26T23:00:11.335756+00:00 2023-11-26T23:00:12.267117+00:00 0:00:00.931361 450272 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-26T23:00:09.356281+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-24T23:00:00+00:00 EmrJobFlowSensor 2023-11-25T23:00:46.299748+00:00 2023-11-25T23:10:48.107075+00:00 0:10:01.807327 450007 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-25T23:00:44.401521+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-25T23:00:24.359047+00:00 2023-11-25T23:00:25.291991+00:00 0:00:00.932944 450006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-25T23:00:22.381512+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-24T23:00:00+00:00 PythonOperator 2023-11-25T23:00:04.076270+00:00 2023-11-25T23:00:04.992165+00:00 0:00:00.915895 450005 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-25T23:00:02.352421+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-23T23:00:00+00:00 EmrJobFlowSensor 2023-11-24T23:00:46.596796+00:00 2023-11-24T23:10:48.355564+00:00 0:10:01.758768 449736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-24T23:00:44.979596+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-24T23:00:26.572362+00:00 2023-11-24T23:00:27.437855+00:00 0:00:00.865493 449735 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-24T23:00:24.907473+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-23T23:00:00+00:00 PythonOperator 2023-11-24T23:00:04.925059+00:00 2023-11-24T23:00:06.202831+00:00 0:00:01.277772 449734 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-24T23:00:02.886469+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-22T23:00:00+00:00 EmrJobFlowSensor 2023-11-23T23:00:59.081796+00:00 2023-11-23T23:11:00.964946+00:00 0:10:01.883150 449466 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-23T23:00:57.461825+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-11-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-23T23:00:37.542629+00:00 2023-11-23T23:00:38.357935+00:00 0:00:00.815306 449465 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-23T23:00:35.485934+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-11-22T23:00:00+00:00 PythonOperator 2023-11-23T23:00:15.421441+00:00 2023-11-23T23:00:16.348558+00:00 0:00:00.927117 449464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-23T23:00:13.473247+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-11-21T23:00:00+00:00 EmrJobFlowSensor 2023-11-22T23:00:59.717797+00:00 2023-11-22T23:12:01.799910+00:00 0:11:02.082113 449194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-22T23:00:57.667826+00:00 2 default_pool