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 08-11T23:00:00+00:00 EmrJobFlowSensor 08-12T23:00:59.708441+00:00 08-12T23:09:01.457243+00:00 0:08:01.748802 587073 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-12T23:00:57.178746+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-11T23:00:00+00:00 EmrCreateJobFlowOperator 08-12T23:00:37.739934+00:00 08-12T23:00:38.551852+00:00 0:00:00.811918 587071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-12T23:00:35.155460+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-11T23:00:00+00:00 PythonOperator 08-12T23:00:17.327757+00:00 08-12T23:00:18.052122+00:00 0:00:00.724365 587068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-12T23:00:15.144541+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-10T23:00:00+00:00 EmrJobFlowSensor 08-11T23:00:54.949060+00:00 08-11T23:08:56.841838+00:00 0:08:01.892778 586571 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-11T23:00:51.430737+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-10T23:00:00+00:00 EmrCreateJobFlowOperator 08-11T23:00:31.830818+00:00 08-11T23:00:32.713592+00:00 0:00:00.882774 586569 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-11T23:00:29.450091+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-10T23:00:00+00:00 PythonOperator 08-11T23:00:13.510425+00:00 08-11T23:00:14.338513+00:00 0:00:00.828088 586566 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-11T23:00:09.474787+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-09T23:00:00+00:00 EmrJobFlowSensor 08-10T23:01:09.174355+00:00 08-10T23:08:10.704841+00:00 0:07:01.530486 586070 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-10T23:01:06.901742+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-09T23:00:00+00:00 EmrCreateJobFlowOperator 08-10T23:00:26.441580+00:00 08-10T23:00:27.324629+00:00 0:00:00.883049 586068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-10T23:00:23.237944+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-09T23:00:00+00:00 PythonOperator 08-10T23:00:05.694107+00:00 08-10T23:00:06.387853+00:00 0:00:00.693746 586064 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-10T23:00:03.220814+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-08T23:00:00+00:00 EmrJobFlowSensor 08-09T23:00:54.847908+00:00 08-09T23:08:56.557609+00:00 0:08:01.709701 585567 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-09T23:00:52.000581+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-08T23:00:00+00:00 EmrCreateJobFlowOperator 08-09T23:00:25.043024+00:00 08-09T23:00:25.891932+00:00 0:00:00.848908 585565 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-09T23:00:22.483452+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-08T23:00:00+00:00 PythonOperator 08-09T23:00:05.561615+00:00 08-09T23:00:06.265664+00:00 0:00:00.704049 585561 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-09T23:00:02.486802+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-07T23:00:00+00:00 EmrJobFlowSensor 08-08T23:12:57.285466+00:00 08-08T23:12:57.860026+00:00 0:00:00.574560 585053 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-08T23:12:54.363379+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-07T23:00:00+00:00 EmrCreateJobFlowOperator 08-08T23:00:47.024448+00:00 08-08T23:00:47.911009+00:00 0:00:00.886561 585044 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-08T23:00:44.251673+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-07T23:00:00+00:00 PythonOperator 08-08T23:00:27.049316+00:00 08-08T23:00:27.860909+00:00 0:00:00.811593 585042 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-08T23:00:24.170541+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-06T23:00:00+00:00 EmrJobFlowSensor 08-07T23:00:52.960793+00:00 08-07T23:08:54.692025+00:00 0:08:01.731232 584567 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-07T23:00:50.170736+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-06T23:00:00+00:00 EmrCreateJobFlowOperator 08-07T23:00:32.414838+00:00 08-07T23:00:33.779575+00:00 0:00:01.364737 584565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-07T23:00:28.112104+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-06T23:00:00+00:00 PythonOperator 08-07T23:00:08.883321+00:00 08-07T23:00:09.719004+00:00 0:00:00.835683 584561 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-07T23:00:06.090277+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-05T23:00:00+00:00 EmrJobFlowSensor 08-06T23:12:25.219995+00:00 08-06T23:12:25.813385+00:00 0:00:00.593390 584103 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-06T23:12:22.461485+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-05T23:00:00+00:00 EmrCreateJobFlowOperator 08-06T23:00:43.056412+00:00 08-06T23:00:43.926036+00:00 0:00:00.869624 584093 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-06T23:00:40.385089+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-05T23:00:00+00:00 PythonOperator 08-06T23:00:21.264384+00:00 08-06T23:00:22.172115+00:00 0:00:00.907731 584089 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-06T23:00:18.373449+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-04T23:00:00+00:00 EmrJobFlowSensor 08-05T23:12:53.254279+00:00 08-05T23:12:54.021612+00:00 0:00:00.767333 583578 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-05T23:12:50.290286+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-04T23:00:00+00:00 EmrCreateJobFlowOperator 08-05T23:00:56.957347+00:00 08-05T23:00:58.957267+00:00 0:00:01.999920 583570 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-05T23:00:44.669696+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-04T23:00:00+00:00 PythonOperator 08-05T23:00:27.321146+00:00 08-05T23:00:28.627967+00:00 0:00:01.306821 583567 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-05T23:00:24.653505+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-03T23:00:00+00:00 EmrJobFlowSensor 08-04T23:00:57.158117+00:00 08-04T23:08:58.853128+00:00 0:08:01.695011 583035 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-04T23:00:54.584368+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-03T23:00:00+00:00 EmrCreateJobFlowOperator 08-04T23:00:35.714778+00:00 08-04T23:00:36.664474+00:00 0:00:00.949696 583034 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-04T23:00:32.559694+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-03T23:00:00+00:00 PythonOperator 08-04T23:00:12.161279+00:00 08-04T23:00:14.219760+00:00 0:00:02.058481 583031 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-04T23:00:08.553484+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-02T23:00:00+00:00 EmrJobFlowSensor 08-03T23:00:57.654692+00:00 08-03T23:08:59.379260+00:00 0:08:01.724568 582655 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-03T23:00:55.092263+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-02T23:00:00+00:00 EmrCreateJobFlowOperator 08-03T23:00:35.791111+00:00 08-03T23:00:36.686037+00:00 0:00:00.894926 582653 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-03T23:00:33.078591+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-02T23:00:00+00:00 PythonOperator 08-03T23:00:13.885175+00:00 08-03T23:00:15.126084+00:00 0:00:01.240909 582650 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-03T23:00:11.066865+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-01T23:00:00+00:00 EmrJobFlowSensor 08-02T23:00:54.385510+00:00 08-02T23:08:56.132842+00:00 0:08:01.747332 582258 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-02T23:00:50.505735+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-01T23:00:00+00:00 EmrCreateJobFlowOperator 08-02T23:00:27.683282+00:00 08-02T23:00:28.756451+00:00 0:00:01.073169 582255 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-02T23:00:24.552392+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-01T23:00:00+00:00 PythonOperator 08-02T23:00:06.735272+00:00 08-02T23:00:09.152522+00:00 0:00:02.417250 582251 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-02T23:00:02.469761+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-31T23:00:00+00:00 EmrJobFlowSensor 08-01T23:01:02.938428+00:00 08-01T23:09:04.708689+00:00 0:08:01.770261 581803 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-01T23:01:00.214564+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-31T23:00:00+00:00 EmrCreateJobFlowOperator 08-01T23:00:44.162261+00:00 08-01T23:00:45.048035+00:00 0:00:00.885774 581800 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-01T23:00:40.197657+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-31T23:00:00+00:00 PythonOperator 08-01T23:00:21.186591+00:00 08-01T23:00:22.571055+00:00 0:00:01.384464 581796 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-01T23:00:18.176885+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-30T23:00:00+00:00 EmrJobFlowSensor 07-31T23:01:03.223655+00:00 07-31T23:09:05.132911+00:00 0:08:01.909256 581350 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-31T23:01:00.529638+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-30T23:00:00+00:00 EmrCreateJobFlowOperator 07-31T23:00:43.822166+00:00 07-31T23:00:44.718735+00:00 0:00:00.896569 581348 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-31T23:00:40.515712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-30T23:00:00+00:00 PythonOperator 07-31T23:00:21.616810+00:00 07-31T23:00:23.794024+00:00 0:00:02.177214 581343 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-31T23:00:18.496552+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-29T23:00:00+00:00 EmrJobFlowSensor 07-30T23:00:55.708134+00:00 07-30T23:08:57.507214+00:00 0:08:01.799080 580876 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-30T23:00:52.648402+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-29T23:00:00+00:00 EmrCreateJobFlowOperator 07-30T23:00:39.537859+00:00 07-30T23:00:40.623440+00:00 0:00:01.085581 580873 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-30T23:00:32.569928+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-29T23:00:00+00:00 PythonOperator 07-30T23:00:13.594564+00:00 07-30T23:00:14.861199+00:00 0:00:01.266635 580869 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-30T23:00:10.534362+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-28T23:00:00+00:00 EmrJobFlowSensor 07-29T23:13:14.967998+00:00 07-29T23:13:15.387039+00:00 0:00:00.419041 580413 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-29T23:13:13.197556+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-28T23:00:00+00:00 EmrCreateJobFlowOperator 07-29T23:00:33.862021+00:00 07-29T23:00:34.848005+00:00 0:00:00.985984 580402 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-29T23:00:31.275020+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-28T23:00:00+00:00 PythonOperator 07-29T23:00:10.796591+00:00 07-29T23:00:11.665755+00:00 0:00:00.869164 580399 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-29T23:00:09.256849+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-27T23:00:00+00:00 EmrJobFlowSensor 07-28T23:12:35.913945+00:00 07-28T23:12:36.706250+00:00 0:00:00.792305 579953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-28T23:12:33.275618+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-27T23:00:00+00:00 EmrCreateJobFlowOperator 07-28T23:00:38.336944+00:00 07-28T23:00:39.106844+00:00 0:00:00.769900 579943 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-28T23:00:36.708923+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-27T23:00:00+00:00 PythonOperator 07-28T23:00:17.479689+00:00 07-28T23:00:18.727548+00:00 0:00:01.247859 579940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-28T23:00:14.702484+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-26T23:00:00+00:00 EmrJobFlowSensor 07-27T23:07:29.954618+00:00 07-27T23:09:30.862308+00:00 0:02:00.907690 579494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-27T23:07:27.332785+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-26T23:00:00+00:00 EmrCreateJobFlowOperator 07-27T23:00:45.399440+00:00 07-27T23:00:46.278658+00:00 0:00:00.879218 579484 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-27T23:00:42.731227+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-26T23:00:00+00:00 PythonOperator 07-27T23:00:23.386444+00:00 07-27T23:00:24.601531+00:00 0:00:01.215087 579481 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-27T23:00:20.715764+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-25T23:00:00+00:00 EmrJobFlowSensor 07-26T23:01:02.235624+00:00 07-26T23:09:04.027392+00:00 0:08:01.791768 579018 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-26T23:00:59.452649+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-25T23:00:00+00:00 EmrCreateJobFlowOperator 07-26T23:00:40.104083+00:00 07-26T23:00:41.007250+00:00 0:00:00.903167 579015 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-26T23:00:37.431895+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-25T23:00:00+00:00 PythonOperator 07-26T23:00:18.098646+00:00 07-26T23:00:19.310682+00:00 0:00:01.212036 579012 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-26T23:00:15.414070+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-24T23:00:00+00:00 EmrJobFlowSensor 07-25T23:01:01.768571+00:00 07-25T23:09:03.439605+00:00 0:08:01.671034 578553 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-25T23:00:59.194024+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-24T23:00:00+00:00 EmrCreateJobFlowOperator 07-25T23:00:39.788471+00:00 07-25T23:00:40.691654+00:00 0:00:00.903183 578550 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-25T23:00:37.183482+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-24T23:00:00+00:00 PythonOperator 07-25T23:00:17.806340+00:00 07-25T23:00:19.025761+00:00 0:00:01.219421 578547 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-25T23:00:15.111760+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-23T23:00:00+00:00 EmrJobFlowSensor 07-24T23:12:52.128495+00:00 07-24T23:12:52.724876+00:00 0:00:00.596381 578087 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-24T23:12:49.271891+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-23T23:00:00+00:00 EmrCreateJobFlowOperator 07-24T23:00:59.680877+00:00 07-24T23:01:00.581399+00:00 0:00:00.900522 578076 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-24T23:00:57.089363+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-23T23:00:00+00:00 PythonOperator 07-24T23:00:27.397249+00:00 07-24T23:00:28.200900+00:00 0:00:00.803651 578071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-24T23:00:25.813431+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-22T23:00:00+00:00 EmrJobFlowSensor 07-23T23:00:48.107866+00:00 07-23T23:08:49.757769+00:00 0:08:01.649903 577610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-23T23:00:45.350693+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-22T23:00:00+00:00 EmrCreateJobFlowOperator 07-23T23:00:26.901118+00:00 07-23T23:00:28.101668+00:00 0:00:01.200550 577606 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-23T23:00:23.266911+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-22T23:00:00+00:00 PythonOperator 07-23T23:00:05.923804+00:00 07-23T23:00:07.123981+00:00 0:00:01.200177 577603 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-23T23:00:03.247077+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-21T23:00:00+00:00 EmrJobFlowSensor 07-22T23:00:53.475338+00:00 07-22T23:08:55.034882+00:00 0:08:01.559544 577166 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-22T23:00:51.632392+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-21T23:00:00+00:00 EmrCreateJobFlowOperator 07-22T23:00:33.495100+00:00 07-22T23:00:34.420108+00:00 0:00:00.925008 577163 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-22T23:00:31.680256+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-21T23:00:00+00:00 PythonOperator 07-22T23:00:09.610205+00:00 07-22T23:00:10.621461+00:00 0:00:01.011256 577159 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-22T23:00:07.655008+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-20T23:00:00+00:00 EmrJobFlowSensor 07-21T23:00:56.877126+00:00 07-21T23:06:58.131385+00:00 0:06:01.254259 576664 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-21T23:00:55.215311+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-20T23:00:00+00:00 EmrCreateJobFlowOperator 07-21T23:00:35.603869+00:00 07-21T23:00:36.792917+00:00 0:00:01.189048 576661 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-21T23:00:33.206749+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-20T23:00:00+00:00 PythonOperator 07-21T23:00:13.248726+00:00 07-21T23:00:14.194676+00:00 0:00:00.945950 576657 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-21T23:00:11.176877+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-19T23:00:00+00:00 EmrJobFlowSensor 07-20T23:01:26.828819+00:00 07-20T23:07:28.047581+00:00 0:06:01.218762 576164 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-20T23:01:25.310626+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-19T23:00:00+00:00 EmrCreateJobFlowOperator 07-20T23:01:04.883572+00:00 07-20T23:01:05.665429+00:00 0:00:00.781857 576161 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-20T23:01:03.291121+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-19T23:00:00+00:00 PythonOperator 07-20T23:00:17.501977+00:00 07-20T23:00:18.407403+00:00 0:00:00.905426 576154 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-20T23:00:15.877560+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-18T23:00:00+00:00 EmrJobFlowSensor 07-19T23:00:55.272698+00:00 07-19T23:08:56.966100+00:00 0:08:01.693402 575657 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-19T23:00:53.304498+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-18T23:00:00+00:00 EmrCreateJobFlowOperator 07-19T23:00:29.406222+00:00 07-19T23:00:30.176710+00:00 0:00:00.770488 575654 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-19T23:00:27.713478+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-18T23:00:00+00:00 PythonOperator 07-19T23:00:05.644322+00:00 07-19T23:00:06.671953+00:00 0:00:01.027631 575649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-19T23:00:03.692180+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-17T23:00:00+00:00 EmrJobFlowSensor 07-18T23:00:57.115144+00:00 07-18T23:07:58.467636+00:00 0:07:01.352492 575131 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-18T23:00:55.390042+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-17T23:00:00+00:00 EmrCreateJobFlowOperator 07-18T23:00:31.259865+00:00 07-18T23:00:31.978682+00:00 0:00:00.718817 575129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-18T23:00:29.691161+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-17T23:00:00+00:00 PythonOperator 07-18T23:00:05.537256+00:00 07-18T23:00:06.410824+00:00 0:00:00.873568 575124 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-18T23:00:03.672251+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-16T23:00:00+00:00 EmrJobFlowSensor 07-17T23:00:47.169351+00:00 07-17T23:07:48.566676+00:00 0:07:01.397325 574610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-17T23:00:45.447310+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-16T23:00:00+00:00 EmrCreateJobFlowOperator 07-17T23:00:27.235159+00:00 07-17T23:00:27.914920+00:00 0:00:00.679761 574606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-17T23:00:25.370535+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-16T23:00:00+00:00 PythonOperator 07-17T23:00:03.049668+00:00 07-17T23:00:04.490379+00:00 0:00:01.440711 574601 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-17T23:00:01.335176+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-15T23:00:00+00:00 EmrJobFlowSensor 07-16T23:00:49.324907+00:00 07-16T23:07:50.832024+00:00 0:07:01.507117 574095 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-16T23:00:47.601845+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-15T23:00:00+00:00 EmrCreateJobFlowOperator 07-16T23:00:30.654359+00:00 07-16T23:00:31.847571+00:00 0:00:01.193212 574092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-16T23:00:27.584450+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-15T23:00:00+00:00 PythonOperator 07-16T23:00:08.100205+00:00 07-16T23:00:09.984620+00:00 0:00:01.884415 574086 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-16T23:00:05.575711+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-14T23:00:00+00:00 EmrJobFlowSensor 07-15T23:01:07.257525+00:00 07-15T23:12:09.183595+00:00 0:11:01.926070 573614 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-15T23:01:05.507613+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-14T23:00:00+00:00 EmrCreateJobFlowOperator 07-15T23:00:47.246962+00:00 07-15T23:00:47.995969+00:00 0:00:00.749007 573611 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-15T23:00:45.489802+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-14T23:00:00+00:00 PythonOperator 07-15T23:00:25.132242+00:00 07-15T23:00:26.203809+00:00 0:00:01.071567 573608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-15T23:00:23.469057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-13T23:00:00+00:00 EmrJobFlowSensor 07-14T23:01:03.137965+00:00 07-14T23:12:05.089054+00:00 0:11:01.951089 573181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-14T23:01:01.535635+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-13T23:00:00+00:00 EmrCreateJobFlowOperator 07-14T23:00:41.278498+00:00 07-14T23:00:42.002980+00:00 0:00:00.724482 573178 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-14T23:00:39.513960+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-13T23:00:00+00:00 PythonOperator 07-14T23:00:21.394052+00:00 07-14T23:00:23.100650+00:00 0:00:01.706598 573174 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-14T23:00:19.498131+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-12T23:00:00+00:00 EmrJobFlowSensor 07-13T23:01:03.124692+00:00 07-13T23:11:04.963007+00:00 0:10:01.838315 572761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-13T23:01:01.380102+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-12T23:00:00+00:00 EmrCreateJobFlowOperator 07-13T23:00:41.215172+00:00 07-13T23:00:41.951633+00:00 0:00:00.736461 572758 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-13T23:00:39.380139+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-12T23:00:00+00:00 PythonOperator 07-13T23:00:18.971029+00:00 07-13T23:00:20.066810+00:00 0:00:01.095781 572754 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-13T23:00:17.333722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-11T23:00:00+00:00 EmrJobFlowSensor 07-12T23:00:59.827256+00:00 07-12T23:12:01.716525+00:00 0:11:01.889269 572337 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-12T23:00:57.579254+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-11T23:00:00+00:00 EmrCreateJobFlowOperator 07-12T23:00:39.106515+00:00 07-12T23:00:39.903957+00:00 0:00:00.797442 572334 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-12T23:00:37.532479+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-11T23:00:00+00:00 PythonOperator 07-12T23:00:17.183066+00:00 07-12T23:00:18.092046+00:00 0:00:00.908980 572331 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-12T23:00:15.512840+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-10T23:00:00+00:00 EmrJobFlowSensor 07-11T23:00:53.134177+00:00 07-11T23:10:54.871721+00:00 0:10:01.737544 571855 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-11T23:00:51.356197+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 07-10T23:00:00+00:00 EmrCreateJobFlowOperator 07-11T23:00:33.149403+00:00 07-11T23:00:33.918305+00:00 0:00:00.768902 571853 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 07-11T23:00:31.275989+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 07-10T23:00:00+00:00 PythonOperator 07-11T23:00:11.178500+00:00 07-11T23:00:12.109675+00:00 0:00:00.931175 571851 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 07-11T23:00:09.261382+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 07-09T23:00:00+00:00 EmrJobFlowSensor 07-10T23:00:57.122441+00:00 07-10T23:10:58.966221+00:00 0:10:01.843780 571324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 07-10T23:00:55.474722+00:00 2 default_pool