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_cluster_and_add_emr_steps 2023-01-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-13T23:00:36.919650+00:00 2023-01-13T23:00:37.640538+00:00 0:00:00.720888 320255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-13T23:00:34.795143+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-12T23:00:00+00:00 PythonOperator 2023-01-13T23:00:15.145037+00:00 2023-01-13T23:00:17.689044+00:00 0:00:02.544007 320252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-13T23:00:12.775276+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-11T23:00:00+00:00 EmrJobFlowSensor 2023-01-12T23:01:02.199912+00:00 2023-01-12T23:11:04.020955+00:00 0:10:01.821043 319646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-12T23:00:59.750275+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-12T23:00:40.010736+00:00 2023-01-12T23:00:40.840703+00:00 0:00:00.829967 319643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-12T23:00:37.738235+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-11T23:00:00+00:00 PythonOperator 2023-01-12T23:00:19.844874+00:00 2023-01-12T23:00:23.541852+00:00 0:00:03.696978 319640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-12T23:00:17.660372+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-10T23:00:00+00:00 EmrJobFlowSensor 2023-01-11T23:00:52.025378+00:00 2023-01-11T23:10:53.854502+00:00 0:10:01.829124 319037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-11T23:00:49.092484+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-11T23:00:31.250444+00:00 2023-01-11T23:00:32.030345+00:00 0:00:00.779901 319034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-11T23:00:28.954789+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-10T23:00:00+00:00 PythonOperator 2023-01-11T23:00:09.410661+00:00 2023-01-11T23:00:12.467180+00:00 0:00:03.056519 319031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-11T23:00:07.000730+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-09T23:00:00+00:00 EmrJobFlowSensor 2023-01-10T23:00:50.379532+00:00 2023-01-10T23:11:52.313581+00:00 0:11:01.934049 318421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-10T23:00:48.041203+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-10T23:00:30.327359+00:00 2023-01-10T23:00:31.144333+00:00 0:00:00.816974 318418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-10T23:00:28.020352+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-09T23:00:00+00:00 PythonOperator 2023-01-10T23:00:08.216978+00:00 2023-01-10T23:00:11.861977+00:00 0:00:03.644999 318415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-10T23:00:05.997793+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-08T23:00:00+00:00 EmrJobFlowSensor 2023-01-09T23:00:57.961824+00:00 2023-01-09T23:10:59.751838+00:00 0:10:01.790014 317807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-09T23:00:55.591291+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-09T23:00:37.759333+00:00 2023-01-09T23:00:38.579843+00:00 0:00:00.820510 317804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-09T23:00:35.433610+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-08T23:00:00+00:00 PythonOperator 2023-01-09T23:00:15.786682+00:00 2023-01-09T23:00:18.335430+00:00 0:00:02.548748 317801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-09T23:00:13.426340+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-07T23:00:00+00:00 EmrJobFlowSensor 2023-01-08T23:00:58.564135+00:00 2023-01-08T23:11:00.486486+00:00 0:10:01.922351 317207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-08T23:00:56.334985+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-08T23:00:36.772552+00:00 2023-01-08T23:00:37.748806+00:00 0:00:00.976254 317204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-08T23:00:34.301489+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-07T23:00:00+00:00 PythonOperator 2023-01-08T23:00:16.467311+00:00 2023-01-08T23:00:19.048381+00:00 0:00:02.581070 317201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-08T23:00:14.282858+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-06T23:00:00+00:00 EmrJobFlowSensor 2023-01-07T23:01:00.970146+00:00 2023-01-07T23:11:02.868460+00:00 0:10:01.898314 316589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-07T23:00:58.313290+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-07T23:00:40.838826+00:00 2023-01-07T23:00:41.691142+00:00 0:00:00.852316 316586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-07T23:00:38.394085+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-06T23:00:00+00:00 PythonOperator 2023-01-07T23:00:18.833922+00:00 2023-01-07T23:00:22.693810+00:00 0:00:03.859888 316582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-07T23:00:16.310910+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-05T23:00:00+00:00 EmrJobFlowSensor 2023-01-06T23:01:03.191134+00:00 2023-01-06T23:11:04.989610+00:00 0:10:01.798476 315979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-06T23:01:00.847886+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-06T23:00:40.991879+00:00 2023-01-06T23:00:41.856068+00:00 0:00:00.864189 315976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-06T23:00:38.827244+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-05T23:00:00+00:00 PythonOperator 2023-01-06T23:00:19.199607+00:00 2023-01-06T23:00:26.151193+00:00 0:00:06.951586 315973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-06T23:00:16.800062+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-04T23:00:00+00:00 EmrJobFlowSensor 2023-01-05T23:00:55.254560+00:00 2023-01-05T23:10:57.052443+00:00 0:10:01.797883 315368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-05T23:00:52.372414+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-05T23:00:32.486128+00:00 2023-01-05T23:00:33.274057+00:00 0:00:00.787929 315365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-05T23:00:30.349305+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-04T23:00:00+00:00 PythonOperator 2023-01-05T23:00:12.717325+00:00 2023-01-05T23:00:19.099613+00:00 0:00:06.382288 315362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-05T23:00:10.330937+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-03T23:00:00+00:00 EmrJobFlowSensor 2023-01-04T23:01:08.194160+00:00 2023-01-04T23:11:10.060999+00:00 0:10:01.866839 314756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-04T23:01:05.935392+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-04T23:00:46.058892+00:00 2023-01-04T23:00:46.849624+00:00 0:00:00.790732 314754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-04T23:00:43.848918+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-03T23:00:00+00:00 PythonOperator 2023-01-04T23:00:25.999817+00:00 2023-01-04T23:00:28.653612+00:00 0:00:02.653795 314752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-04T23:00:23.832678+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-02T23:00:00+00:00 EmrJobFlowSensor 2023-01-03T23:00:59.619410+00:00 2023-01-03T23:11:01.474663+00:00 0:10:01.855253 314145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-03T23:00:57.406079+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-03T23:00:40.499497+00:00 2023-01-03T23:00:41.659774+00:00 0:00:01.160277 314142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-03T23:00:35.386090+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-02T23:00:00+00:00 PythonOperator 2023-01-03T23:00:17.568752+00:00 2023-01-03T23:00:21.157307+00:00 0:00:03.588555 314139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-03T23:00:13.367866+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-01T23:00:00+00:00 EmrJobFlowSensor 2023-01-02T23:00:58.272189+00:00 2023-01-02T23:11:00.149252+00:00 0:10:01.877063 313529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-02T23:00:55.720371+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-02T23:00:32.733204+00:00 2023-01-02T23:00:33.638143+00:00 0:00:00.904939 313527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-02T23:00:30.534077+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-01T23:00:00+00:00 PythonOperator 2023-01-02T23:00:12.696257+00:00 2023-01-02T23:00:17.850425+00:00 0:00:05.154168 313524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-02T23:00:10.496191+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-31T23:00:00+00:00 EmrJobFlowSensor 2023-01-01T23:00:57.990363+00:00 2023-01-01T23:10:59.702001+00:00 0:10:01.711638 312917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-01T23:00:55.799621+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-31T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-01T23:00:38.336163+00:00 2023-01-01T23:00:39.170858+00:00 0:00:00.834695 312914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-01T23:00:35.823949+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-31T23:00:00+00:00 PythonOperator 2023-01-01T23:00:16.070298+00:00 2023-01-01T23:00:19.799322+00:00 0:00:03.729024 312911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-01T23:00:13.739567+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-30T23:00:00+00:00 EmrJobFlowSensor 2022-12-31T23:00:48.978179+00:00 2022-12-31T23:10:50.674166+00:00 0:10:01.695987 312309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-31T23:00:46.839164+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-30T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-31T23:00:29.033445+00:00 2022-12-31T23:00:29.939409+00:00 0:00:00.905964 312306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-31T23:00:26.784221+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-30T23:00:00+00:00 PythonOperator 2022-12-31T23:00:07.006123+00:00 2022-12-31T23:00:09.654923+00:00 0:00:02.648800 312303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-31T23:00:04.766171+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-29T23:00:00+00:00 EmrJobFlowSensor 2022-12-30T23:01:05.628477+00:00 2022-12-30T23:11:07.454867+00:00 0:10:01.826390 311690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-30T23:01:03.231337+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-29T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-30T23:00:45.506554+00:00 2022-12-30T23:00:46.297941+00:00 0:00:00.791387 311687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-30T23:00:43.200256+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-29T23:00:00+00:00 PythonOperator 2022-12-30T23:00:23.594787+00:00 2022-12-30T23:00:26.191234+00:00 0:00:02.596447 311684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-30T23:00:21.179004+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-28T23:00:00+00:00 EmrJobFlowSensor 2022-12-29T23:01:06.142158+00:00 2022-12-29T23:11:07.824743+00:00 0:10:01.682585 311074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-29T23:01:03.963056+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-28T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-29T23:00:44.183443+00:00 2022-12-29T23:00:44.949966+00:00 0:00:00.766523 311071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-29T23:00:41.931776+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-28T23:00:00+00:00 PythonOperator 2022-12-29T23:00:21.963058+00:00 2022-12-29T23:00:25.449403+00:00 0:00:03.486345 311068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-29T23:00:19.831089+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-27T23:00:00+00:00 EmrJobFlowSensor 2022-12-28T23:00:54.930438+00:00 2022-12-28T23:10:56.651194+00:00 0:10:01.720756 310454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-28T23:00:52.419662+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-27T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-28T23:00:32.712311+00:00 2022-12-28T23:00:33.449784+00:00 0:00:00.737473 310451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-28T23:00:30.407310+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-27T23:00:00+00:00 PythonOperator 2022-12-28T23:00:13.210535+00:00 2022-12-28T23:00:16.825725+00:00 0:00:03.615190 310448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-28T23:00:10.324295+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-26T23:00:00+00:00 EmrJobFlowSensor 2022-12-27T23:01:01.740761+00:00 2022-12-27T23:11:03.715699+00:00 0:10:01.974938 309837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-27T23:00:59.579317+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-26T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-27T23:00:41.798861+00:00 2022-12-27T23:00:42.572251+00:00 0:00:00.773390 309834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-27T23:00:39.560299+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-26T23:00:00+00:00 PythonOperator 2022-12-27T23:00:19.799012+00:00 2022-12-27T23:00:23.365501+00:00 0:00:03.566489 309831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-27T23:00:17.544500+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-25T23:00:00+00:00 EmrJobFlowSensor 2022-12-26T23:01:00.436013+00:00 2022-12-26T23:13:02.422425+00:00 0:12:01.986412 309220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-26T23:00:58.187558+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-25T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-26T23:00:40.771068+00:00 2022-12-26T23:00:41.671400+00:00 0:00:00.900332 309217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-26T23:00:38.109064+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-25T23:00:00+00:00 PythonOperator 2022-12-26T23:00:18.437971+00:00 2022-12-26T23:00:21.177165+00:00 0:00:02.739194 309214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-26T23:00:16.107740+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-24T23:00:00+00:00 EmrJobFlowSensor 2022-12-25T23:01:05.493512+00:00 2022-12-25T23:12:07.766326+00:00 0:11:02.272814 308609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-25T23:01:02.875659+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-24T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-25T23:00:43.666653+00:00 2022-12-25T23:00:44.432747+00:00 0:00:00.766094 308606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-25T23:00:40.904585+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-24T23:00:00+00:00 PythonOperator 2022-12-25T23:00:21.900084+00:00 2022-12-25T23:00:27.410242+00:00 0:00:05.510158 308603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-25T23:00:18.915458+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-23T23:00:00+00:00 EmrJobFlowSensor 2022-12-24T23:00:54.449678+00:00 2022-12-24T23:10:56.317935+00:00 0:10:01.868257 307988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-24T23:00:52.097163+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-23T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-24T23:00:32.605304+00:00 2022-12-24T23:00:33.357475+00:00 0:00:00.752171 307985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-24T23:00:30.087984+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-23T23:00:00+00:00 PythonOperator 2022-12-24T23:00:11.662474+00:00 2022-12-24T23:00:17.492458+00:00 0:00:05.829984 307982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-24T23:00:08.113648+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-22T23:00:00+00:00 EmrJobFlowSensor 2022-12-23T23:01:04.650772+00:00 2022-12-23T23:11:06.436063+00:00 0:10:01.785291 307365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-23T23:01:02.164707+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-22T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-23T23:00:42.623532+00:00 2022-12-23T23:00:43.412026+00:00 0:00:00.788494 307362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-23T23:00:40.210134+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-22T23:00:00+00:00 PythonOperator 2022-12-23T23:00:20.587998+00:00 2022-12-23T23:00:24.009786+00:00 0:00:03.421788 307359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-23T23:00:18.206426+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-21T23:00:00+00:00 EmrJobFlowSensor 2022-12-22T23:01:07.109906+00:00 2022-12-22T23:11:08.915839+00:00 0:10:01.805933 306756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-22T23:01:04.699908+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-21T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-22T23:00:45.113971+00:00 2022-12-22T23:00:45.964300+00:00 0:00:00.850329 306753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-22T23:00:42.702537+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-21T23:00:00+00:00 PythonOperator 2022-12-22T23:00:24.676600+00:00 2022-12-22T23:00:28.203404+00:00 0:00:03.526804 306750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-22T23:00:22.536328+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-20T23:00:00+00:00 EmrJobFlowSensor 2022-12-21T23:01:03.201423+00:00 2022-12-21T23:13:05.278507+00:00 0:12:02.077084 306152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-21T23:01:00.606826+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-20T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-21T23:00:40.633809+00:00 2022-12-21T23:00:41.422179+00:00 0:00:00.788370 306149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-21T23:00:38.429577+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-20T23:00:00+00:00 PythonOperator 2022-12-21T23:00:18.634324+00:00 2022-12-21T23:00:21.511450+00:00 0:00:02.877126 306146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-21T23:00:16.379461+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-19T23:00:00+00:00 EmrJobFlowSensor 2022-12-20T23:01:02.467322+00:00 2022-12-20T23:12:04.405100+00:00 0:11:01.937778 305536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-20T23:00:59.413533+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-19T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-20T23:00:33.426977+00:00 2022-12-20T23:00:34.143482+00:00 0:00:00.716505 305534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-20T23:00:30.510183+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-19T23:00:00+00:00 PythonOperator 2022-12-20T23:00:12.477263+00:00 2022-12-20T23:00:15.216360+00:00 0:00:02.739097 305531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-20T23:00:08.414706+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-18T23:00:00+00:00 EmrJobFlowSensor 2022-12-19T23:00:56.085616+00:00 2022-12-19T23:12:58.024050+00:00 0:12:01.938434 304954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-19T23:00:53.720475+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-18T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-19T23:00:35.767670+00:00 2022-12-19T23:00:36.482207+00:00 0:00:00.714537 304951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-19T23:00:33.635455+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-18T23:00:00+00:00 PythonOperator 2022-12-19T23:00:13.791201+00:00 2022-12-19T23:00:17.267996+00:00 0:00:03.476795 304948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-19T23:00:11.616956+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-17T23:00:00+00:00 EmrJobFlowSensor 2022-12-18T23:01:11.028350+00:00 2022-12-18T23:11:12.847892+00:00 0:10:01.819542 304419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-18T23:01:08.837000+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-17T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-18T23:00:47.027967+00:00 2022-12-18T23:00:47.790321+00:00 0:00:00.762354 304416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-18T23:00:44.738016+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-17T23:00:00+00:00 PythonOperator 2022-12-18T23:00:25.245968+00:00 2022-12-18T23:00:27.559849+00:00 0:00:02.313881 304413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-18T23:00:22.719682+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-16T23:00:00+00:00 EmrJobFlowSensor 2022-12-17T23:00:52.165837+00:00 2022-12-17T23:11:54.038841+00:00 0:11:01.873004 303886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-17T23:00:49.932747+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-16T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-17T23:00:32.700710+00:00 2022-12-17T23:00:33.534474+00:00 0:00:00.833764 303883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-17T23:00:29.902018+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-16T23:00:00+00:00 PythonOperator 2022-12-17T23:00:10.307646+00:00 2022-12-17T23:00:12.918307+00:00 0:00:02.610661 303880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-17T23:00:07.837183+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-15T23:00:00+00:00 EmrJobFlowSensor 2022-12-16T23:01:07.100955+00:00 2022-12-16T23:12:08.976258+00:00 0:11:01.875303 303363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-16T23:01:04.729332+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-15T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-16T23:00:45.178151+00:00 2022-12-16T23:00:46.006057+00:00 0:00:00.827906 303360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-16T23:00:42.688017+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-15T23:00:00+00:00 PythonOperator 2022-12-16T23:00:23.593239+00:00 2022-12-16T23:00:27.290870+00:00 0:00:03.697631 303357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-16T23:00:20.671124+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-14T23:00:00+00:00 EmrJobFlowSensor 2022-12-15T23:00:53.882791+00:00 2022-12-15T23:11:55.674991+00:00 0:11:01.792200 302843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-15T23:00:51.547576+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-14T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-15T23:00:30.291119+00:00 2022-12-15T23:00:31.373798+00:00 0:00:01.082679 302840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-15T23:00:27.527379+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-14T23:00:00+00:00 PythonOperator 2022-12-15T23:00:10.199814+00:00 2022-12-15T23:00:13.676659+00:00 0:00:03.476845 302837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-15T23:00:07.189573+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-13T23:00:00+00:00 EmrJobFlowSensor 2022-12-14T23:01:00.302532+00:00 2022-12-14T23:12:02.246594+00:00 0:11:01.944062 302321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-14T23:00:57.799352+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-13T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-14T23:00:40.803336+00:00 2022-12-14T23:00:41.573893+00:00 0:00:00.770557 302318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-14T23:00:37.721520+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-13T23:00:00+00:00 PythonOperator 2022-12-14T23:00:18.068045+00:00 2022-12-14T23:00:20.854446+00:00 0:00:02.786401 302315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-14T23:00:15.690825+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-12T23:00:00+00:00 EmrJobFlowSensor 2022-12-13T23:00:59.321917+00:00 2022-12-13T23:12:01.158618+00:00 0:11:01.836701 301806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-13T23:00:56.809979+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-12T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-13T23:00:39.096095+00:00 2022-12-13T23:00:39.885275+00:00 0:00:00.789180 301803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-13T23:00:36.807287+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-12T23:00:00+00:00 PythonOperator 2022-12-13T23:00:16.849400+00:00 2022-12-13T23:00:20.332169+00:00 0:00:03.482769 301800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-13T23:00:14.703658+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-11T23:00:00+00:00 EmrJobFlowSensor 2022-12-12T23:00:47.500332+00:00 2022-12-12T23:11:49.415487+00:00 0:11:01.915155 301287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-12T23:00:45.255947+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-11T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-12T23:00:27.400334+00:00 2022-12-12T23:00:28.168374+00:00 0:00:00.768040 301284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-12T23:00:25.199488+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-12-11T23:00:00+00:00 PythonOperator 2022-12-12T23:00:05.820713+00:00 2022-12-12T23:00:08.147606+00:00 0:00:02.326893 301281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-12-12T23:00:03.178760+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-12-10T23:00:00+00:00 EmrJobFlowSensor 2022-12-11T23:01:03.892031+00:00 2022-12-11T23:12:05.708488+00:00 0:11:01.816457 300763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-12-11T23:01:01.420152+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-12-10T23:00:00+00:00 EmrCreateJobFlowOperator 2022-12-11T23:00:41.520227+00:00 2022-12-11T23:00:42.277786+00:00 0:00:00.757559 300760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-12-11T23:00:39.336712+00:00 2 default_pool