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 01-26T23:00:00+00:00 EmrJobFlowSensor 01-27T23:01:06.162108+00:00 01-27T23:11:07.973690+00:00 0:10:01.811582 476150 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-27T23:01:04.092373+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-26T23:00:00+00:00 EmrCreateJobFlowOperator 01-27T23:00:46.976241+00:00 01-27T23:00:47.729449+00:00 0:00:00.753208 476147 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-27T23:00:44.071718+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-26T23:00:00+00:00 PythonOperator 01-27T23:00:24.601574+00:00 01-27T23:00:25.804450+00:00 0:00:01.202876 476144 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-27T23:00:22.054536+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-25T23:00:00+00:00 EmrJobFlowSensor 01-26T23:00:52.131515+00:00 01-26T23:10:53.914678+00:00 0:10:01.783163 475749 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-26T23:00:50.506350+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-25T23:00:00+00:00 EmrCreateJobFlowOperator 01-26T23:00:30.355846+00:00 01-26T23:00:31.130955+00:00 0:00:00.775109 475746 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-26T23:00:28.488662+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-25T23:00:00+00:00 PythonOperator 01-26T23:00:08.222276+00:00 01-26T23:00:09.362085+00:00 0:00:01.139809 475743 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-26T23:00:06.458305+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-24T23:00:00+00:00 EmrJobFlowSensor 01-25T23:01:02.654077+00:00 01-25T23:12:04.553463+00:00 0:11:01.899386 475353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-25T23:01:00.554344+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-24T23:00:00+00:00 EmrCreateJobFlowOperator 01-25T23:00:41.018478+00:00 01-25T23:00:41.862185+00:00 0:00:00.843707 475350 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-25T23:00:38.488865+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-24T23:00:00+00:00 PythonOperator 01-25T23:00:20.583098+00:00 01-25T23:00:21.792795+00:00 0:00:01.209697 475347 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-25T23:00:18.456645+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-23T23:00:00+00:00 EmrJobFlowSensor 01-24T23:01:05.905050+00:00 01-24T23:11:07.719264+00:00 0:10:01.814214 474940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-24T23:01:04.183135+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-23T23:00:00+00:00 EmrCreateJobFlowOperator 01-24T23:00:45.840084+00:00 01-24T23:00:46.632053+00:00 0:00:00.791969 474937 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-24T23:00:44.152940+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-23T23:00:00+00:00 PythonOperator 01-24T23:00:24.232449+00:00 01-24T23:00:25.500487+00:00 0:00:01.268038 474934 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-24T23:00:22.132843+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-22T23:00:00+00:00 EmrJobFlowSensor 01-23T23:01:03.691190+00:00 01-23T23:12:05.589187+00:00 0:11:01.897997 474533 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-23T23:01:01.565962+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-22T23:00:00+00:00 EmrCreateJobFlowOperator 01-23T23:00:41.636045+00:00 01-23T23:00:42.644980+00:00 0:00:01.008935 474529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-23T23:00:39.541166+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-22T23:00:00+00:00 PythonOperator 01-23T23:00:19.428425+00:00 01-23T23:00:20.585480+00:00 0:00:01.157055 474526 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-23T23:00:17.579035+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-21T23:00:00+00:00 EmrJobFlowSensor 01-22T23:00:51.634939+00:00 01-22T23:10:53.409018+00:00 0:10:01.774079 474105 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-22T23:00:49.551737+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-21T23:00:00+00:00 EmrCreateJobFlowOperator 01-22T23:00:29.105359+00:00 01-22T23:00:29.883642+00:00 0:00:00.778283 474101 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-22T23:00:27.407821+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-21T23:00:00+00:00 PythonOperator 01-22T23:00:09.413972+00:00 01-22T23:00:11.236753+00:00 0:00:01.822781 474099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-22T23:00:07.396082+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-20T23:00:00+00:00 EmrJobFlowSensor 01-21T23:00:59.333921+00:00 01-21T23:12:01.232416+00:00 0:11:01.898495 473707 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-21T23:00:57.186593+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-20T23:00:00+00:00 EmrCreateJobFlowOperator 01-21T23:00:39.591195+00:00 01-21T23:00:40.288992+00:00 0:00:00.697797 473704 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-21T23:00:37.135776+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-20T23:00:00+00:00 PythonOperator 01-21T23:00:17.261442+00:00 01-21T23:00:18.455306+00:00 0:00:01.193864 473701 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-21T23:00:15.184723+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-19T23:00:00+00:00 EmrJobFlowSensor 01-20T23:00:58.320871+00:00 01-20T23:10:59.986911+00:00 0:10:01.666040 473302 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-20T23:00:56.625434+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-19T23:00:00+00:00 EmrCreateJobFlowOperator 01-20T23:00:36.816421+00:00 01-20T23:00:37.562510+00:00 0:00:00.746089 473299 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-20T23:00:34.654996+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-19T23:00:00+00:00 PythonOperator 01-20T23:00:16.759863+00:00 01-20T23:00:17.925147+00:00 0:00:01.165284 473296 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-20T23:00:14.590291+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-18T23:00:00+00:00 EmrJobFlowSensor 01-19T23:01:56.303791+00:00 01-19T23:10:58.129461+00:00 0:09:01.825670 472899 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-19T23:01:54.647941+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-18T23:00:00+00:00 EmrCreateJobFlowOperator 01-19T23:00:34.504713+00:00 01-19T23:00:35.324236+00:00 0:00:00.819523 472895 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-19T23:00:32.778388+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-18T23:00:00+00:00 PythonOperator 01-19T23:00:12.412063+00:00 01-19T23:00:13.518028+00:00 0:00:01.105965 472892 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-19T23:00:10.759666+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-17T23:00:00+00:00 EmrJobFlowSensor 01-18T23:01:02.958521+00:00 01-18T23:11:04.743027+00:00 0:10:01.784506 472487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-18T23:01:00.900697+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-17T23:00:00+00:00 EmrCreateJobFlowOperator 01-18T23:00:42.530342+00:00 01-18T23:00:43.311176+00:00 0:00:00.780834 472484 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-18T23:00:40.879562+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-17T23:00:00+00:00 PythonOperator 01-18T23:00:20.950375+00:00 01-18T23:00:22.135918+00:00 0:00:01.185543 472481 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-18T23:00:18.858552+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-16T23:00:00+00:00 EmrJobFlowSensor 01-17T23:00:46.920648+00:00 01-17T23:11:48.790715+00:00 0:11:01.870067 472072 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-17T23:00:44.849469+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-16T23:00:00+00:00 EmrCreateJobFlowOperator 01-17T23:00:24.922354+00:00 01-17T23:00:25.674173+00:00 0:00:00.751819 472069 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-17T23:00:22.817417+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-16T23:00:00+00:00 PythonOperator 01-17T23:00:04.618826+00:00 01-17T23:00:05.673176+00:00 0:00:01.054350 472066 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-17T23:00:02.804204+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-15T23:00:00+00:00 EmrJobFlowSensor 01-16T23:00:57.336954+00:00 01-16T23:10:59.069115+00:00 0:10:01.732161 471662 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-16T23:00:55.265290+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-15T23:00:00+00:00 EmrCreateJobFlowOperator 01-16T23:00:34.907513+00:00 01-16T23:00:35.651494+00:00 0:00:00.743981 471658 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-16T23:00:33.243937+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-15T23:00:00+00:00 PythonOperator 01-16T23:00:15.107368+00:00 01-16T23:00:16.250835+00:00 0:00:01.143467 471655 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-16T23:00:13.226978+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-14T23:00:00+00:00 EmrJobFlowSensor 01-15T23:00:50.393054+00:00 01-15T23:11:52.252581+00:00 0:11:01.859527 471245 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-15T23:00:48.752415+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-14T23:00:00+00:00 EmrCreateJobFlowOperator 01-15T23:00:30.630165+00:00 01-15T23:00:31.753043+00:00 0:00:01.122878 471242 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-15T23:00:28.625236+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-14T23:00:00+00:00 PythonOperator 01-15T23:00:08.321352+00:00 01-15T23:00:09.398385+00:00 0:00:01.077033 471239 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-15T23:00:06.606843+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-13T23:00:00+00:00 EmrJobFlowSensor 01-14T23:00:47.148346+00:00 01-14T23:10:49.278720+00:00 0:10:02.130374 470826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-14T23:00:44.965786+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-13T23:00:00+00:00 EmrCreateJobFlowOperator 01-14T23:00:26.613864+00:00 01-14T23:00:27.397068+00:00 0:00:00.783204 470823 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-14T23:00:24.869883+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-13T23:00:00+00:00 PythonOperator 01-14T23:00:05.187759+00:00 01-14T23:00:06.340635+00:00 0:00:01.152876 470820 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-14T23:00:02.855065+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-12T23:00:00+00:00 EmrJobFlowSensor 01-13T23:00:45.719686+00:00 01-13T23:10:47.504733+00:00 0:10:01.785047 470383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-13T23:00:44.008193+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-12T23:00:00+00:00 EmrCreateJobFlowOperator 01-13T23:00:26.228958+00:00 01-13T23:00:27.210761+00:00 0:00:00.981803 470381 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-13T23:00:24.053306+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-12T23:00:00+00:00 PythonOperator 01-13T23:00:04.206941+00:00 01-13T23:00:05.308772+00:00 0:00:01.101831 470378 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-13T23:00:01.947841+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-11T23:00:00+00:00 EmrJobFlowSensor 01-12T23:01:03.359254+00:00 01-12T23:11:05.126179+00:00 0:10:01.766925 469937 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-12T23:01:01.303755+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-11T23:00:00+00:00 EmrCreateJobFlowOperator 01-12T23:00:41.411090+00:00 01-12T23:00:42.166117+00:00 0:00:00.755027 469933 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-12T23:00:39.349236+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-11T23:00:00+00:00 PythonOperator 01-12T23:00:03.471350+00:00 01-12T23:00:04.581560+00:00 0:00:01.110210 469929 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-12T23:00:01.249744+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-10T23:00:00+00:00 EmrJobFlowSensor 01-11T23:00:50.852193+00:00 01-11T23:10:52.646867+00:00 0:10:01.794674 469475 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-11T23:00:48.763064+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-10T23:00:00+00:00 EmrCreateJobFlowOperator 01-11T23:00:28.494053+00:00 01-11T23:00:29.495284+00:00 0:00:01.001231 469472 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-11T23:00:26.783157+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-10T23:00:00+00:00 PythonOperator 01-11T23:00:08.961934+00:00 01-11T23:00:10.062293+00:00 0:00:01.100359 469469 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-11T23:00:06.862371+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-09T23:00:00+00:00 EmrJobFlowSensor 01-10T23:01:06.815276+00:00 01-10T23:11:08.581510+00:00 0:10:01.766234 469008 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-10T23:01:04.777537+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-09T23:00:00+00:00 EmrCreateJobFlowOperator 01-10T23:00:43.165654+00:00 01-10T23:00:44.005129+00:00 0:00:00.839475 469006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-10T23:00:41.055805+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-09T23:00:00+00:00 PythonOperator 01-10T23:00:20.572589+00:00 01-10T23:00:21.640226+00:00 0:00:01.067637 469004 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-10T23:00:18.923255+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-08T23:00:00+00:00 EmrJobFlowSensor 01-09T23:00:47.522322+00:00 01-09T23:10:49.264123+00:00 0:10:01.741801 468580 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-09T23:00:45.824858+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-08T23:00:00+00:00 EmrCreateJobFlowOperator 01-09T23:00:25.629740+00:00 01-09T23:00:26.478298+00:00 0:00:00.848558 468577 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-09T23:00:23.859688+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-08T23:00:00+00:00 PythonOperator 01-09T23:00:06.004111+00:00 01-09T23:00:07.384591+00:00 0:00:01.380480 468574 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-09T23:00:03.780076+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-07T23:00:00+00:00 EmrJobFlowSensor 01-08T23:01:07.115408+00:00 01-08T23:11:08.796863+00:00 0:10:01.681455 468143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-08T23:01:04.988031+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-07T23:00:00+00:00 EmrCreateJobFlowOperator 01-08T23:00:45.217137+00:00 01-08T23:00:46.309718+00:00 0:00:01.092581 468139 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-08T23:00:42.921077+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-07T23:00:00+00:00 PythonOperator 01-08T23:00:22.711530+00:00 01-08T23:00:23.813652+00:00 0:00:01.102122 468135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-08T23:00:20.953779+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-06T23:00:00+00:00 EmrJobFlowSensor 01-07T23:00:57.434847+00:00 01-07T23:10:59.176517+00:00 0:10:01.741670 467701 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-07T23:00:55.284208+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-06T23:00:00+00:00 EmrCreateJobFlowOperator 01-07T23:00:34.874570+00:00 01-07T23:00:35.973038+00:00 0:00:01.098468 467698 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-07T23:00:33.220488+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-06T23:00:00+00:00 PythonOperator 01-07T23:00:15.282333+00:00 01-07T23:00:16.458186+00:00 0:00:01.175853 467695 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-07T23:00:13.202160+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-05T23:00:00+00:00 EmrJobFlowSensor 01-06T23:00:53.237299+00:00 01-06T23:11:55.192597+00:00 0:11:01.955298 467259 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-06T23:00:51.165169+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-05T23:00:00+00:00 EmrCreateJobFlowOperator 01-06T23:00:32.031213+00:00 01-06T23:00:32.755238+00:00 0:00:00.724025 467256 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-06T23:00:29.177253+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-05T23:00:00+00:00 PythonOperator 01-06T23:00:09.826553+00:00 01-06T23:00:11.001467+00:00 0:00:01.174914 467253 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-06T23:00:07.175010+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-04T23:00:00+00:00 EmrJobFlowSensor 01-05T23:00:46.836494+00:00 01-05T23:10:48.784903+00:00 0:10:01.948409 466821 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-05T23:00:44.323609+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-04T23:00:00+00:00 EmrCreateJobFlowOperator 01-05T23:00:24.404081+00:00 01-05T23:00:25.203722+00:00 0:00:00.799641 466818 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-05T23:00:22.359562+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-04T23:00:00+00:00 PythonOperator 01-05T23:00:04.559709+00:00 01-05T23:00:05.609440+00:00 0:00:01.049731 466815 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-05T23:00:02.283536+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-03T23:00:00+00:00 EmrJobFlowSensor 01-04T23:00:50.904972+00:00 01-04T23:10:52.574078+00:00 0:10:01.669106 466388 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-04T23:00:49.299542+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-03T23:00:00+00:00 EmrCreateJobFlowOperator 01-04T23:00:30.905251+00:00 01-04T23:00:31.934128+00:00 0:00:01.028877 466385 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-04T23:00:29.280743+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-03T23:00:00+00:00 PythonOperator 01-04T23:00:08.895446+00:00 01-04T23:00:09.970265+00:00 0:00:01.074819 466382 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-04T23:00:07.263171+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-02T23:00:00+00:00 EmrJobFlowSensor 01-03T23:00:54.429008+00:00 01-03T23:10:56.183567+00:00 0:10:01.754559 465949 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-03T23:00:52.284329+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-02T23:00:00+00:00 EmrCreateJobFlowOperator 01-03T23:00:34.423110+00:00 01-03T23:00:35.369847+00:00 0:00:00.946737 465946 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-03T23:00:32.196740+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-02T23:00:00+00:00 PythonOperator 01-03T23:00:12.038918+00:00 01-03T23:00:13.066209+00:00 0:00:01.027291 465943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-03T23:00:10.182858+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 01-01T23:00:00+00:00 EmrJobFlowSensor 01-02T23:00:46.564578+00:00 01-02T23:10:48.415522+00:00 0:10:01.850944 465515 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-02T23:00:44.378427+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 01-01T23:00:00+00:00 EmrCreateJobFlowOperator 01-02T23:00:26.938097+00:00 01-02T23:00:27.688627+00:00 0:00:00.750530 465512 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-02T23:00:24.362963+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 01-01T23:00:00+00:00 PythonOperator 01-02T23:00:04.420950+00:00 01-02T23:00:05.458997+00:00 0:00:01.038047 465508 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-02T23:00:02.286603+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-31T23:00:00+00:00 EmrJobFlowSensor 01-01T23:00:49.702334+00:00 01-01T23:10:51.433024+00:00 0:10:01.730690 465087 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 01-01T23:00:48.087209+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-31T23:00:00+00:00 EmrCreateJobFlowOperator 01-01T23:00:27.753075+00:00 01-01T23:00:28.546521+00:00 0:00:00.793446 465084 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 01-01T23:00:26.069690+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-31T23:00:00+00:00 PythonOperator 01-01T23:00:06.536412+00:00 01-01T23:00:07.677494+00:00 0:00:01.141082 465081 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 01-01T23:00:04.079567+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-30T23:00:00+00:00 EmrJobFlowSensor 2023-12-31T23:00:49.003675+00:00 2023-12-31T23:10:50.712310+00:00 0:10:01.708635 464666 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-31T23:00:47.407176+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-31T23:00:27.025166+00:00 2023-12-31T23:00:27.809161+00:00 0:00:00.783995 464663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-31T23:00:25.389699+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-30T23:00:00+00:00 PythonOperator 2023-12-31T23:00:05.844735+00:00 2023-12-31T23:00:06.885451+00:00 0:00:01.040716 464660 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-31T23:00:03.380311+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-29T23:00:00+00:00 EmrJobFlowSensor 2023-12-30T23:00:55.918661+00:00 2023-12-30T23:10:57.772127+00:00 0:10:01.853466 464243 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-30T23:00:54.185994+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-30T23:00:36.199465+00:00 2023-12-30T23:00:36.955545+00:00 0:00:00.756080 464240 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-30T23:00:34.159338+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-29T23:00:00+00:00 PythonOperator 2023-12-30T23:00:13.799104+00:00 2023-12-30T23:00:14.820594+00:00 0:00:01.021490 464237 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-30T23:00:12.155377+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-28T23:00:00+00:00 EmrJobFlowSensor 2023-12-29T23:01:05.916250+00:00 2023-12-29T23:12:07.751316+00:00 0:11:01.835066 463818 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T23:01:04.302722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T23:00:44.458315+00:00 2023-12-29T23:00:45.288526+00:00 0:00:00.830211 463815 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T23:00:42.287189+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-28T23:00:00+00:00 PythonOperator 2023-12-29T23:00:22.528982+00:00 2023-12-29T23:00:23.600685+00:00 0:00:01.071703 463812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T23:00:20.277396+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-27T23:00:00+00:00 EmrJobFlowSensor 2023-12-28T23:01:24.790976+00:00 2023-12-28T23:11:26.794882+00:00 0:10:02.003906 463390 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-28T23:01:22.688575+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-28T23:01:02.654080+00:00 2023-12-28T23:01:03.398553+00:00 0:00:00.744473 463387 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-28T23:01:00.619494+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-27T23:00:00+00:00 PythonOperator 2023-12-28T23:00:42.653065+00:00 2023-12-28T23:00:43.692250+00:00 0:00:01.039185 463384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-28T23:00:40.601330+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-26T23:00:00+00:00 EmrJobFlowSensor 2023-12-27T23:00:53.537061+00:00 2023-12-27T23:10:55.273212+00:00 0:10:01.736151 462954 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-27T23:00:51.452291+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T23:00:31.541404+00:00 2023-12-27T23:00:32.221890+00:00 0:00:00.680486 462951 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T23:00:29.379146+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-26T23:00:00+00:00 PythonOperator 2023-12-27T23:00:11.318131+00:00 2023-12-27T23:00:12.344606+00:00 0:00:01.026475 462948 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T23:00:09.365359+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-25T23:00:00+00:00 EmrJobFlowSensor 2023-12-26T23:00:56.731870+00:00 2023-12-26T23:10:58.731821+00:00 0:10:01.999951 462508 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T23:00:54.691878+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-12-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T23:00:36.299022+00:00 2023-12-26T23:00:37.054194+00:00 0:00:00.755172 462505 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T23:00:34.668704+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-12-25T23:00:00+00:00 PythonOperator 2023-12-26T23:00:15.208532+00:00 2023-12-26T23:00:16.279172+00:00 0:00:01.070640 462503 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T23:00:12.684912+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-12-24T23:00:00+00:00 EmrJobFlowSensor 2023-12-25T23:01:02.657351+00:00 2023-12-25T23:12:04.527703+00:00 0:11:01.870352 462075 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T23:01:00.486042+00:00 2 default_pool