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 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
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-16T23:00:00+00:00 EmrJobFlowSensor 2023-10-17T23:01:02.092865+00:00 2023-10-17T23:11:04.115938+00:00 0:10:02.023073 436115 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-17T23:01:00.152353+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-17T23:00:41.978995+00:00 2023-10-17T23:00:43.065358+00:00 0:00:01.086363 436114 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-17T23:00:40.078725+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-16T23:00:00+00:00 PythonOperator 2023-10-17T23:00:20.029431+00:00 2023-10-17T23:00:20.915532+00:00 0:00:00.886101 436112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-17T23:00:18.056447+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-15T23:00:00+00:00 EmrJobFlowSensor 2023-10-16T23:00:49.036939+00:00 2023-10-16T23:11:51.011397+00:00 0:11:01.974458 435750 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-16T23:00:46.899674+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-16T23:00:28.783717+00:00 2023-10-16T23:00:29.641528+00:00 0:00:00.857811 435749 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-16T23:00:26.880948+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-15T23:00:00+00:00 PythonOperator 2023-10-16T23:00:07.285628+00:00 2023-10-16T23:00:08.822405+00:00 0:00:01.536777 435747 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-16T23:00:04.862915+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-14T23:00:00+00:00 EmrJobFlowSensor 2023-10-15T23:01:05.365670+00:00 2023-10-15T23:13:07.456835+00:00 0:12:02.091165 435391 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-15T23:01:03.244661+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-15T23:00:45.422258+00:00 2023-10-15T23:00:46.454753+00:00 0:00:01.032495 435390 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-15T23:00:43.226531+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-14T23:00:00+00:00 PythonOperator 2023-10-15T23:00:23.446420+00:00 2023-10-15T23:00:24.569523+00:00 0:00:01.123103 435389 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-15T23:00:21.204946+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-13T23:00:00+00:00 EmrJobFlowSensor 2023-10-14T23:00:45.805116+00:00 2023-10-14T23:12:47.980634+00:00 0:12:02.175518 435041 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-14T23:00:43.669874+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-14T23:00:25.775141+00:00 2023-10-14T23:00:26.799528+00:00 0:00:01.024387 435040 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-14T23:00:23.650641+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-13T23:00:00+00:00 PythonOperator 2023-10-14T23:00:03.955989+00:00 2023-10-14T23:00:04.999615+00:00 0:00:01.043626 435038 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-14T23:00:01.631035+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-12T23:00:00+00:00 EmrJobFlowSensor 2023-10-13T23:00:55.274521+00:00 2023-10-13T23:12:57.335130+00:00 0:12:02.060609 434704 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-13T23:00:53.351805+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-13T23:00:33.456378+00:00 2023-10-13T23:00:34.553040+00:00 0:00:01.096662 434703 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-13T23:00:31.332960+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-12T23:00:00+00:00 PythonOperator 2023-10-13T23:00:11.839000+00:00 2023-10-13T23:00:12.971105+00:00 0:00:01.132105 434701 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-13T23:00:09.365261+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-11T23:00:00+00:00 EmrJobFlowSensor 2023-10-12T23:01:21.973074+00:00 2023-10-12T23:11:23.795585+00:00 0:10:01.822511 434341 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-12T23:01:19.763859+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-12T23:00:59.705494+00:00 2023-10-12T23:01:00.657232+00:00 0:00:00.951738 434340 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-12T23:00:57.742619+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-11T23:00:00+00:00 PythonOperator 2023-10-12T23:00:39.949286+00:00 2023-10-12T23:00:41.061318+00:00 0:00:01.112032 434339 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-12T23:00:37.725322+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-10T23:00:00+00:00 EmrJobFlowSensor 2023-10-11T23:00:57.648325+00:00 2023-10-11T23:12:59.792918+00:00 0:12:02.144593 433987 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-11T23:00:55.440870+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-11T23:00:37.371739+00:00 2023-10-11T23:00:38.076861+00:00 0:00:00.705122 433986 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-11T23:00:35.423220+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-10T23:00:00+00:00 PythonOperator 2023-10-11T23:00:15.842670+00:00 2023-10-11T23:00:16.911702+00:00 0:00:01.069032 433984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-11T23:00:13.400131+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-09T23:00:00+00:00 EmrJobFlowSensor 2023-10-10T23:00:58.084016+00:00 2023-10-10T23:12:00.095072+00:00 0:11:02.011056 433639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-10T23:00:55.794966+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-10T23:00:36.024152+00:00 2023-10-10T23:00:37.045415+00:00 0:00:01.021263 433638 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-10T23:00:33.773274+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-09T23:00:00+00:00 PythonOperator 2023-10-10T23:00:16.024169+00:00 2023-10-10T23:00:16.952884+00:00 0:00:00.928715 433636 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-10T23:00:13.806523+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-08T23:00:00+00:00 EmrJobFlowSensor 2023-10-09T23:00:54.335426+00:00 2023-10-09T23:11:56.515775+00:00 0:11:02.180349 433282 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-09T23:00:52.202980+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-09T23:00:32.379987+00:00 2023-10-09T23:00:33.363582+00:00 0:00:00.983595 433281 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-09T23:00:30.237523+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-08T23:00:00+00:00 PythonOperator 2023-10-09T23:00:12.505596+00:00 2023-10-09T23:00:14.343308+00:00 0:00:01.837712 433279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-09T23:00:10.164691+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-07T23:00:00+00:00 EmrJobFlowSensor 2023-10-08T23:00:56.291386+00:00 2023-10-08T23:12:58.505921+00:00 0:12:02.214535 432924 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-08T23:00:53.949731+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-08T23:00:37.359859+00:00 2023-10-08T23:00:38.232130+00:00 0:00:00.872271 432923 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-08T23:00:33.962458+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-07T23:00:00+00:00 PythonOperator 2023-10-08T23:00:14.247762+00:00 2023-10-08T23:00:15.354510+00:00 0:00:01.106748 432921 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-08T23:00:11.897282+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-06T23:00:00+00:00 EmrJobFlowSensor 2023-10-07T23:00:51.963545+00:00 2023-10-07T23:11:53.925811+00:00 0:11:01.962266 432573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-07T23:00:49.831577+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-07T23:00:31.771336+00:00 2023-10-07T23:00:32.879417+00:00 0:00:01.108081 432572 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-07T23:00:29.812393+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-06T23:00:00+00:00 PythonOperator 2023-10-07T23:00:10.285870+00:00 2023-10-07T23:00:11.516378+00:00 0:00:01.230508 432570 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-07T23:00:07.792437+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-05T23:00:00+00:00 EmrJobFlowSensor 2023-10-06T23:01:04.926333+00:00 2023-10-06T23:11:06.724496+00:00 0:10:01.798163 432219 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-06T23:01:02.870654+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-06T23:00:43.180812+00:00 2023-10-06T23:00:44.296303+00:00 0:00:01.115491 432218 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-06T23:00:40.907512+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-05T23:00:00+00:00 PythonOperator 2023-10-06T23:00:23.035663+00:00 2023-10-06T23:00:24.138062+00:00 0:00:01.102399 432217 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-06T23:00:20.888675+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-04T23:00:00+00:00 EmrJobFlowSensor 2023-10-05T23:01:00.545674+00:00 2023-10-05T23:13:02.663527+00:00 0:12:02.117853 431842 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-05T23:00:58.331805+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-05T23:00:38.581778+00:00 2023-10-05T23:00:39.744948+00:00 0:00:01.163170 431841 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-05T23:00:36.312154+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-04T23:00:00+00:00 PythonOperator 2023-10-05T23:00:18.617411+00:00 2023-10-05T23:00:19.694964+00:00 0:00:01.077553 431840 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-05T23:00:16.293291+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-03T23:00:00+00:00 EmrJobFlowSensor 2023-10-04T23:01:06.105302+00:00 2023-10-04T23:11:07.908465+00:00 0:10:01.803163 431478 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-04T23:01:03.729075+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-04T23:00:37.688603+00:00 2023-10-04T23:00:38.575401+00:00 0:00:00.886798 431476 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-04T23:00:35.534114+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-03T23:00:00+00:00 PythonOperator 2023-10-04T23:00:15.612202+00:00 2023-10-04T23:00:16.820559+00:00 0:00:01.208357 431475 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-04T23:00:13.511659+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-02T23:00:00+00:00 EmrJobFlowSensor 2023-10-03T23:00:52.415757+00:00 2023-10-03T23:10:54.265397+00:00 0:10:01.849640 431082 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-03T23:00:50.214012+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-03T23:00:30.243631+00:00 2023-10-03T23:00:30.981433+00:00 0:00:00.737802 431081 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-03T23:00:28.190896+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-02T23:00:00+00:00 PythonOperator 2023-10-03T23:00:10.453553+00:00 2023-10-03T23:00:11.512464+00:00 0:00:01.058911 431079 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-03T23:00:08.172543+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-10-01T23:00:00+00:00 EmrJobFlowSensor 2023-10-02T23:00:54.119634+00:00 2023-10-02T23:11:55.968890+00:00 0:11:01.849256 430710 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-02T23:00:52.109587+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-10-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-02T23:00:34.275810+00:00 2023-10-02T23:00:35.261633+00:00 0:00:00.985823 430709 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-02T23:00:32.096188+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-10-01T23:00:00+00:00 PythonOperator 2023-10-02T23:00:12.291217+00:00 2023-10-02T23:00:14.250396+00:00 0:00:01.959179 430707 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-02T23:00:10.055896+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-30T23:00:00+00:00 EmrJobFlowSensor 2023-10-01T23:00:54.475352+00:00 2023-10-01T23:12:56.686916+00:00 0:12:02.211564 430343 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-01T23:00:52.303783+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-01T23:00:32.438784+00:00 2023-10-01T23:00:33.443131+00:00 0:00:01.004347 430342 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-01T23:00:30.264108+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-30T23:00:00+00:00 PythonOperator 2023-10-01T23:00:12.384979+00:00 2023-10-01T23:00:13.465819+00:00 0:00:01.080840 430341 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-01T23:00:10.249637+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-29T23:00:00+00:00 EmrJobFlowSensor 2023-09-30T23:01:04.401759+00:00 2023-09-30T23:11:06.268235+00:00 0:10:01.866476 429979 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-30T23:01:02.090746+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-30T23:00:42.254112+00:00 2023-09-30T23:00:43.230950+00:00 0:00:00.976838 429978 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-30T23:00:40.016128+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-29T23:00:00+00:00 PythonOperator 2023-09-30T23:00:22.277722+00:00 2023-09-30T23:00:23.476320+00:00 0:00:01.198598 429977 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-30T23:00:19.999978+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-28T23:00:00+00:00 EmrJobFlowSensor 2023-09-29T23:01:21.868364+00:00 2023-09-29T23:12:24.107633+00:00 0:11:02.239269 429613 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-29T23:01:19.583194+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-29T23:00:41.251608+00:00 2023-09-29T23:00:42.157227+00:00 0:00:00.905619 429611 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-29T23:00:39.075236+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-28T23:00:00+00:00 PythonOperator 2023-09-29T23:00:21.207465+00:00 2023-09-29T23:00:22.258190+00:00 0:00:01.050725 429610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-29T23:00:19.062355+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-27T23:00:00+00:00 EmrJobFlowSensor 2023-09-28T23:01:29.923356+00:00 2023-09-28T23:11:31.744337+00:00 0:10:01.820981 429229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-28T23:01:27.984783+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-28T23:01:07.926159+00:00 2023-09-28T23:01:08.761633+00:00 0:00:00.835474 429228 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-28T23:01:05.971368+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-27T23:00:00+00:00 PythonOperator 2023-09-28T23:00:48.959217+00:00 2023-09-28T23:00:50.770572+00:00 0:00:01.811355 429226 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-28T23:00:45.957081+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-26T23:00:00+00:00 EmrJobFlowSensor 2023-09-27T23:00:56.336831+00:00 2023-09-27T23:12:58.448592+00:00 0:12:02.111761 428845 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-27T23:00:54.001950+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-27T23:00:36.361514+00:00 2023-09-27T23:00:37.361651+00:00 0:00:01.000137 428844 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-27T23:00:33.996852+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-26T23:00:00+00:00 PythonOperator 2023-09-27T23:00:14.354720+00:00 2023-09-27T23:00:15.478866+00:00 0:00:01.124146 428842 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-27T23:00:11.911985+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-25T23:00:00+00:00 EmrJobFlowSensor 2023-09-26T23:00:59.322590+00:00 2023-09-26T23:11:01.149892+00:00 0:10:01.827302 428475 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-26T23:00:57.133535+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-26T23:00:37.014603+00:00 2023-09-26T23:00:37.853697+00:00 0:00:00.839094 428474 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-26T23:00:35.112015+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-25T23:00:00+00:00 PythonOperator 2023-09-26T23:00:17.080772+00:00 2023-09-26T23:00:18.250485+00:00 0:00:01.169713 428473 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-26T23:00:15.048690+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-24T23:00:00+00:00 EmrJobFlowSensor 2023-09-25T23:01:01.898420+00:00 2023-09-25T23:11:03.826277+00:00 0:10:01.927857 428074 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-25T23:00:59.620906+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-25T23:00:41.780684+00:00 2023-09-25T23:00:42.839708+00:00 0:00:01.059024 428073 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-25T23:00:39.600050+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-24T23:00:00+00:00 PythonOperator 2023-09-25T23:00:19.535520+00:00 2023-09-25T23:00:20.684832+00:00 0:00:01.149312 428072 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-25T23:00:17.527558+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-23T23:00:00+00:00 EmrJobFlowSensor 2023-09-24T23:00:49.362032+00:00 2023-09-24T23:12:51.401963+00:00 0:12:02.039931 427694 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-24T23:00:47.090188+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-24T23:00:27.041767+00:00 2023-09-24T23:00:27.842589+00:00 0:00:00.800822 427693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-24T23:00:25.016076+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-23T23:00:00+00:00 PythonOperator 2023-09-24T23:00:07.287616+00:00 2023-09-24T23:00:08.284287+00:00 0:00:00.996671 427691 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-24T23:00:04.961400+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-22T23:00:00+00:00 EmrJobFlowSensor 2023-09-23T23:00:57.609971+00:00 2023-09-23T23:12:59.779335+00:00 0:12:02.169364 427279 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-23T23:00:55.509703+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-23T23:00:35.535069+00:00 2023-09-23T23:00:36.304689+00:00 0:00:00.769620 427278 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-23T23:00:33.510997+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-22T23:00:00+00:00 PythonOperator 2023-09-23T23:00:15.531793+00:00 2023-09-23T23:00:16.661484+00:00 0:00:01.129691 427276 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-23T23:00:13.430888+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-21T23:00:00+00:00 EmrJobFlowSensor 2023-09-22T23:00:54.156099+00:00 2023-09-22T23:10:55.937034+00:00 0:10:01.780935 426916 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-22T23:00:51.899171+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-22T23:00:34.078511+00:00 2023-09-22T23:00:34.899462+00:00 0:00:00.820951 426915 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-22T23:00:31.833057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-21T23:00:00+00:00 PythonOperator 2023-09-22T23:00:12.250647+00:00 2023-09-22T23:00:13.344241+00:00 0:00:01.093594 426914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-22T23:00:09.812794+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-20T23:00:00+00:00 EmrJobFlowSensor 2023-09-21T23:00:47.830437+00:00 2023-09-21T23:11:49.674007+00:00 0:11:01.843570 426546 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-21T23:00:45.746603+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-21T23:00:28.035215+00:00 2023-09-21T23:00:28.843111+00:00 0:00:00.807896 426545 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-21T23:00:25.790023+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-20T23:00:00+00:00 PythonOperator 2023-09-21T23:00:05.850139+00:00 2023-09-21T23:00:06.882886+00:00 0:00:01.032747 426543 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-21T23:00:03.706596+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-19T23:00:00+00:00 EmrJobFlowSensor 2023-09-20T23:01:00.010897+00:00 2023-09-20T23:11:01.820840+00:00 0:10:01.809943 426169 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-20T23:00:57.833866+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-20T23:00:40.126825+00:00 2023-09-20T23:00:41.034556+00:00 0:00:00.907731 426168 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-20T23:00:37.890964+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-19T23:00:00+00:00 PythonOperator 2023-09-20T23:00:18.067966+00:00 2023-09-20T23:00:19.097936+00:00 0:00:01.029970 426167 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-20T23:00:15.795377+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-18T23:00:00+00:00 EmrJobFlowSensor 2023-09-19T23:01:01.622010+00:00 2023-09-19T23:12:03.684088+00:00 0:11:02.062078 425801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-19T23:00:59.521700+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-19T23:00:41.647126+00:00 2023-09-19T23:00:42.589056+00:00 0:00:00.941930 425800 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-19T23:00:39.460397+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-18T23:00:00+00:00 PythonOperator 2023-09-19T23:00:19.560166+00:00 2023-09-19T23:00:20.587691+00:00 0:00:01.027525 425799 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-19T23:00:17.499113+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-17T23:00:00+00:00 EmrJobFlowSensor 2023-09-18T23:01:00.396869+00:00 2023-09-18T23:11:02.166843+00:00 0:10:01.769974 425359 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-18T23:00:58.453815+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-18T23:00:40.392387+00:00 2023-09-18T23:00:41.283179+00:00 0:00:00.890792 425358 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-18T23:00:38.436136+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-17T23:00:00+00:00 PythonOperator 2023-09-18T23:00:18.638372+00:00 2023-09-18T23:00:19.668739+00:00 0:00:01.030367 425357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-18T23:00:16.425781+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-16T23:00:00+00:00 EmrJobFlowSensor 2023-09-17T23:00:48.716635+00:00 2023-09-17T23:11:50.716629+00:00 0:11:01.999994 424954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-17T23:00:46.462509+00:00 2 default_pool