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 06-25T23:00:00+00:00 EmrJobFlowSensor 06-26T23:01:19.442914+00:00 06-26T23:11:21.422012+00:00 0:10:01.979098 564871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-26T23:01:17.384385+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-25T23:00:00+00:00 EmrCreateJobFlowOperator 06-26T23:00:59.823406+00:00 06-26T23:01:01.005730+00:00 0:00:01.182324 564868 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-26T23:00:55.312504+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-25T23:00:00+00:00 PythonOperator 06-26T23:00:18.881807+00:00 06-26T23:00:20.065860+00:00 0:00:01.184053 564864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-26T23:00:17.114541+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-24T23:00:00+00:00 EmrJobFlowSensor 06-25T23:01:15.510303+00:00 06-25T23:12:17.767962+00:00 0:11:02.257659 564385 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-25T23:01:13.731287+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-24T23:00:00+00:00 EmrCreateJobFlowOperator 06-25T23:00:36.339210+00:00 06-25T23:00:37.465605+00:00 0:00:01.126395 564381 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-25T23:00:31.660901+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-24T23:00:00+00:00 PythonOperator 06-25T23:00:06.383816+00:00 06-25T23:00:07.540119+00:00 0:00:01.156303 564377 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-25T23:00:03.449836+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-23T23:00:00+00:00 EmrJobFlowSensor 06-24T23:01:16.391642+00:00 06-24T23:12:18.570438+00:00 0:11:02.178796 563908 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-24T23:01:13.999156+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-23T23:00:00+00:00 EmrCreateJobFlowOperator 06-24T23:00:53.945696+00:00 06-24T23:00:54.844267+00:00 0:00:00.898571 563905 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-24T23:00:51.941693+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-23T23:00:00+00:00 PythonOperator 06-24T23:00:18.130154+00:00 06-24T23:00:20.743317+00:00 0:00:02.613163 563902 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-24T23:00:12.542499+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-22T23:00:00+00:00 EmrJobFlowSensor 06-23T23:01:21.031679+00:00 06-23T23:11:23.493011+00:00 0:10:02.461332 563428 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-23T23:01:17.415726+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-22T23:00:00+00:00 EmrCreateJobFlowOperator 06-23T23:00:59.681029+00:00 06-23T23:01:00.566599+00:00 0:00:00.885570 563425 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-23T23:00:56.878676+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-22T23:00:00+00:00 PythonOperator 06-23T23:00:12.639162+00:00 06-23T23:00:15.905391+00:00 0:00:03.266229 563420 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-23T23:00:07.380872+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-21T23:00:00+00:00 EmrJobFlowSensor 06-22T23:01:33.638304+00:00 06-22T23:11:35.641772+00:00 0:10:02.003468 562951 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-22T23:01:31.848807+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-21T23:00:00+00:00 EmrCreateJobFlowOperator 06-22T23:01:13.766619+00:00 06-22T23:01:15.006283+00:00 0:00:01.239664 562948 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-22T23:01:09.846130+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-21T23:00:00+00:00 PythonOperator 06-22T23:00:28.617748+00:00 06-22T23:00:30.369544+00:00 0:00:01.751796 562944 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-22T23:00:20.850444+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-20T23:00:00+00:00 EmrJobFlowSensor 06-21T23:00:58.121022+00:00 06-21T23:12:00.361717+00:00 0:11:02.240695 562468 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-21T23:00:55.835363+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-20T23:00:00+00:00 EmrCreateJobFlowOperator 06-21T23:00:31.978069+00:00 06-21T23:00:33.074864+00:00 0:00:01.096795 562466 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-21T23:00:28.543804+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-20T23:00:00+00:00 PythonOperator 06-21T23:00:04.957690+00:00 06-21T23:00:06.251123+00:00 0:00:01.293433 562462 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-21T23:00:02.516066+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-19T23:00:00+00:00 EmrJobFlowSensor 06-20T23:14:40.792825+00:00 06-20T23:14:41.327647+00:00 0:00:00.534822 561992 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-20T23:14:38.485429+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-19T23:00:00+00:00 EmrCreateJobFlowOperator 06-20T23:01:13.107444+00:00 06-20T23:01:14.082777+00:00 0:00:00.975333 561984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-20T23:01:11.090658+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-19T23:00:00+00:00 PythonOperator 06-20T23:00:24.187894+00:00 06-20T23:00:25.329755+00:00 0:00:01.141861 561979 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-20T23:00:22.334656+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-18T23:00:00+00:00 EmrJobFlowSensor 06-20T07:14:36.614217+00:00 06-20T07:23:38.814438+00:00 0:09:02.200221 561592 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-20T07:14:33.046186+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-18T23:00:00+00:00 EmrCreateJobFlowOperator 06-20T07:12:40.911976+00:00 06-20T07:12:43.424207+00:00 0:00:02.512231 561447 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-20T07:08:52.455261+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-18T23:00:00+00:00 PythonOperator 06-20T06:45:33.600029+00:00 06-20T06:45:46.408782+00:00 0:00:12.808753 559726 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-20T06:38:46.203800+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-17T23:00:00+00:00 EmrJobFlowSensor 06-18T23:00:54.352852+00:00 06-18T23:10:56.125728+00:00 0:10:01.772876 558808 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-18T23:00:52.614337+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-17T23:00:00+00:00 EmrCreateJobFlowOperator 06-18T23:00:27.615275+00:00 06-18T23:00:28.638422+00:00 0:00:01.023147 558805 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-18T23:00:24.569246+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-17T23:00:00+00:00 PythonOperator 06-18T23:00:04.651446+00:00 06-18T23:00:05.986427+00:00 0:00:01.334981 558801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-18T23:00:02.422641+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-16T23:00:00+00:00 EmrJobFlowSensor 06-17T23:00:56.027569+00:00 06-17T23:10:57.766590+00:00 0:10:01.739021 558330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-17T23:00:54.341712+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-16T23:00:00+00:00 EmrCreateJobFlowOperator 06-17T23:00:32.998026+00:00 06-17T23:00:33.846211+00:00 0:00:00.848185 558328 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-17T23:00:30.332500+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-16T23:00:00+00:00 PythonOperator 06-17T23:00:10.513013+00:00 06-17T23:00:11.506475+00:00 0:00:00.993462 558324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-17T23:00:08.248940+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-15T23:00:00+00:00 EmrJobFlowSensor 06-16T23:00:54.408339+00:00 06-16T23:11:56.294699+00:00 0:11:01.886360 557850 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-16T23:00:52.592928+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-15T23:00:00+00:00 EmrCreateJobFlowOperator 06-16T23:00:29.012246+00:00 06-16T23:00:29.851889+00:00 0:00:00.839643 557847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-16T23:00:26.562356+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-15T23:00:00+00:00 PythonOperator 06-16T23:00:07.385904+00:00 06-16T23:00:08.780301+00:00 0:00:01.394397 557844 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-16T23:00:04.534163+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-14T23:00:00+00:00 EmrJobFlowSensor 06-15T23:01:02.463856+00:00 06-15T23:11:04.187683+00:00 0:10:01.723827 557373 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-15T23:01:00.713761+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-14T23:00:00+00:00 EmrCreateJobFlowOperator 06-15T23:00:43.064408+00:00 06-15T23:00:43.872426+00:00 0:00:00.808018 557370 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-15T23:00:40.561428+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-14T23:00:00+00:00 PythonOperator 06-15T23:00:19.038238+00:00 06-15T23:00:19.989809+00:00 0:00:00.951571 557367 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-15T23:00:16.496312+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-13T23:00:00+00:00 EmrJobFlowSensor 06-14T23:01:05.431743+00:00 06-14T23:11:07.182051+00:00 0:10:01.750308 556894 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-14T23:01:03.785880+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-13T23:00:00+00:00 EmrCreateJobFlowOperator 06-14T23:00:46.199896+00:00 06-14T23:00:47.303879+00:00 0:00:01.103983 556891 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-14T23:00:43.778333+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-13T23:00:00+00:00 PythonOperator 06-14T23:00:17.375182+00:00 06-14T23:00:18.562867+00:00 0:00:01.187685 556887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-14T23:00:15.700393+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-12T23:00:00+00:00 EmrJobFlowSensor 06-13T23:11:38.312057+00:00 06-13T23:11:38.819644+00:00 0:00:00.507587 556422 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-13T23:11:35.647556+00:00 4 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-12T23:00:00+00:00 EmrCreateJobFlowOperator 06-13T23:00:32.878710+00:00 06-13T23:00:33.610530+00:00 0:00:00.731820 556408 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-13T23:00:31.120173+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-12T23:00:00+00:00 PythonOperator 06-13T23:00:13.853962+00:00 06-13T23:00:16.418108+00:00 0:00:02.564146 556405 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-13T23:00:10.727140+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-11T23:00:00+00:00 EmrJobFlowSensor 06-12T23:09:42.183806+00:00 06-12T23:10:42.979156+00:00 0:01:00.795350 555926 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-12T23:09:39.169514+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-11T23:00:00+00:00 EmrCreateJobFlowOperator 06-12T23:00:34.634771+00:00 06-12T23:00:35.544274+00:00 0:00:00.909503 555913 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-12T23:00:32.423703+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-11T23:00:00+00:00 PythonOperator 06-12T23:00:12.823545+00:00 06-12T23:00:13.959325+00:00 0:00:01.135780 555909 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-12T23:00:10.225875+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-10T23:00:00+00:00 EmrJobFlowSensor 06-11T23:00:58.329074+00:00 06-11T23:12:00.198858+00:00 0:11:01.869784 555421 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-11T23:00:56.749935+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-10T23:00:00+00:00 EmrCreateJobFlowOperator 06-11T23:00:36.424636+00:00 06-11T23:00:37.216273+00:00 0:00:00.791637 555418 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-11T23:00:34.697547+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-10T23:00:00+00:00 PythonOperator 06-11T23:00:15.431311+00:00 06-11T23:00:16.771881+00:00 0:00:01.340570 555415 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-11T23:00:12.740785+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-09T23:00:00+00:00 EmrJobFlowSensor 06-10T23:01:43.473953+00:00 06-10T23:11:45.246337+00:00 0:10:01.772384 554919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-10T23:01:41.868535+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-09T23:00:00+00:00 EmrCreateJobFlowOperator 06-10T23:00:49.391008+00:00 06-10T23:00:50.475829+00:00 0:00:01.084821 554914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-10T23:00:44.516644+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-09T23:00:00+00:00 PythonOperator 06-10T23:00:24.219395+00:00 06-10T23:00:25.092164+00:00 0:00:00.872769 554910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-10T23:00:22.431787+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-08T23:00:00+00:00 EmrJobFlowSensor 06-09T23:01:04.353225+00:00 06-09T23:11:06.246099+00:00 0:10:01.892874 554425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-09T23:00:58.851988+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-08T23:00:00+00:00 EmrCreateJobFlowOperator 06-09T23:00:40.540411+00:00 06-09T23:00:41.184549+00:00 0:00:00.644138 554422 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-09T23:00:38.822328+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-08T23:00:00+00:00 PythonOperator 06-09T23:00:23.956824+00:00 06-09T23:00:25.880896+00:00 0:00:01.924072 554419 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-09T23:00:16.723278+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-07T23:00:00+00:00 EmrJobFlowSensor 06-08T23:01:42.595366+00:00 06-08T23:11:44.571680+00:00 0:10:01.976314 553937 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-08T23:01:40.250723+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-07T23:00:00+00:00 EmrCreateJobFlowOperator 06-08T23:00:43.768470+00:00 06-08T23:00:44.653397+00:00 0:00:00.884927 553932 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-08T23:00:41.484947+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-07T23:00:00+00:00 PythonOperator 06-08T23:00:21.904743+00:00 06-08T23:00:22.847663+00:00 0:00:00.942920 553929 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-08T23:00:19.463855+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-06T23:00:00+00:00 EmrJobFlowSensor 06-07T23:01:13.554221+00:00 06-07T23:11:16.002315+00:00 0:10:02.448094 553447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-07T23:01:09.817316+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-06T23:00:00+00:00 EmrCreateJobFlowOperator 06-07T23:00:47.567109+00:00 06-07T23:00:48.378591+00:00 0:00:00.811482 553444 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-07T23:00:43.863828+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-06T23:00:00+00:00 PythonOperator 06-07T23:00:28.573759+00:00 06-07T23:00:30.206592+00:00 0:00:01.632833 553441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-07T23:00:23.756732+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-05T23:00:00+00:00 EmrJobFlowSensor 06-06T23:00:55.892479+00:00 06-06T23:11:57.780645+00:00 0:11:01.888166 552960 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-06T23:00:53.987607+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-05T23:00:00+00:00 EmrCreateJobFlowOperator 06-06T23:00:29.460072+00:00 06-06T23:00:30.146900+00:00 0:00:00.686828 552958 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-06T23:00:27.891691+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-05T23:00:00+00:00 PythonOperator 06-06T23:00:07.569273+00:00 06-06T23:00:08.408475+00:00 0:00:00.839202 552954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-06T23:00:05.819676+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-04T23:00:00+00:00 EmrJobFlowSensor 06-06T10:09:22.979011+00:00 06-06T10:19:30.795870+00:00 0:10:07.816859 552608 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-06T10:08:32.956122+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-04T23:00:00+00:00 EmrCreateJobFlowOperator 06-06T10:08:06.667622+00:00 06-06T10:08:09.062498+00:00 0:00:02.394876 552555 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-06T10:07:58.881908+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-04T23:00:00+00:00 PythonOperator 06-06T10:07:21.406654+00:00 06-06T10:07:40.006609+00:00 0:00:18.599955 552532 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-06T10:06:20.524396+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-03T23:00:00+00:00 EmrJobFlowSensor 06-04T23:00:55.832478+00:00 06-04T23:11:57.969386+00:00 0:11:02.136908 552034 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-04T23:00:53.720961+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-03T23:00:00+00:00 EmrCreateJobFlowOperator 06-04T23:00:33.672023+00:00 06-04T23:00:34.573638+00:00 0:00:00.901615 552031 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-04T23:00:31.610222+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-03T23:00:00+00:00 PythonOperator 06-04T23:00:11.635301+00:00 06-04T23:00:12.600616+00:00 0:00:00.965315 552028 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-04T23:00:09.587634+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-02T23:00:00+00:00 EmrJobFlowSensor 06-03T23:12:58.686780+00:00 06-03T23:12:59.282073+00:00 0:00:00.595293 551555 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-03T23:12:56.053077+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-02T23:00:00+00:00 EmrCreateJobFlowOperator 06-03T23:00:45.313211+00:00 06-03T23:00:46.228401+00:00 0:00:00.915190 551544 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-03T23:00:42.610198+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-02T23:00:00+00:00 PythonOperator 06-03T23:00:22.643580+00:00 06-03T23:00:23.764571+00:00 0:00:01.120991 551541 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-03T23:00:20.548248+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 06-01T23:00:00+00:00 EmrJobFlowSensor 06-02T23:01:16.354599+00:00 06-02T23:12:18.490058+00:00 0:11:02.135459 551052 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-02T23:01:13.718370+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 06-01T23:00:00+00:00 EmrCreateJobFlowOperator 06-02T23:00:53.802893+00:00 06-02T23:00:54.632584+00:00 0:00:00.829691 551049 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-02T23:00:51.703216+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 06-01T23:00:00+00:00 PythonOperator 06-02T23:00:34.529005+00:00 06-02T23:00:36.130722+00:00 0:00:01.601717 551046 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-02T23:00:31.687617+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-31T23:00:00+00:00 EmrJobFlowSensor 06-01T23:01:09.001537+00:00 06-01T23:12:11.100831+00:00 0:11:02.099294 550568 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 06-01T23:01:05.237613+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-31T23:00:00+00:00 EmrCreateJobFlowOperator 06-01T23:00:47.460964+00:00 06-01T23:00:48.408594+00:00 0:00:00.947630 550565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 06-01T23:00:43.219737+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-31T23:00:00+00:00 PythonOperator 06-01T23:00:25.351869+00:00 06-01T23:00:26.511003+00:00 0:00:01.159134 550560 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 06-01T23:00:23.202678+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-30T23:00:00+00:00 EmrJobFlowSensor 05-31T23:01:18.533039+00:00 05-31T23:12:21.283423+00:00 0:11:02.750384 550075 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-31T23:01:14.423266+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-30T23:00:00+00:00 EmrCreateJobFlowOperator 05-31T23:00:57.098012+00:00 05-31T23:00:58.018522+00:00 0:00:00.920510 550072 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-31T23:00:54.400953+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-30T23:00:00+00:00 PythonOperator 05-31T23:00:34.522468+00:00 05-31T23:00:35.747929+00:00 0:00:01.225461 550069 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-31T23:00:32.387626+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-29T23:00:00+00:00 EmrJobFlowSensor 05-30T23:00:47.043917+00:00 05-30T23:10:49.237989+00:00 0:10:02.194072 549579 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-30T23:00:44.065797+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-29T23:00:00+00:00 EmrCreateJobFlowOperator 05-30T23:00:26.673012+00:00 05-30T23:00:27.599206+00:00 0:00:00.926194 549576 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-30T23:00:24.036976+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-29T23:00:00+00:00 PythonOperator 05-30T23:00:05.078502+00:00 05-30T23:00:06.959703+00:00 0:00:01.881201 549572 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-30T23:00:02.019336+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-28T23:00:00+00:00 EmrJobFlowSensor 05-29T23:01:03.896203+00:00 05-29T23:12:05.928343+00:00 0:11:02.032140 549099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-29T23:01:01.788813+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-28T23:00:00+00:00 EmrCreateJobFlowOperator 05-29T23:00:42.510127+00:00 05-29T23:00:43.502074+00:00 0:00:00.991947 549096 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-29T23:00:39.769383+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-28T23:00:00+00:00 PythonOperator 05-29T23:00:18.416355+00:00 05-29T23:00:19.754063+00:00 0:00:01.337708 549092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-29T23:00:15.752450+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-27T23:00:00+00:00 EmrJobFlowSensor 05-28T23:01:07.268170+00:00 05-28T23:12:09.300186+00:00 0:11:02.032016 548602 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-28T23:01:05.117104+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-27T23:00:00+00:00 EmrCreateJobFlowOperator 05-28T23:00:43.483931+00:00 05-28T23:00:44.331359+00:00 0:00:00.847428 548599 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-28T23:00:41.187510+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-27T23:00:00+00:00 PythonOperator 05-28T23:00:19.170723+00:00 05-28T23:00:20.373475+00:00 0:00:01.202752 548596 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-28T23:00:17.026483+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-26T23:00:00+00:00 EmrJobFlowSensor 05-27T23:00:50.406408+00:00 05-27T23:11:52.528139+00:00 0:11:02.121731 548109 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-27T23:00:47.297622+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-26T23:00:00+00:00 EmrCreateJobFlowOperator 05-27T23:00:29.828669+00:00 05-27T23:00:30.680411+00:00 0:00:00.851742 548106 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-27T23:00:27.290784+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-26T23:00:00+00:00 PythonOperator 05-27T23:00:08.500824+00:00 05-27T23:00:09.936442+00:00 0:00:01.435618 548103 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-27T23:00:05.219322+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-25T23:00:00+00:00 EmrJobFlowSensor 05-26T23:13:07.020145+00:00 05-26T23:13:07.573519+00:00 0:00:00.553374 547612 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-26T23:13:04.866268+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-25T23:00:00+00:00 EmrCreateJobFlowOperator 05-26T23:00:51.712013+00:00 05-26T23:00:52.544130+00:00 0:00:00.832117 547598 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-26T23:00:49.341337+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-25T23:00:00+00:00 PythonOperator 05-26T23:00:15.791519+00:00 05-26T23:00:16.975764+00:00 0:00:01.184245 547596 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-26T23:00:13.621974+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-24T23:00:00+00:00 EmrJobFlowSensor 05-25T23:13:13.951158+00:00 05-25T23:13:14.489342+00:00 0:00:00.538184 547111 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-25T23:13:10.853219+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-24T23:00:00+00:00 EmrCreateJobFlowOperator 05-25T23:01:04.902617+00:00 05-25T23:01:05.744079+00:00 0:00:00.841462 547101 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-25T23:01:02.624877+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-24T23:00:00+00:00 PythonOperator 05-25T23:00:19.435354+00:00 05-25T23:00:21.731440+00:00 0:00:02.296086 547096 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-25T23:00:15.407629+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-23T23:00:00+00:00 EmrJobFlowSensor 05-24T23:13:01.945976+00:00 05-24T23:13:02.456938+00:00 0:00:00.510962 546620 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-24T23:12:59.201387+00:00 3 default_pool