Task Instances

Reset Filters
  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 10-03T23:00:00+00:00 EmrJobFlowSensor 10-04T23:01:16.295736+00:00 10-04T23:09:18.135809+00:00 0:08:01.840073 614748 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-04T23:01:12.921459+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-03T23:00:00+00:00 EmrCreateJobFlowOperator 10-04T23:00:50.383356+00:00 10-04T23:00:51.456880+00:00 0:00:01.073524 614746 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-04T23:00:46.747085+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-03T23:00:00+00:00 PythonOperator 10-04T23:00:28.819713+00:00 10-04T23:00:29.688454+00:00 0:00:00.868741 614744 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-04T23:00:24.652694+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-02T23:00:00+00:00 EmrJobFlowSensor 10-03T23:00:53.612296+00:00 10-03T23:09:55.557244+00:00 0:09:01.944948 614228 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-03T23:00:50.344923+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-02T23:00:00+00:00 EmrCreateJobFlowOperator 10-03T23:00:33.752797+00:00 10-03T23:00:35.329557+00:00 0:00:01.576760 614226 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-03T23:00:30.297228+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-02T23:00:00+00:00 PythonOperator 10-03T23:00:08.332055+00:00 10-03T23:00:09.313735+00:00 0:00:00.981680 614223 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-03T23:00:04.141576+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 10-01T23:00:00+00:00 EmrJobFlowSensor 10-02T23:00:57.636764+00:00 10-02T23:08:59.588895+00:00 0:08:01.952131 613717 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-02T23:00:54.139400+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 10-01T23:00:00+00:00 EmrCreateJobFlowOperator 10-02T23:00:35.670518+00:00 10-02T23:00:36.728360+00:00 0:00:01.057842 613715 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-02T23:00:32.045461+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 10-01T23:00:00+00:00 PythonOperator 10-02T23:00:13.481987+00:00 10-02T23:00:14.380212+00:00 0:00:00.898225 613712 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-02T23:00:10.033840+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-30T23:00:00+00:00 EmrJobFlowSensor 10-01T23:00:58.392895+00:00 10-01T23:09:00.310502+00:00 0:08:01.917607 613203 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 10-01T23:00:56.442730+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-30T23:00:00+00:00 EmrCreateJobFlowOperator 10-01T23:00:33.794737+00:00 10-01T23:00:34.836260+00:00 0:00:01.041523 613201 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 10-01T23:00:30.328765+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-30T23:00:00+00:00 PythonOperator 10-01T23:00:14.033609+00:00 10-01T23:00:14.918354+00:00 0:00:00.884745 613197 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 10-01T23:00:10.025499+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-29T23:00:00+00:00 EmrJobFlowSensor 09-30T23:00:51.235764+00:00 09-30T23:07:52.837271+00:00 0:07:01.601507 612685 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-30T23:00:47.853495+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-29T23:00:00+00:00 EmrCreateJobFlowOperator 09-30T23:00:29.446409+00:00 09-30T23:00:30.491170+00:00 0:00:01.044761 612683 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-30T23:00:25.684394+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-29T23:00:00+00:00 PythonOperator 09-30T23:00:07.148019+00:00 09-30T23:00:08.009793+00:00 0:00:00.861774 612679 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-30T23:00:03.623567+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-28T23:00:00+00:00 EmrJobFlowSensor 09-29T23:01:14.604950+00:00 09-29T23:09:16.752945+00:00 0:08:02.147995 612172 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-29T23:01:10.981598+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-28T23:00:00+00:00 EmrCreateJobFlowOperator 09-29T23:00:50.495971+00:00 09-29T23:00:51.514148+00:00 0:00:01.018177 612170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-29T23:00:46.905284+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-28T23:00:00+00:00 PythonOperator 09-29T23:00:28.201821+00:00 09-29T23:00:29.087946+00:00 0:00:00.886125 612168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-29T23:00:24.862009+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-27T23:00:00+00:00 EmrJobFlowSensor 09-28T23:00:57.058361+00:00 09-28T23:08:59.111483+00:00 0:08:02.053122 611660 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-28T23:00:52.975154+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-27T23:00:00+00:00 EmrCreateJobFlowOperator 09-28T23:00:32.863329+00:00 09-28T23:00:33.922286+00:00 0:00:01.058957 611658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-28T23:00:28.759139+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-27T23:00:00+00:00 PythonOperator 09-28T23:00:10.716942+00:00 09-28T23:00:11.779330+00:00 0:00:01.062388 611653 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-28T23:00:06.741027+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-26T23:00:00+00:00 EmrJobFlowSensor 09-27T23:00:54.786982+00:00 09-27T23:07:56.593812+00:00 0:07:01.806830 611149 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-27T23:00:50.941431+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-26T23:00:00+00:00 EmrCreateJobFlowOperator 09-27T23:00:33.458239+00:00 09-27T23:00:34.882158+00:00 0:00:01.423919 611147 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-27T23:00:28.982819+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-26T23:00:00+00:00 PythonOperator 09-27T23:00:10.977244+00:00 09-27T23:00:12.026304+00:00 0:00:01.049060 611143 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-27T23:00:06.871754+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-25T23:00:00+00:00 EmrJobFlowSensor 09-26T23:12:35.453453+00:00 09-26T23:12:36.177826+00:00 0:00:00.724373 610481 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-26T23:12:31.397751+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-25T23:00:00+00:00 EmrCreateJobFlowOperator 09-26T23:00:42.227307+00:00 09-26T23:00:43.193807+00:00 0:00:00.966500 610471 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-26T23:00:38.882836+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-25T23:00:00+00:00 PythonOperator 09-26T23:00:21.636347+00:00 09-26T23:00:22.933571+00:00 0:00:01.297224 610468 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-26T23:00:16.749105+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-24T23:00:00+00:00 EmrJobFlowSensor 09-25T23:12:42.270216+00:00 09-25T23:12:42.811006+00:00 0:00:00.540790 609962 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-25T23:12:39.813374+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-24T23:00:00+00:00 EmrCreateJobFlowOperator 09-25T23:00:42.255789+00:00 09-25T23:00:43.296883+00:00 0:00:01.041094 609953 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-25T23:00:38.628114+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-24T23:00:00+00:00 PythonOperator 09-25T23:00:20.278960+00:00 09-25T23:00:21.382368+00:00 0:00:01.103408 609950 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-25T23:00:16.630948+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-23T23:00:00+00:00 EmrJobFlowSensor 09-24T23:01:16.520387+00:00 09-24T23:08:18.285350+00:00 0:07:01.764963 609447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-24T23:01:12.923883+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-23T23:00:00+00:00 EmrCreateJobFlowOperator 09-24T23:00:53.403938+00:00 09-24T23:00:54.373657+00:00 0:00:00.969719 609445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-24T23:00:50.909171+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-23T23:00:00+00:00 PythonOperator 09-24T23:00:28.121591+00:00 09-24T23:00:29.170136+00:00 0:00:01.048545 609443 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-24T23:00:24.795396+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-22T23:00:00+00:00 EmrJobFlowSensor 09-23T23:12:34.126729+00:00 09-23T23:12:34.848824+00:00 0:00:00.722095 608942 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-23T23:12:30.740684+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-22T23:00:00+00:00 EmrCreateJobFlowOperator 09-23T23:00:28.176629+00:00 09-23T23:00:29.250956+00:00 0:00:01.074327 608932 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-23T23:00:24.627173+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-22T23:00:00+00:00 PythonOperator 09-23T23:00:07.378751+00:00 09-23T23:00:08.137351+00:00 0:00:00.758600 608928 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-23T23:00:04.398159+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-21T23:00:00+00:00 EmrJobFlowSensor 09-22T23:00:51.225287+00:00 09-22T23:08:53.173398+00:00 0:08:01.948111 608420 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-22T23:00:47.611531+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-21T23:00:00+00:00 EmrCreateJobFlowOperator 09-22T23:00:30.000635+00:00 09-22T23:00:31.159575+00:00 0:00:01.158940 608418 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-22T23:00:25.595256+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-21T23:00:00+00:00 PythonOperator 09-22T23:00:07.183701+00:00 09-22T23:00:08.225196+00:00 0:00:01.041495 608415 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-22T23:00:03.482941+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-20T23:00:00+00:00 EmrJobFlowSensor 09-21T23:01:05.984501+00:00 09-21T23:09:07.915025+00:00 0:08:01.930524 607912 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-21T23:01:02.552436+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-20T23:00:00+00:00 EmrCreateJobFlowOperator 09-21T23:00:44.048003+00:00 09-21T23:00:45.088559+00:00 0:00:01.040556 607910 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-21T23:00:40.591797+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-20T23:00:00+00:00 PythonOperator 09-21T23:00:24.260503+00:00 09-21T23:00:25.271980+00:00 0:00:01.011477 607909 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-21T23:00:20.528328+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-19T23:00:00+00:00 EmrJobFlowSensor 09-20T23:12:20.042404+00:00 09-20T23:12:20.583913+00:00 0:00:00.541509 607412 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-20T23:12:17.804183+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-19T23:00:00+00:00 EmrCreateJobFlowOperator 09-20T23:00:49.819417+00:00 09-20T23:00:50.621502+00:00 0:00:00.802085 607403 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-20T23:00:47.688340+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-19T23:00:00+00:00 PythonOperator 09-20T23:00:23.852990+00:00 09-20T23:00:24.546967+00:00 0:00:00.693977 607400 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-20T23:00:21.674115+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-18T23:00:00+00:00 EmrJobFlowSensor 09-19T23:12:31.387125+00:00 09-19T23:12:32.117463+00:00 0:00:00.730338 606906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-19T23:12:27.759636+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-18T23:00:00+00:00 EmrCreateJobFlowOperator 09-19T23:00:31.501165+00:00 09-19T23:00:32.618280+00:00 0:00:01.117115 606896 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-19T23:00:27.068904+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-18T23:00:00+00:00 PythonOperator 09-19T23:00:09.222279+00:00 09-19T23:00:10.246898+00:00 0:00:01.024619 606892 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-19T23:00:05.091855+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-17T23:00:00+00:00 EmrJobFlowSensor 09-18T23:12:45.154362+00:00 09-18T23:12:45.875858+00:00 0:00:00.721496 606394 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-18T23:12:41.601591+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-17T23:00:00+00:00 EmrCreateJobFlowOperator 09-18T23:00:47.645997+00:00 09-18T23:00:48.737675+00:00 0:00:01.091678 606384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-18T23:00:43.968832+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-17T23:00:00+00:00 PythonOperator 09-18T23:00:25.777792+00:00 09-18T23:00:26.856673+00:00 0:00:01.078881 606382 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-18T23:00:21.957992+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-16T23:00:00+00:00 EmrJobFlowSensor 09-17T23:00:59.449746+00:00 09-17T23:09:01.623279+00:00 0:08:02.173533 605863 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-17T23:00:55.945194+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-16T23:00:00+00:00 EmrCreateJobFlowOperator 09-17T23:00:39.255698+00:00 09-17T23:00:40.314825+00:00 0:00:01.059127 605861 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-17T23:00:35.824615+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-16T23:00:00+00:00 PythonOperator 09-17T23:00:11.616819+00:00 09-17T23:00:12.617439+00:00 0:00:01.000620 605858 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-17T23:00:07.855477+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-15T23:00:00+00:00 EmrJobFlowSensor 09-16T23:01:05.958276+00:00 09-16T23:09:07.908325+00:00 0:08:01.950049 605355 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-16T23:01:02.097070+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-15T23:00:00+00:00 EmrCreateJobFlowOperator 09-16T23:00:44.574301+00:00 09-16T23:00:46.456428+00:00 0:00:01.882127 605353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-16T23:00:40.074091+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-15T23:00:00+00:00 PythonOperator 09-16T23:00:24.349120+00:00 09-16T23:00:26.578018+00:00 0:00:02.228898 605351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-16T23:00:16.064742+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-14T23:00:00+00:00 EmrJobFlowSensor 09-15T23:01:08.603506+00:00 09-15T23:09:10.503849+00:00 0:08:01.900343 604847 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-15T23:01:05.065842+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-14T23:00:00+00:00 EmrCreateJobFlowOperator 09-15T23:00:42.568153+00:00 09-15T23:00:43.580371+00:00 0:00:01.012218 604845 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-15T23:00:38.954813+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-14T23:00:00+00:00 PythonOperator 09-15T23:00:18.947885+00:00 09-15T23:00:19.538756+00:00 0:00:00.590871 604843 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-15T23:00:17.053052+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-13T23:00:00+00:00 EmrJobFlowSensor 09-14T23:01:02.308619+00:00 09-14T23:08:04.083247+00:00 0:07:01.774628 604335 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-14T23:00:58.660104+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-13T23:00:00+00:00 EmrCreateJobFlowOperator 09-14T23:00:38.319507+00:00 09-14T23:00:39.135609+00:00 0:00:00.816102 604333 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-14T23:00:36.494450+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-13T23:00:00+00:00 PythonOperator 09-14T23:00:17.920955+00:00 09-14T23:00:19.101810+00:00 0:00:01.180855 604331 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-14T23:00:14.421410+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-12T23:00:00+00:00 EmrJobFlowSensor 09-13T23:01:02.829642+00:00 09-13T23:09:04.437784+00:00 0:08:01.608142 603836 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-13T23:01:00.842737+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-12T23:00:00+00:00 EmrCreateJobFlowOperator 09-13T23:00:42.828229+00:00 09-13T23:00:43.573693+00:00 0:00:00.745464 603834 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-13T23:00:40.826780+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-12T23:00:00+00:00 PythonOperator 09-13T23:00:24.532493+00:00 09-13T23:00:25.510215+00:00 0:00:00.977722 603831 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-13T23:00:18.873983+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-11T23:00:00+00:00 EmrJobFlowSensor 09-13T01:44:12.436034+00:00 09-13T01:52:14.049551+00:00 0:08:01.613517 603388 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-13T01:44:10.433397+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-11T23:00:00+00:00 EmrCreateJobFlowOperator 09-13T01:43:48.168877+00:00 09-13T01:43:53.364818+00:00 0:00:05.195941 603354 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-13T01:39:56.119944+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-11T23:00:00+00:00 PythonOperator 09-13T01:34:27.471791+00:00 09-13T01:34:36.676665+00:00 0:00:09.204874 603052 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-13T01:32:39.747854+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-10T23:00:00+00:00 EmrJobFlowSensor 09-11T23:01:00.123507+00:00 09-11T23:08:01.796465+00:00 0:07:01.672958 602351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-11T23:00:56.688509+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-10T23:00:00+00:00 EmrCreateJobFlowOperator 09-11T23:00:38.004586+00:00 09-11T23:00:38.951337+00:00 0:00:00.946751 602349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-11T23:00:34.675799+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-10T23:00:00+00:00 PythonOperator 09-11T23:00:17.765655+00:00 09-11T23:00:18.655522+00:00 0:00:00.889867 602345 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-11T23:00:14.567833+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-09T23:00:00+00:00 EmrJobFlowSensor 09-10T23:00:56.521296+00:00 09-10T23:07:58.280604+00:00 0:07:01.759308 601849 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-10T23:00:53.302084+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-09T23:00:00+00:00 EmrCreateJobFlowOperator 09-10T23:00:33.242066+00:00 09-10T23:00:33.918210+00:00 0:00:00.676144 601847 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-10T23:00:31.355859+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-09T23:00:00+00:00 PythonOperator 09-10T23:00:12.858850+00:00 09-10T23:00:13.393708+00:00 0:00:00.534858 601844 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-10T23:00:11.241471+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-08T23:00:00+00:00 EmrJobFlowSensor 09-09T23:00:58.556646+00:00 09-09T23:09:00.427251+00:00 0:08:01.870605 601342 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-09T23:00:55.148951+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-08T23:00:00+00:00 EmrCreateJobFlowOperator 09-09T23:00:36.694852+00:00 09-09T23:00:38.027339+00:00 0:00:01.332487 601340 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-09T23:00:33.078064+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-08T23:00:00+00:00 PythonOperator 09-09T23:00:18.954430+00:00 09-09T23:00:20.961274+00:00 0:00:02.006844 601337 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-09T23:00:11.075802+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-07T23:00:00+00:00 EmrJobFlowSensor 09-08T23:01:01.182351+00:00 09-08T23:09:03.351434+00:00 0:08:02.169083 600824 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-08T23:00:57.276801+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-07T23:00:00+00:00 EmrCreateJobFlowOperator 09-08T23:00:41.113812+00:00 09-08T23:00:42.321980+00:00 0:00:01.208168 600822 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-08T23:00:37.263185+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-07T23:00:00+00:00 PythonOperator 09-08T23:00:19.697539+00:00 09-08T23:00:21.312302+00:00 0:00:01.614763 600819 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-08T23:00:15.166323+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-06T23:00:00+00:00 EmrJobFlowSensor 09-07T23:01:06.443725+00:00 09-07T23:09:08.232697+00:00 0:08:01.788972 600317 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-07T23:01:03.213869+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-06T23:00:00+00:00 EmrCreateJobFlowOperator 09-07T23:00:44.369710+00:00 09-07T23:00:45.334030+00:00 0:00:00.964320 600314 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-07T23:00:41.192028+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-06T23:00:00+00:00 PythonOperator 09-07T23:00:24.133760+00:00 09-07T23:00:24.999912+00:00 0:00:00.866152 600312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-07T23:00:19.124732+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-05T23:00:00+00:00 EmrJobFlowSensor 09-06T23:01:07.089604+00:00 09-06T23:08:08.907708+00:00 0:07:01.818104 599804 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-06T23:01:03.609898+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-05T23:00:00+00:00 EmrCreateJobFlowOperator 09-06T23:00:44.815394+00:00 09-06T23:00:45.823502+00:00 0:00:01.008108 599802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-06T23:00:41.590833+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-05T23:00:00+00:00 PythonOperator 09-06T23:00:23.210077+00:00 09-06T23:00:24.135584+00:00 0:00:00.925507 599800 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-06T23:00:19.526149+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-04T23:00:00+00:00 EmrJobFlowSensor 09-05T23:01:06.030498+00:00 09-05T23:09:08.068771+00:00 0:08:02.038273 599294 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-05T23:01:02.354584+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-04T23:00:00+00:00 EmrCreateJobFlowOperator 09-05T23:00:45.376002+00:00 09-05T23:00:46.901550+00:00 0:00:01.525548 599292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-05T23:00:40.338655+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-04T23:00:00+00:00 PythonOperator 09-05T23:00:22.395349+00:00 09-05T23:00:23.613409+00:00 0:00:01.218060 599290 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-05T23:00:14.162662+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-03T23:00:00+00:00 EmrJobFlowSensor 09-04T23:00:56.862844+00:00 09-04T23:08:58.768341+00:00 0:08:01.905497 598782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-04T23:00:53.231936+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-03T23:00:00+00:00 EmrCreateJobFlowOperator 09-04T23:00:35.689850+00:00 09-04T23:00:36.820550+00:00 0:00:01.130700 598780 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-04T23:00:31.162560+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-03T23:00:00+00:00 PythonOperator 09-04T23:00:12.690488+00:00 09-04T23:00:13.654808+00:00 0:00:00.964320 598776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-04T23:00:09.105095+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-02T23:00:00+00:00 EmrJobFlowSensor 09-03T23:01:15.197627+00:00 09-03T23:08:17.151162+00:00 0:07:01.953535 598266 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-03T23:01:11.360842+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-02T23:00:00+00:00 EmrCreateJobFlowOperator 09-03T23:00:48.016774+00:00 09-03T23:00:49.179116+00:00 0:00:01.162342 598264 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-03T23:00:43.354823+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-02T23:00:00+00:00 PythonOperator 09-03T23:00:25.970078+00:00 09-03T23:00:27.180371+00:00 0:00:01.210293 598261 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-03T23:00:21.337600+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-01T23:00:00+00:00 EmrJobFlowSensor 09-02T23:01:16.034865+00:00 09-02T23:09:17.962899+00:00 0:08:01.928034 597755 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-02T23:01:12.349809+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-01T23:00:00+00:00 EmrCreateJobFlowOperator 09-02T23:00:50.719797+00:00 09-02T23:00:51.772782+00:00 0:00:01.052985 597753 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-02T23:00:46.205731+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-01T23:00:00+00:00 PythonOperator 09-02T23:00:29.761191+00:00 09-02T23:00:30.849846+00:00 0:00:01.088655 597750 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-02T23:00:26.189679+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-31T23:00:00+00:00 EmrJobFlowSensor 09-01T23:01:09.516737+00:00 09-01T23:09:11.514498+00:00 0:08:01.997761 597244 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-01T23:01:05.979614+00:00 2 default_pool