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 create_emr_steps 2023-05-11T23:00:00+00:00 PythonOperator 2023-05-12T23:00:10.871507+00:00 2023-05-12T23:00:12.998122+00:00 0:00:02.126615 378079 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T23:00:07.788567+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-10T23:00:00+00:00 EmrJobFlowSensor 2023-05-11T23:01:00.352643+00:00 2023-05-11T23:12:02.404034+00:00 0:11:02.051391 377486 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T23:00:57.699348+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T23:00:40.096151+00:00 2023-05-11T23:00:40.947743+00:00 0:00:00.851592 377483 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-11T23:00:37.679998+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-10T23:00:00+00:00 PythonOperator 2023-05-11T23:00:17.797571+00:00 2023-05-11T23:00:18.876808+00:00 0:00:01.079237 377480 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T23:00:15.601368+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-09T23:00:00+00:00 EmrJobFlowSensor 2023-05-10T23:00:49.756511+00:00 2023-05-10T23:10:51.494991+00:00 0:10:01.738480 376868 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T23:00:47.658967+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T23:00:28.173266+00:00 2023-05-10T23:00:28.945603+00:00 0:00:00.772337 376865 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-10T23:00:25.637950+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-09T23:00:00+00:00 PythonOperator 2023-05-10T23:00:08.402718+00:00 2023-05-10T23:00:09.582801+00:00 0:00:01.180083 376862 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T23:00:05.508795+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-08T23:00:00+00:00 EmrJobFlowSensor 2023-05-09T23:00:56.340430+00:00 2023-05-09T23:11:58.246041+00:00 0:11:01.905611 376247 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T23:00:54.115206+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T23:00:34.232990+00:00 2023-05-09T23:00:35.015681+00:00 0:00:00.782691 376244 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-09T23:00:32.025494+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-08T23:00:00+00:00 PythonOperator 2023-05-09T23:00:14.277423+00:00 2023-05-09T23:00:15.342556+00:00 0:00:01.065133 376241 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T23:00:12.014096+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-07T23:00:00+00:00 EmrJobFlowSensor 2023-05-08T23:00:58.273445+00:00 2023-05-08T23:11:00.145777+00:00 0:10:01.872332 375626 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T23:00:55.871286+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T23:00:38.042835+00:00 2023-05-08T23:00:38.751048+00:00 0:00:00.708213 375623 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-08T23:00:35.852993+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-07T23:00:00+00:00 PythonOperator 2023-05-08T23:00:16.017547+00:00 2023-05-08T23:00:17.028372+00:00 0:00:01.010825 375620 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T23:00:13.835180+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-06T23:00:00+00:00 EmrJobFlowSensor 2023-05-07T23:13:10.869465+00:00 2023-05-07T23:13:11.325914+00:00 0:00:00.456449 375001 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T23:13:08.593328+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T23:00:25.973991+00:00 2023-05-07T23:00:26.929036+00:00 0:00:00.955045 374988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-07T23:00:23.843381+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-06T23:00:00+00:00 PythonOperator 2023-05-07T23:00:04.801971+00:00 2023-05-07T23:00:06.162608+00:00 0:00:01.360637 374985 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T23:00:01.818877+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-05T23:00:00+00:00 EmrJobFlowSensor 2023-05-06T23:00:47.407611+00:00 2023-05-06T23:11:49.268778+00:00 0:11:01.861167 374392 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T23:00:45.206584+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T23:00:27.383970+00:00 2023-05-06T23:00:28.243053+00:00 0:00:00.859083 374389 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-06T23:00:25.176325+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-05T23:00:00+00:00 PythonOperator 2023-05-06T23:00:06.270611+00:00 2023-05-06T23:00:08.121451+00:00 0:00:01.850840 374386 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T23:00:03.157562+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-04T23:00:00+00:00 EmrJobFlowSensor 2023-05-05T23:00:47.893097+00:00 2023-05-05T23:10:49.665465+00:00 0:10:01.772368 373784 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T23:00:45.709776+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T23:00:25.851495+00:00 2023-05-05T23:00:26.692320+00:00 0:00:00.840825 373781 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-05T23:00:23.650818+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-04T23:00:00+00:00 PythonOperator 2023-05-05T23:00:06.157193+00:00 2023-05-05T23:00:07.128776+00:00 0:00:00.971583 373778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T23:00:03.639581+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-03T23:00:00+00:00 EmrJobFlowSensor 2023-05-04T23:13:01.598451+00:00 2023-05-04T23:13:02.055373+00:00 0:00:00.456922 373187 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T23:12:59.301540+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T23:01:09.887399+00:00 2023-05-04T23:01:10.672960+00:00 0:00:00.785561 373172 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-04T23:01:07.603939+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-03T23:00:00+00:00 PythonOperator 2023-05-04T23:00:22.353648+00:00 2023-05-04T23:00:23.304240+00:00 0:00:00.950592 373166 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T23:00:19.881060+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-02T23:00:00+00:00 EmrJobFlowSensor 2023-05-03T23:12:52.613058+00:00 2023-05-03T23:12:53.371762+00:00 0:00:00.758704 372583 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T23:12:50.389714+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T23:00:33.499374+00:00 2023-05-03T23:00:34.292776+00:00 0:00:00.793402 372570 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-03T23:00:31.410168+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-02T23:00:00+00:00 PythonOperator 2023-05-03T23:00:14.118408+00:00 2023-05-03T23:00:15.194133+00:00 0:00:01.075725 372567 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T23:00:11.129522+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-05-01T23:00:00+00:00 EmrJobFlowSensor 2023-05-02T23:00:46.314332+00:00 2023-05-02T23:10:48.171749+00:00 0:10:01.857417 371984 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T23:00:43.443131+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-05-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T23:00:26.247663+00:00 2023-05-02T23:00:27.014021+00:00 0:00:00.766358 371981 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-02T23:00:23.487272+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-05-01T23:00:00+00:00 PythonOperator 2023-05-02T23:00:03.666192+00:00 2023-05-02T23:00:04.752957+00:00 0:00:01.086765 371978 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T23:00:01.356130+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-30T23:00:00+00:00 EmrJobFlowSensor 2023-05-01T23:01:02.476429+00:00 2023-05-01T23:12:04.724872+00:00 0:11:02.248443 371390 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T23:00:59.804582+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T23:00:39.999488+00:00 2023-05-01T23:00:40.814793+00:00 0:00:00.815305 371387 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-05-01T23:00:37.721664+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-30T23:00:00+00:00 PythonOperator 2023-05-01T23:00:17.885156+00:00 2023-05-01T23:00:18.935952+00:00 0:00:01.050796 371384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T23:00:15.643987+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-29T23:00:00+00:00 EmrJobFlowSensor 2023-04-30T23:01:11.145236+00:00 2023-04-30T23:11:12.934503+00:00 0:10:01.789267 370803 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T23:01:08.437031+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T23:00:49.677761+00:00 2023-04-30T23:00:50.519237+00:00 0:00:00.841476 370800 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-04-30T23:00:46.405854+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-29T23:00:00+00:00 PythonOperator 2023-04-30T23:00:28.589280+00:00 2023-04-30T23:00:29.551968+00:00 0:00:00.962688 370797 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T23:00:26.371431+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-28T23:00:00+00:00 EmrJobFlowSensor 2023-04-29T23:01:14.566505+00:00 2023-04-29T23:11:16.423776+00:00 0:10:01.857271 370227 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T23:01:11.898330+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T23:00:36.454283+00:00 2023-04-29T23:00:37.210170+00:00 0:00:00.755887 370225 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-04-29T23:00:32.535377+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-28T23:00:00+00:00 PythonOperator 2023-04-29T23:00:13.459773+00:00 2023-04-29T23:00:14.442736+00:00 0:00:00.982963 370222 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T23:00:10.595875+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-27T23:00:00+00:00 EmrJobFlowSensor 2023-04-28T23:06:55.673547+00:00 2023-04-28T23:17:57.617619+00:00 0:11:01.944072 369650 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T23:06:53.441817+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T23:06:33.483557+00:00 2023-04-28T23:06:34.255053+00:00 0:00:00.771496 369646 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-04-28T23:06:31.352250+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-27T23:00:00+00:00 PythonOperator 2023-04-28T23:06:11.394092+00:00 2023-04-28T23:06:12.303937+00:00 0:00:00.909845 369642 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T23:06:09.319304+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-26T23:00:00+00:00 EmrJobFlowSensor 2023-04-27T23:01:03.400914+00:00 2023-04-27T23:12:05.398037+00:00 0:11:01.997123 369047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-27T23:01:01.208944+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-27T23:00:41.305407+00:00 2023-04-27T23:00:42.044302+00:00 0:00:00.738895 369044 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-04-27T23:00:39.174308+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-26T23:00:00+00:00 PythonOperator 2023-04-27T23:00:21.238360+00:00 2023-04-27T23:00:22.121663+00:00 0:00:00.883303 369041 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-27T23:00:19.155109+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-06T23:00:00+00:00 EmrJobFlowSensor 2023-04-07T23:00:51.146665+00:00 2023-04-07T23:10:52.902465+00:00 0:10:01.755800 365599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T23:00:47.609052+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T23:00:27.789234+00:00 2023-04-07T23:00:28.634670+00:00 0:00:00.845436 365596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-04-07T23:00:25.515000+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-06T23:00:00+00:00 PythonOperator 2023-04-07T23:00:05.780679+00:00 2023-04-07T23:00:09.154686+00:00 0:00:03.374007 365593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T23:00:03.427502+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-05T23:00:00+00:00 EmrJobFlowSensor 2023-04-06T23:07:51.263034+00:00 2023-04-06T23:17:53.056848+00:00 0:10:01.793814 365132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T23:07:48.928454+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T23:07:29.255422+00:00 2023-04-06T23:07:30.123111+00:00 0:00:00.867689 365128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-04-06T23:07:26.873375+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-05T23:00:00+00:00 PythonOperator 2023-04-06T23:07:10.714570+00:00 2023-04-06T23:07:20.845302+00:00 0:00:10.130732 365124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T23:07:06.851829+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-04T23:00:00+00:00 EmrJobFlowSensor 2023-04-05T23:00:56.767314+00:00 2023-04-05T23:10:58.480307+00:00 0:10:01.712993 364637 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T23:00:54.641955+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T23:00:35.358522+00:00 2023-04-05T23:00:36.126413+00:00 0:00:00.767891 364634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-04-05T23:00:32.625985+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-04T23:00:00+00:00 PythonOperator 2023-04-05T23:00:15.239223+00:00 2023-04-05T23:00:18.663125+00:00 0:00:03.423902 364631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T23:00:12.602081+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-03T23:00:00+00:00 EmrJobFlowSensor 2023-04-04T23:00:57.414085+00:00 2023-04-04T23:10:59.006308+00:00 0:10:01.592223 364144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T23:00:55.191865+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T23:00:38.501702+00:00 2023-04-04T23:00:39.385092+00:00 0:00:00.883390 364141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-04-04T23:00:33.002942+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-03T23:00:00+00:00 PythonOperator 2023-04-04T23:00:13.440292+00:00 2023-04-04T23:00:17.663162+00:00 0:00:04.222870 364138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T23:00:10.915582+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-02T23:00:00+00:00 EmrJobFlowSensor 2023-04-03T23:03:31.236200+00:00 2023-04-03T23:13:33.019293+00:00 0:10:01.783093 363651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T23:03:28.616509+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T23:03:08.602709+00:00 2023-04-03T23:03:09.416710+00:00 0:00:00.814001 363648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-04-03T23:03:06.469551+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-02T23:00:00+00:00 PythonOperator 2023-04-03T23:02:47.476754+00:00 2023-04-03T23:02:51.026060+00:00 0:00:03.549306 363645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T23:02:44.452134+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-04-01T23:00:00+00:00 EmrJobFlowSensor 2023-04-02T23:00:57.803376+00:00 2023-04-02T23:10:59.503512+00:00 0:10:01.700136 363149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T23:00:55.728258+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T23:00:35.934999+00:00 2023-04-02T23:00:36.876379+00:00 0:00:00.941380 363147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-04-02T23:00:33.702764+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-04-01T23:00:00+00:00 PythonOperator 2023-04-02T23:00:15.919970+00:00 2023-04-02T23:00:19.184021+00:00 0:00:03.264051 363145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T23:00:13.675110+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-31T23:00:00+00:00 EmrJobFlowSensor 2023-04-01T23:00:51.599564+00:00 2023-04-01T23:10:53.289009+00:00 0:10:01.689445 362660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T23:00:49.432147+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T23:00:29.988996+00:00 2023-04-01T23:00:30.797691+00:00 0:00:00.808695 362658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-04-01T23:00:27.333286+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-31T23:00:00+00:00 PythonOperator 2023-04-01T23:00:07.586565+00:00 2023-04-01T23:00:11.739190+00:00 0:00:04.152625 362654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T23:00:05.264227+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-30T23:00:00+00:00 EmrJobFlowSensor 2023-03-31T23:00:46.964935+00:00 2023-03-31T23:10:48.603234+00:00 0:10:01.638299 362168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T23:00:44.838995+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T23:00:27.154310+00:00 2023-03-31T23:00:27.996889+00:00 0:00:00.842579 362165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-31T23:00:24.808981+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-30T23:00:00+00:00 PythonOperator 2023-03-31T23:00:05.096210+00:00 2023-03-31T23:00:09.645111+00:00 0:00:04.548901 362162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T23:00:02.791047+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-29T23:00:00+00:00 EmrJobFlowSensor 2023-03-30T23:01:00.135176+00:00 2023-03-30T23:12:02.200015+00:00 0:11:02.064839 361665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T23:00:57.516901+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T23:00:37.702871+00:00 2023-03-30T23:00:38.465453+00:00 0:00:00.762582 361662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-30T23:00:35.490823+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-29T23:00:00+00:00 PythonOperator 2023-03-30T23:00:17.678643+00:00 2023-03-30T23:00:21.781662+00:00 0:00:04.103019 361659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T23:00:15.376724+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-28T23:00:00+00:00 EmrJobFlowSensor 2023-03-29T23:01:02.186486+00:00 2023-03-29T23:12:04.066529+00:00 0:11:01.880043 361170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T23:00:59.919973+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T23:00:38.002814+00:00 2023-03-29T23:00:38.816766+00:00 0:00:00.813952 361166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-29T23:00:35.837555+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-28T23:00:00+00:00 PythonOperator 2023-03-29T23:00:16.697656+00:00 2023-03-29T23:00:20.239001+00:00 0:00:03.541345 361164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T23:00:13.819227+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-27T23:00:00+00:00 EmrJobFlowSensor 2023-03-28T23:00:55.509951+00:00 2023-03-28T23:10:57.447220+00:00 0:10:01.937269 360667 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T23:00:52.331122+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T23:00:34.438733+00:00 2023-03-28T23:00:36.119358+00:00 0:00:01.680625 360664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-28T23:00:30.296556+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-27T23:00:00+00:00 PythonOperator 2023-03-28T23:00:12.387127+00:00 2023-03-28T23:00:16.411707+00:00 0:00:04.024580 360661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T23:00:10.245417+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-26T23:00:00+00:00 EmrJobFlowSensor 2023-03-27T23:00:58.495643+00:00 2023-03-27T23:11:00.238997+00:00 0:10:01.743354 360170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T23:00:56.357152+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T23:00:36.458154+00:00 2023-03-27T23:00:37.662758+00:00 0:00:01.204604 360167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-27T23:00:34.338503+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-26T23:00:00+00:00 PythonOperator 2023-03-27T23:00:16.521294+00:00 2023-03-27T23:00:22.563761+00:00 0:00:06.042467 360164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T23:00:14.312856+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-25T23:00:00+00:00 EmrJobFlowSensor 2023-03-26T23:00:46.842730+00:00 2023-03-26T23:10:48.539708+00:00 0:10:01.696978 359672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T23:00:44.498862+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T23:00:24.608941+00:00 2023-03-26T23:00:25.607992+00:00 0:00:00.999051 359669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-26T23:00:22.388129+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-25T23:00:00+00:00 PythonOperator 2023-03-26T23:00:04.579267+00:00 2023-03-26T23:00:08.254664+00:00 0:00:03.675397 359666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T23:00:02.319168+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-24T23:00:00+00:00 EmrJobFlowSensor 2023-03-25T23:00:49.006331+00:00 2023-03-25T23:10:50.772642+00:00 0:10:01.766311 359180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T23:00:46.530079+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T23:00:27.004035+00:00 2023-03-25T23:00:27.788667+00:00 0:00:00.784632 359177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-25T23:00:24.524535+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-24T23:00:00+00:00 PythonOperator 2023-03-25T23:00:05.209834+00:00 2023-03-25T23:00:08.535834+00:00 0:00:03.326000 359174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T23:00:02.478589+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-23T23:00:00+00:00 EmrJobFlowSensor 2023-03-24T23:01:00.807286+00:00 2023-03-24T23:11:02.724286+00:00 0:10:01.917000 358698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T23:00:58.505132+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T23:00:38.590522+00:00 2023-03-24T23:00:39.337788+00:00 0:00:00.747266 358695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-24T23:00:36.485489+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-23T23:00:00+00:00 PythonOperator 2023-03-24T23:00:17.051035+00:00 2023-03-24T23:00:20.328060+00:00 0:00:03.277025 358692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T23:00:14.467444+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-22T23:00:00+00:00 EmrJobFlowSensor 2023-03-23T23:00:49.511849+00:00 2023-03-23T23:10:51.287264+00:00 0:10:01.775415 358205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T23:00:47.339903+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T23:00:27.599132+00:00 2023-03-23T23:00:28.445629+00:00 0:00:00.846497 358202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-23T23:00:25.268763+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-22T23:00:00+00:00 PythonOperator 2023-03-23T23:00:08.112427+00:00 2023-03-23T23:00:11.735859+00:00 0:00:03.623432 358199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T23:00:05.299152+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-21T23:00:00+00:00 EmrJobFlowSensor 2023-03-22T23:00:51.888987+00:00 2023-03-22T23:10:53.683495+00:00 0:10:01.794508 357725 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T23:00:49.659521+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T23:00:29.899337+00:00 2023-03-22T23:00:30.750759+00:00 0:00:00.851422 357722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-22T23:00:27.641139+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-21T23:00:00+00:00 PythonOperator 2023-03-22T23:00:09.288142+00:00 2023-03-22T23:00:18.821770+00:00 0:00:09.533628 357719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T23:00:05.605403+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-03-20T23:00:00+00:00 EmrJobFlowSensor 2023-03-21T23:00:45.930059+00:00 2023-03-21T23:10:47.620156+00:00 0:10:01.690097 357226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T23:00:43.735049+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-03-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T23:00:26.093522+00:00 2023-03-21T23:00:26.892876+00:00 0:00:00.799354 357223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-03-21T23:00:23.713531+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-03-20T23:00:00+00:00 PythonOperator 2023-03-21T23:00:04.599868+00:00 2023-03-21T23:00:07.978702+00:00 0:00:03.378834 357220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T23:00:01.694561+00:00 2 default_pool