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 07-05T23:00:00+00:00 EmrJobFlowSensor 07-06T23:00:58.176409+00:00 07-06T23:12:00.178929+00:00 0:11:02.002520 569605 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-06T23:00:56.002836+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-05T23:00:00+00:00 EmrCreateJobFlowOperator 07-06T23:00:36.134310+00:00 07-06T23:00:37.192019+00:00 0:00:01.057709 569602 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-06T23:00:33.893844+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-05T23:00:00+00:00 PythonOperator 07-06T23:00:15.267237+00:00 07-06T23:00:16.994342+00:00 0:00:01.727105 569599 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-06T23:00:11.851712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-04T23:00:00+00:00 EmrJobFlowSensor 07-05T23:00:54.319314+00:00 07-05T23:11:56.562552+00:00 0:11:02.243238 569142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-05T23:00:52.098473+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-04T23:00:00+00:00 EmrCreateJobFlowOperator 07-05T23:00:35.500534+00:00 07-05T23:00:36.305171+00:00 0:00:00.804637 569140 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-05T23:00:32.081739+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-04T23:00:00+00:00 PythonOperator 07-05T23:00:11.321536+00:00 07-05T23:00:12.617193+00:00 0:00:01.295657 569136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-05T23:00:08.060285+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-03T23:00:00+00:00 EmrJobFlowSensor 07-04T23:12:30.103528+00:00 07-04T23:12:30.622432+00:00 0:00:00.518904 568692 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-04T23:12:27.477105+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-03T23:00:00+00:00 EmrCreateJobFlowOperator 07-04T23:00:42.488523+00:00 07-04T23:00:43.418453+00:00 0:00:00.929930 568681 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-04T23:00:40.132124+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-03T23:00:00+00:00 PythonOperator 07-04T23:00:18.809523+00:00 07-04T23:00:20.027452+00:00 0:00:01.217929 568678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-04T23:00:16.115755+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-02T23:00:00+00:00 EmrJobFlowSensor 07-03T23:00:54.857798+00:00 07-03T23:11:56.865428+00:00 0:11:02.007630 568204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-03T23:00:52.153900+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-02T23:00:00+00:00 EmrCreateJobFlowOperator 07-03T23:00:30.448849+00:00 07-03T23:00:31.376411+00:00 0:00:00.927562 568201 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-03T23:00:28.133345+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-02T23:00:00+00:00 PythonOperator 07-03T23:00:08.837819+00:00 07-03T23:00:11.035680+00:00 0:00:02.197861 568197 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-03T23:00:06.115663+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-01T23:00:00+00:00 EmrJobFlowSensor 07-02T23:00:54.151253+00:00 07-02T23:11:56.148760+00:00 0:11:01.997507 567746 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-02T23:00:51.879406+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-01T23:00:00+00:00 EmrCreateJobFlowOperator 07-02T23:00:28.385410+00:00 07-02T23:00:29.217247+00:00 0:00:00.831837 567743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-02T23:00:25.858073+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-01T23:00:00+00:00 PythonOperator 07-02T23:00:06.243994+00:00 07-02T23:00:07.608408+00:00 0:00:01.364414 567739 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-02T23:00:03.838021+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-30T23:00:00+00:00 EmrJobFlowSensor 07-01T23:13:01.055388+00:00 07-01T23:13:01.723279+00:00 0:00:00.667891 567282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-01T23:12:58.266786+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-30T23:00:00+00:00 EmrCreateJobFlowOperator 07-01T23:00:37.659579+00:00 07-01T23:00:39.002936+00:00 0:00:01.343357 567269 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-01T23:00:34.251327+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-30T23:00:00+00:00 PythonOperator 07-01T23:00:14.982080+00:00 07-01T23:00:16.228939+00:00 0:00:01.246859 567265 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-01T23:00:12.271076+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-29T23:00:00+00:00 EmrJobFlowSensor 06-30T23:13:03.864466+00:00 06-30T23:13:04.429727+00:00 0:00:00.565261 566815 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-30T23:13:01.557469+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-29T23:00:00+00:00 EmrCreateJobFlowOperator 06-30T23:00:38.212605+00:00 06-30T23:00:39.074890+00:00 0:00:00.862285 566804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-30T23:00:35.881832+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-29T23:00:00+00:00 PythonOperator 06-30T23:00:19.268884+00:00 06-30T23:00:21.601984+00:00 0:00:02.333100 566801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-30T23:00:15.865395+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-28T23:00:00+00:00 EmrJobFlowSensor 06-29T23:00:56.777084+00:00 06-29T23:11:59.250813+00:00 0:11:02.473729 566338 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-29T23:00:54.299361+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-28T23:00:00+00:00 EmrCreateJobFlowOperator 06-29T23:00:31.258095+00:00 06-29T23:00:32.083453+00:00 0:00:00.825358 566335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-29T23:00:28.274250+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-28T23:00:00+00:00 PythonOperator 06-29T23:00:10.740262+00:00 06-29T23:00:11.992326+00:00 0:00:01.252064 566331 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-29T23:00:08.246564+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-27T23:00:00+00:00 EmrJobFlowSensor 06-28T23:01:10.512178+00:00 06-28T23:12:12.702055+00:00 0:11:02.189877 565863 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-28T23:01:07.786129+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-27T23:00:00+00:00 EmrCreateJobFlowOperator 06-28T23:00:49.482038+00:00 06-28T23:00:50.487344+00:00 0:00:01.005306 565860 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-28T23:00:45.767557+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-27T23:00:00+00:00 PythonOperator 06-28T23:00:26.008562+00:00 06-28T23:00:27.302275+00:00 0:00:01.293713 565857 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-28T23:00:23.746697+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-26T23:00:00+00:00 EmrJobFlowSensor 06-27T23:00:57.379510+00:00 06-27T23:10:59.384203+00:00 0:10:02.004693 565364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-27T23:00:54.543683+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-26T23:00:00+00:00 EmrCreateJobFlowOperator 06-27T23:00:35.274512+00:00 06-27T23:00:36.114180+00:00 0:00:00.839668 565361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-27T23:00:32.568791+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-26T23:00:00+00:00 PythonOperator 06-27T23:00:10.878088+00:00 06-27T23:00:12.139550+00:00 0:00:01.261462 565357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-27T23:00:08.476301+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-25T23:00:00+00:00 EmrJobFlowSensor 06-26T23:01:19.442914+00:00 06-26T23:11:21.422012+00:00 0:10:01.979098 564871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-26T23:01:17.384385+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-25T23:00:00+00:00 EmrCreateJobFlowOperator 06-26T23:00:59.823406+00:00 06-26T23:01:01.005730+00:00 0:00:01.182324 564868 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-26T23:00:55.312504+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-25T23:00:00+00:00 PythonOperator 06-26T23:00:18.881807+00:00 06-26T23:00:20.065860+00:00 0:00:01.184053 564864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-26T23:00:17.114541+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-24T23:00:00+00:00 EmrJobFlowSensor 06-25T23:01:15.510303+00:00 06-25T23:12:17.767962+00:00 0:11:02.257659 564385 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-25T23:01:13.731287+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-24T23:00:00+00:00 EmrCreateJobFlowOperator 06-25T23:00:36.339210+00:00 06-25T23:00:37.465605+00:00 0:00:01.126395 564381 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-25T23:00:31.660901+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-24T23:00:00+00:00 PythonOperator 06-25T23:00:06.383816+00:00 06-25T23:00:07.540119+00:00 0:00:01.156303 564377 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-25T23:00:03.449836+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-23T23:00:00+00:00 EmrJobFlowSensor 06-24T23:01:16.391642+00:00 06-24T23:12:18.570438+00:00 0:11:02.178796 563908 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-24T23:01:13.999156+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-23T23:00:00+00:00 EmrCreateJobFlowOperator 06-24T23:00:53.945696+00:00 06-24T23:00:54.844267+00:00 0:00:00.898571 563905 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-24T23:00:51.941693+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-23T23:00:00+00:00 PythonOperator 06-24T23:00:18.130154+00:00 06-24T23:00:20.743317+00:00 0:00:02.613163 563902 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-24T23:00:12.542499+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-22T23:00:00+00:00 EmrJobFlowSensor 06-23T23:01:21.031679+00:00 06-23T23:11:23.493011+00:00 0:10:02.461332 563428 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-23T23:01:17.415726+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-22T23:00:00+00:00 EmrCreateJobFlowOperator 06-23T23:00:59.681029+00:00 06-23T23:01:00.566599+00:00 0:00:00.885570 563425 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-23T23:00:56.878676+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-22T23:00:00+00:00 PythonOperator 06-23T23:00:12.639162+00:00 06-23T23:00:15.905391+00:00 0:00:03.266229 563420 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-23T23:00:07.380872+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-21T23:00:00+00:00 EmrJobFlowSensor 06-22T23:01:33.638304+00:00 06-22T23:11:35.641772+00:00 0:10:02.003468 562951 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-22T23:01:31.848807+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-21T23:00:00+00:00 EmrCreateJobFlowOperator 06-22T23:01:13.766619+00:00 06-22T23:01:15.006283+00:00 0:00:01.239664 562948 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-22T23:01:09.846130+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-21T23:00:00+00:00 PythonOperator 06-22T23:00:28.617748+00:00 06-22T23:00:30.369544+00:00 0:00:01.751796 562944 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-22T23:00:20.850444+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-20T23:00:00+00:00 EmrJobFlowSensor 06-21T23:00:58.121022+00:00 06-21T23:12:00.361717+00:00 0:11:02.240695 562468 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-21T23:00:55.835363+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-20T23:00:00+00:00 EmrCreateJobFlowOperator 06-21T23:00:31.978069+00:00 06-21T23:00:33.074864+00:00 0:00:01.096795 562466 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-21T23:00:28.543804+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-20T23:00:00+00:00 PythonOperator 06-21T23:00:04.957690+00:00 06-21T23:00:06.251123+00:00 0:00:01.293433 562462 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-21T23:00:02.516066+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-19T23:00:00+00:00 EmrJobFlowSensor 06-20T23:14:40.792825+00:00 06-20T23:14:41.327647+00:00 0:00:00.534822 561992 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-20T23:14:38.485429+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-19T23:00:00+00:00 EmrCreateJobFlowOperator 06-20T23:01:13.107444+00:00 06-20T23:01:14.082777+00:00 0:00:00.975333 561984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-20T23:01:11.090658+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-19T23:00:00+00:00 PythonOperator 06-20T23:00:24.187894+00:00 06-20T23:00:25.329755+00:00 0:00:01.141861 561979 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-20T23:00:22.334656+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-18T23:00:00+00:00 EmrJobFlowSensor 06-20T07:14:36.614217+00:00 06-20T07:23:38.814438+00:00 0:09:02.200221 561592 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-20T07:14:33.046186+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-18T23:00:00+00:00 EmrCreateJobFlowOperator 06-20T07:12:40.911976+00:00 06-20T07:12:43.424207+00:00 0:00:02.512231 561447 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-20T07:08:52.455261+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-18T23:00:00+00:00 PythonOperator 06-20T06:45:33.600029+00:00 06-20T06:45:46.408782+00:00 0:00:12.808753 559726 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-20T06:38:46.203800+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-17T23:00:00+00:00 EmrJobFlowSensor 06-18T23:00:54.352852+00:00 06-18T23:10:56.125728+00:00 0:10:01.772876 558808 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-18T23:00:52.614337+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-17T23:00:00+00:00 EmrCreateJobFlowOperator 06-18T23:00:27.615275+00:00 06-18T23:00:28.638422+00:00 0:00:01.023147 558805 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-18T23:00:24.569246+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-17T23:00:00+00:00 PythonOperator 06-18T23:00:04.651446+00:00 06-18T23:00:05.986427+00:00 0:00:01.334981 558801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-18T23:00:02.422641+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-16T23:00:00+00:00 EmrJobFlowSensor 06-17T23:00:56.027569+00:00 06-17T23:10:57.766590+00:00 0:10:01.739021 558330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-17T23:00:54.341712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-16T23:00:00+00:00 EmrCreateJobFlowOperator 06-17T23:00:32.998026+00:00 06-17T23:00:33.846211+00:00 0:00:00.848185 558328 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-17T23:00:30.332500+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-16T23:00:00+00:00 PythonOperator 06-17T23:00:10.513013+00:00 06-17T23:00:11.506475+00:00 0:00:00.993462 558324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-17T23:00:08.248940+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-15T23:00:00+00:00 EmrJobFlowSensor 06-16T23:00:54.408339+00:00 06-16T23:11:56.294699+00:00 0:11:01.886360 557850 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-16T23:00:52.592928+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-15T23:00:00+00:00 EmrCreateJobFlowOperator 06-16T23:00:29.012246+00:00 06-16T23:00:29.851889+00:00 0:00:00.839643 557847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-16T23:00:26.562356+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-15T23:00:00+00:00 PythonOperator 06-16T23:00:07.385904+00:00 06-16T23:00:08.780301+00:00 0:00:01.394397 557844 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-16T23:00:04.534163+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-14T23:00:00+00:00 EmrJobFlowSensor 06-15T23:01:02.463856+00:00 06-15T23:11:04.187683+00:00 0:10:01.723827 557373 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-15T23:01:00.713761+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-14T23:00:00+00:00 EmrCreateJobFlowOperator 06-15T23:00:43.064408+00:00 06-15T23:00:43.872426+00:00 0:00:00.808018 557370 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-15T23:00:40.561428+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-14T23:00:00+00:00 PythonOperator 06-15T23:00:19.038238+00:00 06-15T23:00:19.989809+00:00 0:00:00.951571 557367 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-15T23:00:16.496312+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-13T23:00:00+00:00 EmrJobFlowSensor 06-14T23:01:05.431743+00:00 06-14T23:11:07.182051+00:00 0:10:01.750308 556894 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-14T23:01:03.785880+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-13T23:00:00+00:00 EmrCreateJobFlowOperator 06-14T23:00:46.199896+00:00 06-14T23:00:47.303879+00:00 0:00:01.103983 556891 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-14T23:00:43.778333+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-13T23:00:00+00:00 PythonOperator 06-14T23:00:17.375182+00:00 06-14T23:00:18.562867+00:00 0:00:01.187685 556887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-14T23:00:15.700393+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-12T23:00:00+00:00 EmrJobFlowSensor 06-13T23:11:38.312057+00:00 06-13T23:11:38.819644+00:00 0:00:00.507587 556422 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-13T23:11:35.647556+00:00 4 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-12T23:00:00+00:00 EmrCreateJobFlowOperator 06-13T23:00:32.878710+00:00 06-13T23:00:33.610530+00:00 0:00:00.731820 556408 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-13T23:00:31.120173+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-12T23:00:00+00:00 PythonOperator 06-13T23:00:13.853962+00:00 06-13T23:00:16.418108+00:00 0:00:02.564146 556405 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-13T23:00:10.727140+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-11T23:00:00+00:00 EmrJobFlowSensor 06-12T23:09:42.183806+00:00 06-12T23:10:42.979156+00:00 0:01:00.795350 555926 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-12T23:09:39.169514+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-11T23:00:00+00:00 EmrCreateJobFlowOperator 06-12T23:00:34.634771+00:00 06-12T23:00:35.544274+00:00 0:00:00.909503 555913 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-12T23:00:32.423703+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-11T23:00:00+00:00 PythonOperator 06-12T23:00:12.823545+00:00 06-12T23:00:13.959325+00:00 0:00:01.135780 555909 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-12T23:00:10.225875+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-10T23:00:00+00:00 EmrJobFlowSensor 06-11T23:00:58.329074+00:00 06-11T23:12:00.198858+00:00 0:11:01.869784 555421 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-11T23:00:56.749935+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-10T23:00:00+00:00 EmrCreateJobFlowOperator 06-11T23:00:36.424636+00:00 06-11T23:00:37.216273+00:00 0:00:00.791637 555418 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-11T23:00:34.697547+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-10T23:00:00+00:00 PythonOperator 06-11T23:00:15.431311+00:00 06-11T23:00:16.771881+00:00 0:00:01.340570 555415 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-11T23:00:12.740785+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-09T23:00:00+00:00 EmrJobFlowSensor 06-10T23:01:43.473953+00:00 06-10T23:11:45.246337+00:00 0:10:01.772384 554919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-10T23:01:41.868535+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-09T23:00:00+00:00 EmrCreateJobFlowOperator 06-10T23:00:49.391008+00:00 06-10T23:00:50.475829+00:00 0:00:01.084821 554914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-10T23:00:44.516644+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-09T23:00:00+00:00 PythonOperator 06-10T23:00:24.219395+00:00 06-10T23:00:25.092164+00:00 0:00:00.872769 554910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-10T23:00:22.431787+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-08T23:00:00+00:00 EmrJobFlowSensor 06-09T23:01:04.353225+00:00 06-09T23:11:06.246099+00:00 0:10:01.892874 554425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-09T23:00:58.851988+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-08T23:00:00+00:00 EmrCreateJobFlowOperator 06-09T23:00:40.540411+00:00 06-09T23:00:41.184549+00:00 0:00:00.644138 554422 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-09T23:00:38.822328+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-08T23:00:00+00:00 PythonOperator 06-09T23:00:23.956824+00:00 06-09T23:00:25.880896+00:00 0:00:01.924072 554419 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-09T23:00:16.723278+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-07T23:00:00+00:00 EmrJobFlowSensor 06-08T23:01:42.595366+00:00 06-08T23:11:44.571680+00:00 0:10:01.976314 553937 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-08T23:01:40.250723+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-07T23:00:00+00:00 EmrCreateJobFlowOperator 06-08T23:00:43.768470+00:00 06-08T23:00:44.653397+00:00 0:00:00.884927 553932 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-08T23:00:41.484947+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-07T23:00:00+00:00 PythonOperator 06-08T23:00:21.904743+00:00 06-08T23:00:22.847663+00:00 0:00:00.942920 553929 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-08T23:00:19.463855+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-06T23:00:00+00:00 EmrJobFlowSensor 06-07T23:01:13.554221+00:00 06-07T23:11:16.002315+00:00 0:10:02.448094 553447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-07T23:01:09.817316+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-06T23:00:00+00:00 EmrCreateJobFlowOperator 06-07T23:00:47.567109+00:00 06-07T23:00:48.378591+00:00 0:00:00.811482 553444 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-07T23:00:43.863828+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-06T23:00:00+00:00 PythonOperator 06-07T23:00:28.573759+00:00 06-07T23:00:30.206592+00:00 0:00:01.632833 553441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-07T23:00:23.756732+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-05T23:00:00+00:00 EmrJobFlowSensor 06-06T23:00:55.892479+00:00 06-06T23:11:57.780645+00:00 0:11:01.888166 552960 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-06T23:00:53.987607+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-05T23:00:00+00:00 EmrCreateJobFlowOperator 06-06T23:00:29.460072+00:00 06-06T23:00:30.146900+00:00 0:00:00.686828 552958 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-06T23:00:27.891691+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-05T23:00:00+00:00 PythonOperator 06-06T23:00:07.569273+00:00 06-06T23:00:08.408475+00:00 0:00:00.839202 552954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-06T23:00:05.819676+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-04T23:00:00+00:00 EmrJobFlowSensor 06-06T10:09:22.979011+00:00 06-06T10:19:30.795870+00:00 0:10:07.816859 552608 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-06T10:08:32.956122+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-04T23:00:00+00:00 EmrCreateJobFlowOperator 06-06T10:08:06.667622+00:00 06-06T10:08:09.062498+00:00 0:00:02.394876 552555 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-06T10:07:58.881908+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-04T23:00:00+00:00 PythonOperator 06-06T10:07:21.406654+00:00 06-06T10:07:40.006609+00:00 0:00:18.599955 552532 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-06T10:06:20.524396+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-03T23:00:00+00:00 EmrJobFlowSensor 06-04T23:00:55.832478+00:00 06-04T23:11:57.969386+00:00 0:11:02.136908 552034 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-04T23:00:53.720961+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-03T23:00:00+00:00 EmrCreateJobFlowOperator 06-04T23:00:33.672023+00:00 06-04T23:00:34.573638+00:00 0:00:00.901615 552031 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-04T23:00:31.610222+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-03T23:00:00+00:00 PythonOperator 06-04T23:00:11.635301+00:00 06-04T23:00:12.600616+00:00 0:00:00.965315 552028 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-04T23:00:09.587634+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-02T23:00:00+00:00 EmrJobFlowSensor 06-03T23:12:58.686780+00:00 06-03T23:12:59.282073+00:00 0:00:00.595293 551555 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-03T23:12:56.053077+00:00 3 default_pool