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 05-03T23:00:00+00:00 EmrJobFlowSensor 05-04T23:12:07.539256+00:00 05-04T23:12:08.194304+00:00 0:00:00.655048 536926 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-04T23:12:04.995458+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-03T23:00:00+00:00 EmrCreateJobFlowOperator 05-04T23:00:26.787592+00:00 05-04T23:00:27.470109+00:00 0:00:00.682517 536914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-04T23:00:25.026708+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-03T23:00:00+00:00 PythonOperator 05-04T23:00:05.395090+00:00 05-04T23:00:06.628872+00:00 0:00:01.233782 536910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-04T23:00:03.013624+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-02T23:00:00+00:00 EmrJobFlowSensor 05-03T23:01:01.678490+00:00 05-03T23:12:03.867906+00:00 0:11:02.189416 536445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-03T23:00:59.462483+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-02T23:00:00+00:00 EmrCreateJobFlowOperator 05-03T23:00:40.012250+00:00 05-03T23:00:41.512017+00:00 0:00:01.499767 536442 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-03T23:00:37.508069+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-02T23:00:00+00:00 PythonOperator 05-03T23:00:13.835598+00:00 05-03T23:00:16.418874+00:00 0:00:02.583276 536438 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-03T23:00:11.431298+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 05-01T23:00:00+00:00 EmrJobFlowSensor 05-02T23:13:12.223917+00:00 05-02T23:13:12.772768+00:00 0:00:00.548851 535961 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-02T23:13:09.828003+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 05-01T23:00:00+00:00 EmrCreateJobFlowOperator 05-02T23:00:37.210647+00:00 05-02T23:00:38.049554+00:00 0:00:00.838907 535947 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-02T23:00:35.036127+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 05-01T23:00:00+00:00 PythonOperator 05-02T23:00:09.362721+00:00 05-02T23:00:10.544799+00:00 0:00:01.182078 535943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-02T23:00:06.982346+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-30T23:00:00+00:00 EmrJobFlowSensor 05-01T23:01:09.127945+00:00 05-01T23:12:11.147479+00:00 0:11:02.019534 535451 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 05-01T23:01:06.713047+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-30T23:00:00+00:00 EmrCreateJobFlowOperator 05-01T23:00:46.981039+00:00 05-01T23:00:47.906141+00:00 0:00:00.925102 535449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 05-01T23:00:44.692523+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-30T23:00:00+00:00 PythonOperator 05-01T23:00:24.715696+00:00 05-01T23:00:25.883581+00:00 0:00:01.167885 535447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 05-01T23:00:22.457933+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-29T23:00:00+00:00 EmrJobFlowSensor 04-30T23:17:06.782806+00:00 04-30T23:17:07.332217+00:00 0:00:00.549411 534896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-30T23:17:04.134968+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-29T23:00:00+00:00 EmrCreateJobFlowOperator 04-30T23:00:32.368697+00:00 04-30T23:00:33.239660+00:00 0:00:00.870963 534883 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-30T23:00:30.190841+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-29T23:00:00+00:00 PythonOperator 04-30T23:00:10.344648+00:00 04-30T23:00:11.476131+00:00 0:00:01.131483 534881 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-30T23:00:08.166083+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-28T23:00:00+00:00 EmrJobFlowSensor 04-29T23:12:37.784121+00:00 04-29T23:12:38.332495+00:00 0:00:00.548374 534324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-29T23:12:35.248148+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-28T23:00:00+00:00 EmrCreateJobFlowOperator 04-29T23:00:27.520771+00:00 04-29T23:00:28.346397+00:00 0:00:00.825626 534311 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-29T23:00:25.229215+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-28T23:00:00+00:00 PythonOperator 04-29T23:00:05.944322+00:00 04-29T23:00:07.141456+00:00 0:00:01.197134 534308 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-29T23:00:03.204199+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-27T23:00:00+00:00 EmrJobFlowSensor 04-29T12:42:11.002116+00:00 04-29T12:51:14.055270+00:00 0:09:03.053154 534016 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-29T12:41:52.728572+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-26T23:00:00+00:00 EmrJobFlowSensor 04-29T12:41:55.548121+00:00 04-29T12:50:58.316155+00:00 0:09:02.768034 533998 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-29T12:41:52.728558+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-25T23:00:00+00:00 EmrJobFlowSensor 04-29T12:41:42.853848+00:00 04-29T12:41:45.960698+00:00 0:00:03.106850 533957 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-29T12:38:14.247423+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-27T23:00:00+00:00 EmrCreateJobFlowOperator 04-29T12:40:06.526673+00:00 04-29T12:40:13.816651+00:00 0:00:07.289978 533860 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-29T12:38:14.247408+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-26T23:00:00+00:00 EmrCreateJobFlowOperator 04-29T12:39:46.154261+00:00 04-29T12:39:53.369348+00:00 0:00:07.215087 533831 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-29T12:38:14.247377+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-25T23:00:00+00:00 EmrCreateJobFlowOperator 04-29T12:31:03.878761+00:00 04-29T12:31:10.300809+00:00 0:00:06.422048 533361 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-29T12:30:50.509341+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-27T23:00:00+00:00 PythonOperator 04-29T11:54:00.366073+00:00 04-29T11:54:32.976720+00:00 0:00:32.610647 531146 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-29T11:53:26.580300+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-26T23:00:00+00:00 PythonOperator 04-29T10:25:46.530041+00:00 04-29T10:26:02.432369+00:00 0:00:15.902328 525823 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-29T10:23:19.800276+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-25T23:00:00+00:00 PythonOperator 04-29T09:04:48.400823+00:00 04-29T09:05:06.153537+00:00 0:00:17.752714 520925 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-29T09:00:47.448047+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-24T23:00:00+00:00 EmrJobFlowSensor 04-25T23:00:58.233162+00:00 04-25T23:12:00.281852+00:00 0:11:02.048690 519622 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-25T23:00:55.813780+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-24T23:00:00+00:00 EmrCreateJobFlowOperator 04-25T23:00:38.250935+00:00 04-25T23:00:39.162415+00:00 0:00:00.911480 519619 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-25T23:00:35.732663+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-24T23:00:00+00:00 PythonOperator 04-25T23:00:17.171502+00:00 04-25T23:00:21.401617+00:00 0:00:04.230115 519615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-25T23:00:13.671637+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-23T23:00:00+00:00 EmrJobFlowSensor 04-24T23:00:51.919575+00:00 04-24T23:10:53.881557+00:00 0:10:01.961982 519136 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-24T23:00:49.713848+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-23T23:00:00+00:00 EmrCreateJobFlowOperator 04-24T23:00:32.122533+00:00 04-24T23:00:33.087510+00:00 0:00:00.964977 519133 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-24T23:00:29.636434+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-23T23:00:00+00:00 PythonOperator 04-24T23:00:03.925766+00:00 04-24T23:00:05.092308+00:00 0:00:01.166542 519129 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-24T23:00:01.559428+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-22T23:00:00+00:00 EmrJobFlowSensor 04-23T23:00:53.430034+00:00 04-23T23:10:55.252715+00:00 0:10:01.822681 518641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-23T23:00:51.250341+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-22T23:00:00+00:00 EmrCreateJobFlowOperator 04-23T23:00:31.306572+00:00 04-23T23:00:32.124886+00:00 0:00:00.818314 518638 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-23T23:00:29.158848+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-22T23:00:00+00:00 PythonOperator 04-23T23:00:11.437246+00:00 04-23T23:00:13.816571+00:00 0:00:02.379325 518634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-23T23:00:09.142155+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-21T23:00:00+00:00 EmrJobFlowSensor 04-22T23:00:48.678790+00:00 04-22T23:11:50.909115+00:00 0:11:02.230325 518141 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-22T23:00:45.144866+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-21T23:00:00+00:00 EmrCreateJobFlowOperator 04-22T23:00:33.067900+00:00 04-22T23:00:34.318966+00:00 0:00:01.251066 518139 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-22T23:00:25.041503+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-21T23:00:00+00:00 PythonOperator 04-22T23:00:06.007613+00:00 04-22T23:00:08.341933+00:00 0:00:02.334320 518135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-22T23:00:03.003763+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-20T23:00:00+00:00 EmrJobFlowSensor 04-21T23:15:37.599162+00:00 04-21T23:15:38.111235+00:00 0:00:00.512073 517658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-21T23:15:35.036458+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-20T23:00:00+00:00 EmrCreateJobFlowOperator 04-21T23:00:45.480256+00:00 04-21T23:00:46.822195+00:00 0:00:01.341939 517647 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-21T23:00:43.277208+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-20T23:00:00+00:00 PythonOperator 04-21T23:00:25.160615+00:00 04-21T23:00:27.508685+00:00 0:00:02.348070 517644 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-21T23:00:21.237723+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-19T23:00:00+00:00 EmrJobFlowSensor 04-20T23:13:21.785906+00:00 04-20T23:13:22.339292+00:00 0:00:00.553386 517166 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-20T23:13:19.350875+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-19T23:00:00+00:00 EmrCreateJobFlowOperator 04-20T23:00:41.745822+00:00 04-20T23:00:42.613060+00:00 0:00:00.867238 517154 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-20T23:00:39.287890+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-19T23:00:00+00:00 PythonOperator 04-20T23:00:19.716803+00:00 04-20T23:00:20.888202+00:00 0:00:01.171399 517150 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-20T23:00:17.276563+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-18T23:00:00+00:00 EmrJobFlowSensor 04-19T23:00:51.195592+00:00 04-19T23:11:53.195886+00:00 0:11:02.000294 516673 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-19T23:00:48.888077+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-18T23:00:00+00:00 EmrCreateJobFlowOperator 04-19T23:00:33.980968+00:00 04-19T23:00:34.817404+00:00 0:00:00.836436 516671 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-19T23:00:28.873942+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-18T23:00:00+00:00 PythonOperator 04-19T23:00:07.115395+00:00 04-19T23:00:08.273710+00:00 0:00:01.158315 516666 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-19T23:00:04.818288+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-17T23:00:00+00:00 EmrJobFlowSensor 04-18T23:14:57.614651+00:00 04-18T23:14:58.142346+00:00 0:00:00.527695 516181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-18T23:14:55.448117+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-17T23:00:00+00:00 EmrCreateJobFlowOperator 04-18T23:00:25.108196+00:00 04-18T23:00:26.094125+00:00 0:00:00.985929 516168 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-18T23:00:22.856814+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-17T23:00:00+00:00 PythonOperator 04-18T23:00:05.397063+00:00 04-18T23:00:06.561443+00:00 0:00:01.164380 516164 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-18T23:00:02.780766+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-16T23:00:00+00:00 EmrJobFlowSensor 04-17T23:00:56.030110+00:00 04-17T23:11:58.068818+00:00 0:11:02.038708 515657 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-17T23:00:53.733086+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-16T23:00:00+00:00 EmrCreateJobFlowOperator 04-17T23:00:33.934037+00:00 04-17T23:00:34.834948+00:00 0:00:00.900911 515654 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-17T23:00:31.713352+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-16T23:00:00+00:00 PythonOperator 04-17T23:00:10.369853+00:00 04-17T23:00:11.709512+00:00 0:00:01.339659 515651 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-17T23:00:07.760102+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-15T23:00:00+00:00 EmrJobFlowSensor 04-16T23:00:57.821467+00:00 04-16T23:10:59.478341+00:00 0:10:01.656874 515172 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-16T23:00:56.029069+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-15T23:00:00+00:00 EmrCreateJobFlowOperator 04-16T23:00:35.774768+00:00 04-16T23:00:36.492855+00:00 0:00:00.718087 515170 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-16T23:00:33.962171+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-15T23:00:00+00:00 PythonOperator 04-16T23:00:14.374901+00:00 04-16T23:00:15.475631+00:00 0:00:01.100730 515167 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-16T23:00:11.926651+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-14T23:00:00+00:00 EmrJobFlowSensor 04-16T10:14:21.201928+00:00 04-16T10:24:23.132413+00:00 0:10:01.930485 514778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-16T10:14:18.628616+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-14T23:00:00+00:00 EmrCreateJobFlowOperator 04-16T10:14:12.594673+00:00 04-16T10:14:14.185016+00:00 0:00:01.590343 514772 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-16T10:13:33.856310+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-14T23:00:00+00:00 PythonOperator 04-16T10:13:17.022852+00:00 04-16T10:13:26.855826+00:00 0:00:09.832974 514740 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-16T10:12:25.696061+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-13T23:00:00+00:00 EmrJobFlowSensor 04-14T23:13:03.695089+00:00 04-14T23:13:04.159520+00:00 0:00:00.464431 514177 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-14T23:13:01.911369+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-13T23:00:00+00:00 EmrCreateJobFlowOperator 04-14T23:00:38.172842+00:00 04-14T23:00:38.884666+00:00 0:00:00.711824 514167 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-14T23:00:36.078866+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-13T23:00:00+00:00 PythonOperator 04-14T23:00:18.163168+00:00 04-14T23:00:19.419640+00:00 0:00:01.256472 514164 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-14T23:00:16.067490+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-12T23:00:00+00:00 EmrJobFlowSensor 04-13T23:00:49.068191+00:00 04-13T23:10:50.906485+00:00 0:10:01.838294 513693 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-13T23:00:46.811362+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-12T23:00:00+00:00 EmrCreateJobFlowOperator 04-13T23:00:27.844417+00:00 04-13T23:00:28.574803+00:00 0:00:00.730386 513690 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-13T23:00:24.767466+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-12T23:00:00+00:00 PythonOperator 04-13T23:00:06.438543+00:00 04-13T23:00:07.394781+00:00 0:00:00.956238 513686 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-13T23:00:04.725089+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-11T23:00:00+00:00 EmrJobFlowSensor 04-12T23:01:02.032805+00:00 04-12T23:12:04.001445+00:00 0:11:01.968640 513206 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-12T23:01:00.251473+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-11T23:00:00+00:00 EmrCreateJobFlowOperator 04-12T23:00:40.375345+00:00 04-12T23:00:41.416234+00:00 0:00:01.040889 513204 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-12T23:00:38.223604+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-11T23:00:00+00:00 PythonOperator 04-12T23:00:17.916035+00:00 04-12T23:00:18.859535+00:00 0:00:00.943500 513200 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-12T23:00:16.191452+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-10T23:00:00+00:00 EmrJobFlowSensor 04-11T23:00:56.976010+00:00 04-11T23:10:58.801183+00:00 0:10:01.825173 512715 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-11T23:00:54.918958+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-10T23:00:00+00:00 EmrCreateJobFlowOperator 04-11T23:00:37.141358+00:00 04-11T23:00:37.957031+00:00 0:00:00.815673 512713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-11T23:00:34.904096+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-10T23:00:00+00:00 PythonOperator 04-11T23:00:15.185850+00:00 04-11T23:00:16.410412+00:00 0:00:01.224562 512711 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-11T23:00:12.937295+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-08T23:00:00+00:00 EmrJobFlowSensor 04-09T23:01:30.184611+00:00 04-09T23:11:31.859515+00:00 0:10:01.674904 511289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-09T23:01:28.153257+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-08T23:00:00+00:00 EmrCreateJobFlowOperator 04-09T23:01:04.011813+00:00 04-09T23:01:04.825241+00:00 0:00:00.813428 511286 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-09T23:01:02.133105+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-08T23:00:00+00:00 PythonOperator 04-09T23:00:42.565343+00:00 04-09T23:00:43.594367+00:00 0:00:01.029024 511283 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-09T23:00:40.114111+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-07T23:00:00+00:00 EmrJobFlowSensor 04-08T23:00:53.573662+00:00 04-08T23:10:55.239900+00:00 0:10:01.666238 510827 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-08T23:00:51.603588+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-07T23:00:00+00:00 EmrCreateJobFlowOperator 04-08T23:00:29.385401+00:00 04-08T23:00:30.230596+00:00 0:00:00.845195 510824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-08T23:00:27.507698+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-07T23:00:00+00:00 PythonOperator 04-08T23:00:07.547287+00:00 04-08T23:00:08.570615+00:00 0:00:01.023328 510820 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-08T23:00:05.488801+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-06T23:00:00+00:00 EmrJobFlowSensor 04-07T23:00:58.027533+00:00 04-07T23:10:59.887929+00:00 0:10:01.860396 510351 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-07T23:00:56.131699+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-06T23:00:00+00:00 EmrCreateJobFlowOperator 04-07T23:00:36.513662+00:00 04-07T23:00:37.355645+00:00 0:00:00.841983 510348 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-07T23:00:34.115026+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-06T23:00:00+00:00 PythonOperator 04-07T23:00:18.159260+00:00 04-07T23:00:19.161436+00:00 0:00:01.002176 510346 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-07T23:00:16.148229+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-05T23:00:00+00:00 EmrJobFlowSensor 04-06T23:01:09.228579+00:00 04-06T23:11:11.099211+00:00 0:10:01.870632 510008 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-06T23:01:06.756775+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-05T23:00:00+00:00 EmrCreateJobFlowOperator 04-06T23:00:42.496388+00:00 04-06T23:00:43.300097+00:00 0:00:00.803709 510005 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-06T23:00:40.457506+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-05T23:00:00+00:00 PythonOperator 04-06T23:00:20.404785+00:00 04-06T23:00:21.483517+00:00 0:00:01.078732 510002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-06T23:00:18.418615+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-04T23:00:00+00:00 EmrJobFlowSensor 04-05T23:00:48.816660+00:00 04-05T23:10:50.708846+00:00 0:10:01.892186 509517 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-05T23:00:46.744553+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-04T23:00:00+00:00 EmrCreateJobFlowOperator 04-05T23:00:26.810000+00:00 04-05T23:00:27.666354+00:00 0:00:00.856354 509514 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-05T23:00:24.731344+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-04T23:00:00+00:00 PythonOperator 04-05T23:00:06.908831+00:00 04-05T23:00:07.960812+00:00 0:00:01.051981 509510 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-05T23:00:04.702466+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-03T23:00:00+00:00 EmrJobFlowSensor 04-04T23:12:45.610738+00:00 04-04T23:12:46.142143+00:00 0:00:00.531405 509032 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-04T23:12:43.645683+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-03T23:00:00+00:00 EmrCreateJobFlowOperator 04-04T23:00:28.021631+00:00 04-04T23:00:28.719973+00:00 0:00:00.698342 509019 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-04T23:00:25.811484+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-03T23:00:00+00:00 PythonOperator 04-04T23:00:08.253613+00:00 04-04T23:00:09.299439+00:00 0:00:01.045826 509016 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-04T23:00:05.786788+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-02T23:00:00+00:00 EmrJobFlowSensor 04-03T23:01:03.030819+00:00 04-03T23:12:04.968822+00:00 0:11:01.938003 508616 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-03T23:01:01.424343+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-02T23:00:00+00:00 EmrCreateJobFlowOperator 04-03T23:00:44.482942+00:00 04-03T23:00:45.481691+00:00 0:00:00.998749 508614 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-03T23:00:41.402058+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-02T23:00:00+00:00 PythonOperator 04-03T23:00:21.048362+00:00 04-03T23:00:22.174909+00:00 0:00:01.126547 508610 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-03T23:00:19.382025+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 04-01T23:00:00+00:00 EmrJobFlowSensor 04-02T23:00:58.042617+00:00 04-02T23:12:00.000734+00:00 0:11:01.958117 508298 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T23:00:56.102521+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 04-01T23:00:00+00:00 EmrCreateJobFlowOperator 04-02T23:00:36.795238+00:00 04-02T23:00:37.503282+00:00 0:00:00.708044 508295 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T23:00:34.084108+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 04-01T23:00:00+00:00 PythonOperator 04-02T23:00:15.785397+00:00 04-02T23:00:17.640123+00:00 0:00:01.854726 508291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T23:00:14.070180+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-31T23:00:00+00:00 EmrJobFlowSensor 04-01T23:12:37.568762+00:00 04-01T23:12:38.263677+00:00 0:00:00.694915 507972 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T23:12:34.347503+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 03-31T23:00:00+00:00 EmrCreateJobFlowOperator 04-01T23:00:29.613595+00:00 04-01T23:00:30.369927+00:00 0:00:00.756332 507961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T23:00:27.710764+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 03-31T23:00:00+00:00 PythonOperator 04-01T23:00:09.004996+00:00 04-01T23:00:10.742546+00:00 0:00:01.737550 507957 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T23:00:05.691460+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 03-30T23:00:00+00:00 EmrJobFlowSensor 03-31T23:12:33.922901+00:00 03-31T23:12:34.352233+00:00 0:00:00.429332 507628 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 03-31T23:12:31.933075+00:00 3 default_pool