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 03-31T23:00:00+00:00 EmrCreateJobFlowOperator 04-01T23:00:29.613595+00:00 04-01T23:00:30.369927+00:00 0:00:00.756332 507961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T23:00:27.710764+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-31T23:00:00+00:00 PythonOperator 04-01T23:00:09.004996+00:00 04-01T23:00:10.742546+00:00 0:00:01.737550 507957 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T23:00:05.691460+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-30T23:00:00+00:00 EmrJobFlowSensor 03-31T23:12:33.922901+00:00 03-31T23:12:34.352233+00:00 0:00:00.429332 507628 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-31T23:12:31.933075+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-30T23:00:00+00:00 EmrCreateJobFlowOperator 03-31T23:00:30.304815+00:00 03-31T23:00:31.073658+00:00 0:00:00.768843 507618 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-31T23:00:27.306456+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-30T23:00:00+00:00 PythonOperator 03-31T23:00:09.232484+00:00 03-31T23:00:10.377934+00:00 0:00:01.145450 507614 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-31T23:00:07.291570+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-29T23:00:00+00:00 EmrJobFlowSensor 03-30T23:12:20.832768+00:00 03-30T23:12:21.557482+00:00 0:00:00.724714 507289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-30T23:12:17.507036+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-29T23:00:00+00:00 EmrCreateJobFlowOperator 03-30T23:00:30.043741+00:00 03-30T23:00:30.908818+00:00 0:00:00.865077 507279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-30T23:00:26.891887+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-29T23:00:00+00:00 PythonOperator 03-30T23:00:08.563526+00:00 03-30T23:00:10.824320+00:00 0:00:02.260794 507276 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-30T23:00:04.872995+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-28T23:00:00+00:00 EmrJobFlowSensor 03-29T23:00:51.765356+00:00 03-29T23:10:53.473942+00:00 0:10:01.708586 506946 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-29T23:00:49.861223+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-28T23:00:00+00:00 EmrCreateJobFlowOperator 03-29T23:00:29.820371+00:00 03-29T23:00:30.875456+00:00 0:00:01.055085 506942 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-29T23:00:27.841565+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-28T23:00:00+00:00 PythonOperator 03-29T23:00:07.902131+00:00 03-29T23:00:09.834312+00:00 0:00:01.932181 506938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-29T23:00:05.824181+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-27T23:00:00+00:00 EmrJobFlowSensor 03-28T23:01:05.459905+00:00 03-28T23:12:07.315621+00:00 0:11:01.855716 506615 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-28T23:01:03.618969+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-27T23:00:00+00:00 EmrCreateJobFlowOperator 03-28T23:00:43.868943+00:00 03-28T23:00:44.577648+00:00 0:00:00.708705 506612 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-28T23:00:41.613168+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-27T23:00:00+00:00 PythonOperator 03-28T23:00:22.466230+00:00 03-28T23:00:23.601027+00:00 0:00:01.134797 506609 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-28T23:00:19.584189+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-26T23:00:00+00:00 EmrJobFlowSensor 03-27T23:12:57.211275+00:00 03-27T23:12:57.634414+00:00 0:00:00.423139 506287 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-27T23:12:55.261971+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-26T23:00:00+00:00 EmrCreateJobFlowOperator 03-27T23:00:38.296802+00:00 03-27T23:00:39.346017+00:00 0:00:01.049215 506277 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-27T23:00:34.610482+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-26T23:00:00+00:00 PythonOperator 03-27T23:00:17.177053+00:00 03-27T23:00:19.523665+00:00 0:00:02.346612 506273 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-27T23:00:12.593382+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-25T23:00:00+00:00 EmrJobFlowSensor 03-26T23:00:50.715355+00:00 03-26T23:11:52.657831+00:00 0:11:01.942476 505946 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-26T23:00:48.749808+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-25T23:00:00+00:00 EmrCreateJobFlowOperator 03-26T23:00:30.423074+00:00 03-26T23:00:31.458574+00:00 0:00:01.035500 505943 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-26T23:00:26.733266+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-25T23:00:00+00:00 PythonOperator 03-26T23:00:09.113592+00:00 03-26T23:00:10.178961+00:00 0:00:01.065369 505940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-26T23:00:06.714004+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-24T23:00:00+00:00 EmrJobFlowSensor 03-25T23:00:53.000787+00:00 03-25T23:11:54.789097+00:00 0:11:01.788310 505636 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-25T23:00:51.056668+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-24T23:00:00+00:00 EmrCreateJobFlowOperator 03-25T23:00:34.262535+00:00 03-25T23:00:35.285528+00:00 0:00:01.022993 505634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-25T23:00:31.029953+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-24T23:00:00+00:00 PythonOperator 03-25T23:00:11.309924+00:00 03-25T23:00:12.480645+00:00 0:00:01.170721 505631 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-25T23:00:09.008968+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-23T23:00:00+00:00 EmrJobFlowSensor 03-24T23:01:03.137480+00:00 03-24T23:11:04.890616+00:00 0:10:01.753136 505393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-24T23:01:01.170444+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-23T23:00:00+00:00 EmrCreateJobFlowOperator 03-24T23:00:41.099984+00:00 03-24T23:00:41.788543+00:00 0:00:00.688559 505391 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-24T23:00:39.150288+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-23T23:00:00+00:00 PythonOperator 03-24T23:00:19.120795+00:00 03-24T23:00:20.301548+00:00 0:00:01.180753 505389 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-24T23:00:17.130894+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-22T23:00:00+00:00 EmrJobFlowSensor 03-23T23:12:22.482292+00:00 03-23T23:12:22.913770+00:00 0:00:00.431478 505107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-23T23:12:20.543026+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-22T23:00:00+00:00 EmrCreateJobFlowOperator 03-23T23:00:40.838265+00:00 03-23T23:00:41.571305+00:00 0:00:00.733040 505097 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-23T23:00:38.847772+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-22T23:00:00+00:00 PythonOperator 03-23T23:00:18.816879+00:00 03-23T23:00:19.873762+00:00 0:00:01.056883 505093 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-23T23:00:16.829260+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-21T23:00:00+00:00 EmrJobFlowSensor 03-22T23:01:05.853376+00:00 03-22T23:11:07.938783+00:00 0:10:02.085407 504761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-22T23:01:02.685701+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-21T23:00:00+00:00 EmrCreateJobFlowOperator 03-22T23:00:43.854771+00:00 03-22T23:00:44.835280+00:00 0:00:00.980509 504757 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-22T23:00:40.661712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-21T23:00:00+00:00 PythonOperator 03-22T23:00:23.769131+00:00 03-22T23:00:25.417637+00:00 0:00:01.648506 504755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-22T23:00:20.647638+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-20T23:00:00+00:00 EmrJobFlowSensor 03-21T23:01:02.256022+00:00 03-21T23:11:03.982295+00:00 0:10:01.726273 504434 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-21T23:01:00.219591+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-20T23:00:00+00:00 EmrCreateJobFlowOperator 03-21T23:00:41.460479+00:00 03-21T23:00:42.474933+00:00 0:00:01.014454 504431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-21T23:00:38.200171+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-20T23:00:00+00:00 PythonOperator 03-21T23:00:18.090004+00:00 03-21T23:00:19.131137+00:00 0:00:01.041133 504428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-21T23:00:16.183087+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-19T23:00:00+00:00 EmrJobFlowSensor 03-20T23:01:06.499707+00:00 03-20T23:12:08.297344+00:00 0:11:01.797637 504101 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-20T23:01:04.610093+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-19T23:00:00+00:00 EmrCreateJobFlowOperator 03-20T23:00:42.527842+00:00 03-20T23:00:43.200868+00:00 0:00:00.673026 504098 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-20T23:00:40.584722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-19T23:00:00+00:00 PythonOperator 03-20T23:00:22.508922+00:00 03-20T23:00:23.567793+00:00 0:00:01.058871 504095 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-20T23:00:20.574090+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-18T23:00:00+00:00 EmrJobFlowSensor 03-19T23:01:22.769115+00:00 03-19T23:12:24.728897+00:00 0:11:01.959782 503767 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-19T23:01:20.858879+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-18T23:00:00+00:00 EmrCreateJobFlowOperator 03-19T23:00:41.586348+00:00 03-19T23:00:42.468965+00:00 0:00:00.882617 503761 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-19T23:00:39.648209+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-18T23:00:00+00:00 PythonOperator 03-19T23:00:19.659170+00:00 03-19T23:00:20.789114+00:00 0:00:01.129944 503757 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-19T23:00:17.631367+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-17T23:00:00+00:00 EmrJobFlowSensor 03-18T23:00:59.304696+00:00 03-18T23:12:01.168570+00:00 0:11:01.863874 503437 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-18T23:00:57.324215+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-17T23:00:00+00:00 EmrCreateJobFlowOperator 03-18T23:00:39.165506+00:00 03-18T23:00:39.890279+00:00 0:00:00.724773 503434 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-18T23:00:37.306214+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-17T23:00:00+00:00 PythonOperator 03-18T23:00:17.210722+00:00 03-18T23:00:18.382976+00:00 0:00:01.172254 503431 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-18T23:00:15.286429+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-16T23:00:00+00:00 EmrJobFlowSensor 03-17T23:00:54.370300+00:00 03-17T23:10:56.589486+00:00 0:10:02.219186 503106 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-17T23:00:51.117257+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-16T23:00:00+00:00 EmrCreateJobFlowOperator 03-17T23:00:30.960049+00:00 03-17T23:00:31.682393+00:00 0:00:00.722344 503104 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-17T23:00:29.098327+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-16T23:00:00+00:00 PythonOperator 03-17T23:00:11.132236+00:00 03-17T23:00:12.220722+00:00 0:00:01.088486 503100 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-17T23:00:09.075059+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-15T23:00:00+00:00 EmrJobFlowSensor 03-16T23:11:53.842224+00:00 03-16T23:11:54.527224+00:00 0:00:00.685000 502781 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-16T23:11:50.611138+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-15T23:00:00+00:00 EmrCreateJobFlowOperator 03-16T23:00:35.908316+00:00 03-16T23:00:36.659418+00:00 0:00:00.751102 502771 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-16T23:00:34.006434+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-15T23:00:00+00:00 PythonOperator 03-16T23:00:13.933620+00:00 03-16T23:00:14.990143+00:00 0:00:01.056523 502767 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-16T23:00:11.989856+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-14T23:00:00+00:00 EmrJobFlowSensor 03-15T23:12:28.711437+00:00 03-15T23:12:29.347896+00:00 0:00:00.636459 502445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-15T23:12:26.772981+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-14T23:00:00+00:00 EmrCreateJobFlowOperator 03-15T23:00:30.159666+00:00 03-15T23:00:30.834048+00:00 0:00:00.674382 502434 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-15T23:00:28.155547+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-14T23:00:00+00:00 PythonOperator 03-15T23:00:09.346089+00:00 03-15T23:00:10.968665+00:00 0:00:01.622576 502431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-15T23:00:06.136206+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-13T23:00:00+00:00 EmrJobFlowSensor 03-14T23:12:57.522299+00:00 03-14T23:12:58.207273+00:00 0:00:00.684974 502115 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-14T23:12:54.325459+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-13T23:00:00+00:00 EmrCreateJobFlowOperator 03-14T23:00:36.839231+00:00 03-14T23:00:37.809391+00:00 0:00:00.970160 502103 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-14T23:00:33.650023+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-13T23:00:00+00:00 PythonOperator 03-14T23:00:13.586525+00:00 03-14T23:00:14.563259+00:00 0:00:00.976734 502100 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-14T23:00:11.637552+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-12T23:00:00+00:00 EmrJobFlowSensor 03-13T23:00:50.818605+00:00 03-13T23:11:53.082599+00:00 0:11:02.263994 501775 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-13T23:00:47.574867+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-12T23:00:00+00:00 EmrCreateJobFlowOperator 03-13T23:00:28.728650+00:00 03-13T23:00:29.710275+00:00 0:00:00.981625 501773 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-13T23:00:25.555431+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-12T23:00:00+00:00 PythonOperator 03-13T23:00:08.865089+00:00 03-13T23:00:11.123531+00:00 0:00:02.258442 501769 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-13T23:00:05.539967+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-11T23:00:00+00:00 EmrJobFlowSensor 03-12T23:00:47.663623+00:00 03-12T23:11:49.324728+00:00 0:11:01.661105 501448 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-12T23:00:45.645365+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-11T23:00:00+00:00 EmrCreateJobFlowOperator 03-12T23:00:28.867888+00:00 03-12T23:00:29.852387+00:00 0:00:00.984499 501445 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-12T23:00:25.627667+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-11T23:00:00+00:00 PythonOperator 03-12T23:00:05.647471+00:00 03-12T23:00:06.677969+00:00 0:00:01.030498 501441 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-12T23:00:03.606627+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-10T23:00:00+00:00 EmrJobFlowSensor 03-11T23:01:05.707235+00:00 03-11T23:12:07.579321+00:00 0:11:01.872086 501118 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-11T23:01:03.750181+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-10T23:00:00+00:00 EmrCreateJobFlowOperator 03-11T23:00:43.710847+00:00 03-11T23:00:44.611773+00:00 0:00:00.900926 501115 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-11T23:00:41.731623+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-10T23:00:00+00:00 PythonOperator 03-11T23:00:22.924146+00:00 03-11T23:00:24.997233+00:00 0:00:02.073087 501111 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-11T23:00:19.711552+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-09T23:00:00+00:00 EmrJobFlowSensor 03-10T23:01:06.243506+00:00 03-10T23:12:08.422337+00:00 0:11:02.178831 500778 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-10T23:01:03.019789+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-09T23:00:00+00:00 EmrCreateJobFlowOperator 03-10T23:00:44.318818+00:00 03-10T23:00:45.358676+00:00 0:00:01.039858 500775 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-10T23:00:41.000492+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-09T23:00:00+00:00 PythonOperator 03-10T23:00:20.986579+00:00 03-10T23:00:21.990208+00:00 0:00:01.003629 500771 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-10T23:00:18.985042+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-08T23:00:00+00:00 EmrJobFlowSensor 03-09T23:12:22.614803+00:00 03-09T23:12:23.029692+00:00 0:00:00.414889 500454 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-09T23:12:20.662577+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-08T23:00:00+00:00 EmrCreateJobFlowOperator 03-09T23:00:45.370938+00:00 03-09T23:00:46.373637+00:00 0:00:01.002699 500445 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-09T23:00:42.053827+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-08T23:00:00+00:00 PythonOperator 03-09T23:00:21.929087+00:00 03-09T23:00:23.357434+00:00 0:00:01.428347 500442 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-09T23:00:20.034097+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-07T23:00:00+00:00 EmrJobFlowSensor 03-08T23:12:43.678814+00:00 03-08T23:12:44.120088+00:00 0:00:00.441274 500121 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-08T23:12:41.733279+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-07T23:00:00+00:00 EmrCreateJobFlowOperator 03-08T23:00:40.996469+00:00 03-08T23:00:41.666757+00:00 0:00:00.670288 500113 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-08T23:00:39.093845+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-07T23:00:00+00:00 PythonOperator 03-08T23:00:20.310908+00:00 03-08T23:00:21.904360+00:00 0:00:01.593452 500109 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-08T23:00:17.071836+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-06T23:00:00+00:00 EmrJobFlowSensor 03-07T23:01:02.309113+00:00 03-07T23:11:04.497354+00:00 0:10:02.188241 499780 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-07T23:00:58.432692+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-06T23:00:00+00:00 EmrCreateJobFlowOperator 03-07T23:00:38.703644+00:00 03-07T23:00:39.411215+00:00 0:00:00.707571 499777 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-07T23:00:36.414442+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-06T23:00:00+00:00 PythonOperator 03-07T23:00:19.577866+00:00 03-07T23:00:21.505009+00:00 0:00:01.927143 499774 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-07T23:00:16.395857+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-05T23:00:00+00:00 EmrJobFlowSensor 03-06T23:00:54.903990+00:00 03-06T23:11:56.909678+00:00 0:11:02.005688 499452 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-06T23:00:52.982104+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-05T23:00:00+00:00 EmrCreateJobFlowOperator 03-06T23:00:32.927402+00:00 03-06T23:00:33.603087+00:00 0:00:00.675685 499449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-06T23:00:30.965114+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-05T23:00:00+00:00 PythonOperator 03-06T23:00:14.274686+00:00 03-06T23:00:15.888140+00:00 0:00:01.613454 499446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-06T23:00:10.945983+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-04T23:00:00+00:00 EmrJobFlowSensor 03-05T23:00:51.470919+00:00 03-05T23:10:53.186315+00:00 0:10:01.715396 499119 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-05T23:00:49.626288+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-04T23:00:00+00:00 EmrCreateJobFlowOperator 03-05T23:00:31.482888+00:00 03-05T23:00:32.503039+00:00 0:00:01.020151 499117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-05T23:00:27.609450+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-04T23:00:00+00:00 PythonOperator 03-05T23:00:07.654447+00:00 03-05T23:00:09.081448+00:00 0:00:01.427001 499112 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-05T23:00:05.590266+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-03T23:00:00+00:00 EmrJobFlowSensor 03-04T23:00:49.407123+00:00 03-04T23:10:51.452115+00:00 0:10:02.044992 498659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-04T23:00:46.135960+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-03T23:00:00+00:00 EmrCreateJobFlowOperator 03-04T23:00:29.448056+00:00 03-04T23:00:30.506751+00:00 0:00:01.058695 498656 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-04T23:00:24.113383+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-03T23:00:00+00:00 PythonOperator 03-04T23:00:07.457630+00:00 03-04T23:00:09.096475+00:00 0:00:01.638845 498652 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-04T23:00:04.093992+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-02T23:00:00+00:00 EmrJobFlowSensor 03-03T23:12:27.951674+00:00 03-03T23:12:28.409293+00:00 0:00:00.457619 498170 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-03T23:12:25.969609+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-02T23:00:00+00:00 EmrCreateJobFlowOperator 03-03T23:00:40.092554+00:00 03-03T23:00:41.152068+00:00 0:00:01.059514 498158 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-03T23:00:36.136993+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-02T23:00:00+00:00 PythonOperator 03-03T23:00:18.154494+00:00 03-03T23:00:19.140874+00:00 0:00:00.986380 498155 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-03T23:00:16.119655+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-01T23:00:00+00:00 EmrJobFlowSensor 03-02T23:12:39.272794+00:00 03-02T23:12:39.991642+00:00 0:00:00.718848 497667 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-02T23:12:35.957743+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-01T23:00:00+00:00 EmrCreateJobFlowOperator 03-02T23:00:39.770546+00:00 03-02T23:00:40.495008+00:00 0:00:00.724462 497656 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-02T23:00:38.111513+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-01T23:00:00+00:00 PythonOperator 03-02T23:00:20.994568+00:00 03-02T23:00:21.955639+00:00 0:00:00.961071 497654 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-02T23:00:18.094861+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 02-29T23:00:00+00:00 EmrJobFlowSensor 03-01T23:12:51.193968+00:00 03-01T23:12:51.896017+00:00 0:00:00.702049 497173 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-01T23:12:47.964031+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 02-29T23:00:00+00:00 EmrCreateJobFlowOperator 03-01T23:00:47.453079+00:00 03-01T23:00:48.443074+00:00 0:00:00.989995 497162 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 2 default 03-01T23:00:44.154689+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 02-29T23:00:00+00:00 PythonOperator 03-01T23:00:27.379229+00:00 03-01T23:00:28.868176+00:00 0:00:01.488947 497159 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 03-01T23:00:24.138617+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 02-28T23:00:00+00:00 EmrJobFlowSensor 02-29T23:07:27.470670+00:00 02-29T23:10:28.599560+00:00 0:03:01.128890 496672 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 02-29T23:07:24.198509+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 02-28T23:00:00+00:00 EmrCreateJobFlowOperator 02-29T23:00:34.157628+00:00 02-29T23:00:34.933523+00:00 0:00:00.775895 496661 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 02-29T23:00:32.143441+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 02-28T23:00:00+00:00 PythonOperator 02-29T23:00:15.455529+00:00 02-29T23:00:17.436639+00:00 0:00:01.981110 496657 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 02-29T23:00:12.119347+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 02-27T23:00:00+00:00 EmrJobFlowSensor 02-28T23:00:55.348157+00:00 02-28T23:11:57.608437+00:00 0:11:02.260280 496131 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 02-28T23:00:52.153814+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 02-27T23:00:00+00:00 EmrCreateJobFlowOperator 02-28T23:00:32.166397+00:00 02-28T23:00:32.880324+00:00 0:00:00.713927 496128 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 02-28T23:00:30.134652+00:00 2 default_pool