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 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
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-17T23:00:26.544403+00:00 2023-09-17T23:00:27.375808+00:00 0:00:00.831405 424953 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-17T23:00:24.495729+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-16T23:00:00+00:00 PythonOperator 2023-09-17T23:00:06.653931+00:00 2023-09-17T23:00:07.659796+00:00 0:00:01.005865 424951 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-17T23:00:04.419730+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-15T23:00:00+00:00 EmrJobFlowSensor 2023-09-16T23:00:58.138165+00:00 2023-09-16T23:10:59.948126+00:00 0:10:01.809961 424579 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-16T23:00:55.989653+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-16T23:00:38.219241+00:00 2023-09-16T23:00:39.080284+00:00 0:00:00.861043 424578 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-16T23:00:35.928000+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-15T23:00:00+00:00 PythonOperator 2023-09-16T23:00:16.048228+00:00 2023-09-16T23:00:17.059366+00:00 0:00:01.011138 424576 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-16T23:00:13.911343+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-14T23:00:00+00:00 EmrJobFlowSensor 2023-09-15T23:01:02.882763+00:00 2023-09-15T23:12:04.849678+00:00 0:11:01.966915 424204 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-15T23:01:00.606316+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-15T23:00:42.695574+00:00 2023-09-15T23:00:43.467449+00:00 0:00:00.771875 424203 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-15T23:00:40.589973+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-14T23:00:00+00:00 PythonOperator 2023-09-15T23:00:20.687264+00:00 2023-09-15T23:00:21.639385+00:00 0:00:00.952121 424202 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-15T23:00:18.513003+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-13T23:00:00+00:00 EmrJobFlowSensor 2023-09-14T23:01:06.592175+00:00 2023-09-14T23:12:08.605344+00:00 0:11:02.013169 423827 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-14T23:01:04.479334+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-14T23:00:44.518961+00:00 2023-09-14T23:00:45.275535+00:00 0:00:00.756574 423826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-14T23:00:42.455704+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-13T23:00:00+00:00 PythonOperator 2023-09-14T23:00:24.567795+00:00 2023-09-14T23:00:25.582860+00:00 0:00:01.015065 423825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-14T23:00:22.437417+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-12T23:00:00+00:00 EmrJobFlowSensor 2023-09-13T23:00:55.872621+00:00 2023-09-13T23:11:57.996950+00:00 0:11:02.124329 423449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-13T23:00:53.263959+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-13T23:00:35.199175+00:00 2023-09-13T23:00:36.086495+00:00 0:00:00.887320 423448 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-13T23:00:33.252328+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-12T23:00:00+00:00 PythonOperator 2023-09-13T23:00:13.532322+00:00 2023-09-13T23:00:14.727017+00:00 0:00:01.194695 423446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-13T23:00:11.230459+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-11T23:00:00+00:00 EmrJobFlowSensor 2023-09-12T23:01:06.384026+00:00 2023-09-12T23:11:08.411851+00:00 0:10:02.027825 423068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-12T23:01:03.498271+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-12T23:00:44.095105+00:00 2023-09-12T23:00:45.144004+00:00 0:00:01.048899 423067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-12T23:00:41.411173+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-11T23:00:00+00:00 PythonOperator 2023-09-12T23:00:23.952043+00:00 2023-09-12T23:00:25.144485+00:00 0:00:01.192442 423066 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-12T23:00:21.390605+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-10T23:00:00+00:00 EmrJobFlowSensor 2023-09-11T23:00:52.482762+00:00 2023-09-11T23:11:54.597373+00:00 0:11:02.114611 422692 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-11T23:00:49.917233+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-11T23:00:32.542757+00:00 2023-09-11T23:00:33.519513+00:00 0:00:00.976756 422691 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-11T23:00:29.819929+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-10T23:00:00+00:00 PythonOperator 2023-09-11T23:00:11.617023+00:00 2023-09-11T23:00:14.035483+00:00 0:00:02.418460 422689 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-11T23:00:07.743251+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-09T23:00:00+00:00 EmrJobFlowSensor 2023-09-10T23:00:50.878143+00:00 2023-09-10T23:11:52.983331+00:00 0:11:02.105188 422304 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-10T23:00:48.078322+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-10T23:00:28.807886+00:00 2023-09-10T23:00:29.847378+00:00 0:00:01.039492 422303 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-10T23:00:26.058668+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-09-09T23:00:00+00:00 PythonOperator 2023-09-10T23:00:08.110266+00:00 2023-09-10T23:00:09.539040+00:00 0:00:01.428774 422301 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-10T23:00:06.040460+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-09-08T23:00:00+00:00 EmrJobFlowSensor 2023-09-09T23:05:49.729993+00:00 2023-09-09T23:15:51.566756+00:00 0:10:01.836763 421938 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-09T23:05:47.727465+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-09-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-09-09T23:05:29.731084+00:00 2023-09-09T23:05:30.743514+00:00 0:00:01.012430 421936 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-09T23:05:27.704726+00:00 2 default_pool