Task Instances


  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-17T23:00:00+00:00 EmrJobFlowSensor 2023-02-18T23:00:54.928906+00:00 2023-02-18T23:10:56.642094+00:00 0:10:01.713188 342319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T23:00:52.404200+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-18T23:00:32.681516+00:00 2023-02-18T23:00:33.412574+00:00 0:00:00.731058 342316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-18T23:00:30.329488+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-17T23:00:00+00:00 PythonOperator 2023-02-18T23:00:12.556653+00:00 2023-02-18T23:00:15.760156+00:00 0:00:03.203503 342313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-18T23:00:10.235721+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-16T23:00:00+00:00 EmrJobFlowSensor 2023-02-17T23:01:06.244083+00:00 2023-02-17T23:11:08.046948+00:00 0:10:01.802865 341698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T23:01:04.075544+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T23:00:44.522351+00:00 2023-02-17T23:00:45.392936+00:00 0:00:00.870585 341695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-17T23:00:42.055321+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-16T23:00:00+00:00 PythonOperator 2023-02-17T23:00:24.175803+00:00 2023-02-17T23:00:28.700606+00:00 0:00:04.524803 341692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T23:00:22.035559+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-15T23:00:00+00:00 EmrJobFlowSensor 2023-02-16T23:01:01.532142+00:00 2023-02-16T23:11:03.259072+00:00 0:10:01.726930 341081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T23:00:59.333018+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T23:00:39.383684+00:00 2023-02-16T23:00:40.223639+00:00 0:00:00.839955 341078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-16T23:00:37.274907+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-15T23:00:00+00:00 PythonOperator 2023-02-16T23:00:19.875710+00:00 2023-02-16T23:00:23.382814+00:00 0:00:03.507104 341075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T23:00:17.255968+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-14T23:00:00+00:00 EmrJobFlowSensor 2023-02-15T23:01:07.857527+00:00 2023-02-15T23:11:09.660687+00:00 0:10:01.803160 340468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T23:01:05.384915+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T23:00:45.495188+00:00 2023-02-15T23:00:46.272850+00:00 0:00:00.777662 340465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-15T23:00:43.362615+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-14T23:00:00+00:00 PythonOperator 2023-02-15T23:00:25.462612+00:00 2023-02-15T23:00:29.612777+00:00 0:00:04.150165 340462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T23:00:21.345123+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-13T23:00:00+00:00 EmrJobFlowSensor 2023-02-14T23:00:51.295854+00:00 2023-02-14T23:10:53.108884+00:00 0:10:01.813030 339863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T23:00:48.713968+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T23:00:31.310847+00:00 2023-02-14T23:00:32.447959+00:00 0:00:01.137112 339860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-14T23:00:26.622493+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-13T23:00:00+00:00 PythonOperator 2023-02-14T23:00:08.714307+00:00 2023-02-14T23:00:12.199886+00:00 0:00:03.485579 339857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T23:00:06.528461+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-12T23:00:00+00:00 EmrJobFlowSensor 2023-02-13T23:00:54.923748+00:00 2023-02-13T23:10:56.750626+00:00 0:10:01.826878 339258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T23:00:52.642556+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T23:00:34.987711+00:00 2023-02-13T23:00:35.833335+00:00 0:00:00.845624 339255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-13T23:00:32.621406+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-12T23:00:00+00:00 PythonOperator 2023-02-13T23:00:13.382907+00:00 2023-02-13T23:00:17.189396+00:00 0:00:03.806489 339252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T23:00:10.624548+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-11T23:00:00+00:00 EmrJobFlowSensor 2023-02-12T23:00:58.191992+00:00 2023-02-12T23:11:00.067799+00:00 0:10:01.875807 338638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T23:00:55.773792+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T23:00:35.906669+00:00 2023-02-12T23:00:36.666060+00:00 0:00:00.759391 338635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-12T23:00:33.757223+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-11T23:00:00+00:00 PythonOperator 2023-02-12T23:00:15.880093+00:00 2023-02-12T23:00:19.712518+00:00 0:00:03.832425 338632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T23:00:13.737339+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-10T23:00:00+00:00 EmrJobFlowSensor 2023-02-11T23:01:06.150809+00:00 2023-02-11T23:11:07.995831+00:00 0:10:01.845022 338023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T23:01:03.106464+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T23:00:45.442019+00:00 2023-02-11T23:00:46.221187+00:00 0:00:00.779168 338020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-11T23:00:42.959665+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-10T23:00:00+00:00 PythonOperator 2023-02-11T23:00:23.308921+00:00 2023-02-11T23:00:26.105892+00:00 0:00:02.796971 338017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T23:00:20.993726+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-09T23:00:00+00:00 EmrJobFlowSensor 2023-02-10T23:01:01.443896+00:00 2023-02-10T23:11:03.354939+00:00 0:10:01.911043 337408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T23:00:59.034914+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T23:00:39.373498+00:00 2023-02-10T23:00:40.151599+00:00 0:00:00.778101 337406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-10T23:00:37.012199+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-09T23:00:00+00:00 PythonOperator 2023-02-10T23:00:19.438473+00:00 2023-02-10T23:00:22.682984+00:00 0:00:03.244511 337404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T23:00:16.924837+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-08T23:00:00+00:00 EmrJobFlowSensor 2023-02-09T23:00:58.495015+00:00 2023-02-09T23:11:00.216408+00:00 0:10:01.721393 336796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T23:00:56.333548+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T23:00:38.776606+00:00 2023-02-09T23:00:39.522356+00:00 0:00:00.745750 336793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-09T23:00:36.279105+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-08T23:00:00+00:00 PythonOperator 2023-02-09T23:00:19.127149+00:00 2023-02-09T23:00:23.615083+00:00 0:00:04.487934 336790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T23:00:14.258926+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-07T23:00:00+00:00 EmrJobFlowSensor 2023-02-08T23:00:49.838387+00:00 2023-02-08T23:10:52.063408+00:00 0:10:02.225021 336189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T23:00:47.634569+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T23:00:29.964685+00:00 2023-02-08T23:00:31.028015+00:00 0:00:01.063330 336187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-08T23:00:27.588918+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-07T23:00:00+00:00 PythonOperator 2023-02-08T23:00:07.998599+00:00 2023-02-08T23:00:11.900514+00:00 0:00:03.901915 336183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T23:00:05.567823+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-06T23:00:00+00:00 EmrJobFlowSensor 2023-02-07T23:00:46.762773+00:00 2023-02-07T23:10:48.517025+00:00 0:10:01.754252 335588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T23:00:44.431948+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T23:00:26.657623+00:00 2023-02-07T23:00:27.523148+00:00 0:00:00.865525 335585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-07T23:00:24.427346+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-06T23:00:00+00:00 PythonOperator 2023-02-07T23:00:05.148069+00:00 2023-02-07T23:00:08.924101+00:00 0:00:03.776032 335582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T23:00:02.386893+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-05T23:00:00+00:00 EmrJobFlowSensor 2023-02-06T23:01:49.196560+00:00 2023-02-06T23:12:51.035401+00:00 0:11:01.838841 334994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-06T23:01:46.980056+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-06T23:01:27.891454+00:00 2023-02-06T23:01:28.865346+00:00 0:00:00.973892 334991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-06T23:01:24.962187+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-05T23:00:00+00:00 PythonOperator 2023-02-06T23:01:05.510985+00:00 2023-02-06T23:01:10.070406+00:00 0:00:04.559421 334988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-06T23:01:02.940936+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-04T23:00:00+00:00 EmrJobFlowSensor 2023-02-05T23:00:47.956553+00:00 2023-02-05T23:10:49.722111+00:00 0:10:01.765558 334391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-05T23:00:45.605317+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-05T23:00:26.155514+00:00 2023-02-05T23:00:26.938392+00:00 0:00:00.782878 334388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-05T23:00:23.629572+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-04T23:00:00+00:00 PythonOperator 2023-02-05T23:00:04.229388+00:00 2023-02-05T23:00:07.133994+00:00 0:00:02.904606 334385 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-05T23:00:01.508993+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-03T23:00:00+00:00 EmrJobFlowSensor 2023-02-04T23:00:52.433296+00:00 2023-02-04T23:11:54.601714+00:00 0:11:02.168418 333779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-04T23:00:50.039825+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-04T23:00:30.266474+00:00 2023-02-04T23:00:31.144229+00:00 0:00:00.877755 333776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-04T23:00:27.975665+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-03T23:00:00+00:00 PythonOperator 2023-02-04T23:00:10.554005+00:00 2023-02-04T23:00:14.355048+00:00 0:00:03.801043 333773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-04T23:00:07.959585+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-02T23:00:00+00:00 EmrJobFlowSensor 2023-02-03T23:01:01.264678+00:00 2023-02-03T23:11:03.080924+00:00 0:10:01.816246 333182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-03T23:00:58.906883+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-03T23:00:41.965022+00:00 2023-02-03T23:00:42.721451+00:00 0:00:00.756429 333179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-03T23:00:38.805518+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-02T23:00:00+00:00 PythonOperator 2023-02-03T23:00:18.997658+00:00 2023-02-03T23:00:22.881071+00:00 0:00:03.883413 333176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-03T23:00:16.786416+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-02-01T23:00:00+00:00 EmrJobFlowSensor 2023-02-02T23:00:56.421723+00:00 2023-02-02T23:10:58.110138+00:00 0:10:01.688415 332594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-02T23:00:54.207143+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-02-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-02T23:00:36.349014+00:00 2023-02-02T23:00:37.607350+00:00 0:00:01.258336 332591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-02T23:00:32.204132+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-02-01T23:00:00+00:00 PythonOperator 2023-02-02T23:00:15.279161+00:00 2023-02-02T23:00:19.681241+00:00 0:00:04.402080 332588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-02T23:00:12.167512+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-31T23:00:00+00:00 EmrJobFlowSensor 2023-02-01T23:01:07.526803+00:00 2023-02-01T23:11:09.103616+00:00 0:10:01.576813 331992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-01T23:01:05.263315+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-31T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-01T23:00:46.552439+00:00 2023-02-01T23:00:47.395301+00:00 0:00:00.842862 331989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-02-01T23:00:43.243136+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-31T23:00:00+00:00 PythonOperator 2023-02-01T23:00:23.300930+00:00 2023-02-01T23:00:26.279614+00:00 0:00:02.978684 331986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-01T23:00:21.204982+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-30T23:00:00+00:00 EmrJobFlowSensor 2023-01-31T23:00:59.308811+00:00 2023-01-31T23:11:01.062311+00:00 0:10:01.753500 331387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-31T23:00:57.108068+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-31T23:00:39.210661+00:00 2023-01-31T23:00:39.971627+00:00 0:00:00.760966 331384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-31T23:00:37.089506+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-30T23:00:00+00:00 PythonOperator 2023-01-31T23:00:17.518641+00:00 2023-01-31T23:00:21.992698+00:00 0:00:04.474057 331381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-31T23:00:15.091918+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-29T23:00:00+00:00 EmrJobFlowSensor 2023-01-30T23:01:32.505595+00:00 2023-01-30T23:11:34.163675+00:00 0:10:01.658080 330782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-30T23:01:30.273220+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-30T23:01:12.533548+00:00 2023-01-30T23:01:13.400868+00:00 0:00:00.867320 330780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-30T23:01:10.245124+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-29T23:00:00+00:00 PythonOperator 2023-01-30T23:00:51.227680+00:00 2023-01-30T23:00:54.119284+00:00 0:00:02.891604 330776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-30T23:00:48.183854+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-28T23:00:00+00:00 EmrJobFlowSensor 2023-01-29T23:01:07.400594+00:00 2023-01-29T23:11:09.083810+00:00 0:10:01.683216 330161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-29T23:01:05.187402+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-29T23:00:47.413771+00:00 2023-01-29T23:00:48.157578+00:00 0:00:00.743807 330158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-29T23:00:45.173366+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-28T23:00:00+00:00 PythonOperator 2023-01-29T23:00:25.698103+00:00 2023-01-29T23:00:32.039080+00:00 0:00:06.340977 330155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-29T23:00:23.156197+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-27T23:00:00+00:00 EmrJobFlowSensor 2023-01-28T23:01:05.885183+00:00 2023-01-28T23:11:07.651243+00:00 0:10:01.766060 329547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-28T23:01:03.733094+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-28T23:00:46.115345+00:00 2023-01-28T23:00:47.241427+00:00 0:00:01.126082 329544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-28T23:00:41.680465+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-27T23:00:00+00:00 PythonOperator 2023-01-28T23:00:25.420424+00:00 2023-01-28T23:00:29.174795+00:00 0:00:03.754371 329542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-28T23:00:21.684049+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-26T23:00:00+00:00 EmrJobFlowSensor 2023-01-27T23:01:10.812341+00:00 2023-01-27T23:11:12.945804+00:00 0:10:02.133463 328927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-27T23:01:08.318862+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-27T23:00:32.978925+00:00 2023-01-27T23:00:33.789786+00:00 0:00:00.810861 328924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-27T23:00:30.287617+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-26T23:00:00+00:00 PythonOperator 2023-01-27T23:00:10.556770+00:00 2023-01-27T23:00:15.459602+00:00 0:00:04.902832 328920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-27T23:00:08.263023+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-25T23:00:00+00:00 EmrJobFlowSensor 2023-01-26T23:00:58.268195+00:00 2023-01-26T23:11:00.164296+00:00 0:10:01.896101 328313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-26T23:00:55.824631+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-26T23:00:38.146302+00:00 2023-01-26T23:00:38.897767+00:00 0:00:00.751465 328311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-26T23:00:35.816898+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-25T23:00:00+00:00 PythonOperator 2023-01-26T23:00:16.311339+00:00 2023-01-26T23:00:20.091936+00:00 0:00:03.780597 328308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-26T23:00:13.809302+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-24T23:00:00+00:00 EmrJobFlowSensor 2023-01-25T23:01:04.705083+00:00 2023-01-25T23:11:06.405244+00:00 0:10:01.700161 327695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-25T23:01:02.420481+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-25T23:00:44.721683+00:00 2023-01-25T23:00:45.740265+00:00 0:00:01.018582 327693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-25T23:00:42.333262+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-24T23:00:00+00:00 PythonOperator 2023-01-25T23:00:22.454245+00:00 2023-01-25T23:00:26.591353+00:00 0:00:04.137108 327689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-25T23:00:20.255596+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-23T23:00:00+00:00 EmrJobFlowSensor 2023-01-24T23:01:20.667887+00:00 2023-01-24T23:11:22.375145+00:00 0:10:01.707258 327077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-24T23:01:18.442364+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-24T23:00:58.838635+00:00 2023-01-24T23:00:59.709900+00:00 0:00:00.871265 327074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-24T23:00:56.414328+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-23T23:00:00+00:00 PythonOperator 2023-01-24T23:00:39.005425+00:00 2023-01-24T23:00:48.733456+00:00 0:00:09.728031 327071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-24T23:00:36.447378+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-22T23:00:00+00:00 EmrJobFlowSensor 2023-01-23T23:00:48.401842+00:00 2023-01-23T23:10:50.125390+00:00 0:10:01.723548 326461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-23T23:00:45.692036+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-23T23:00:26.249292+00:00 2023-01-23T23:00:27.021798+00:00 0:00:00.772506 326457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-23T23:00:23.729254+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-22T23:00:00+00:00 PythonOperator 2023-01-23T23:00:07.108801+00:00 2023-01-23T23:00:10.396749+00:00 0:00:03.287948 326455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-23T23:00:03.718378+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-23T13:51:37.236160+00:00 EmrJobFlowSensor 2023-01-23T13:52:36.690679+00:00 2023-01-23T14:05:38.800950+00:00 0:13:02.110271 326222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-23T13:52:34.529257+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-23T13:51:37.236160+00:00 EmrCreateJobFlowOperator 2023-01-23T13:52:16.544185+00:00 2023-01-23T13:52:17.313612+00:00 0:00:00.769427 326221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-23T13:52:14.428679+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-23T13:51:37.236160+00:00 PythonOperator 2023-01-23T13:51:54.621245+00:00 2023-01-23T13:51:57.299379+00:00 0:00:02.678134 326220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-23T13:51:52.329853+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-21T23:00:00+00:00 EmrJobFlowSensor 2023-01-22T23:01:06.573418+00:00 2023-01-22T23:11:08.387479+00:00 0:10:01.814061 325834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-22T23:01:04.200906+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-22T23:00:46.300362+00:00 2023-01-22T23:00:47.436902+00:00 0:00:01.136540 325831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-22T23:00:44.066085+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-21T23:00:00+00:00 PythonOperator 2023-01-22T23:00:24.341774+00:00 2023-01-22T23:00:28.152149+00:00 0:00:03.810375 325828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-22T23:00:22.112320+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-20T23:00:00+00:00 EmrJobFlowSensor 2023-01-21T23:01:08.126936+00:00 2023-01-21T23:11:09.904160+00:00 0:10:01.777224 325212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-21T23:01:05.160275+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-21T23:00:45.441649+00:00 2023-01-21T23:00:46.239506+00:00 0:00:00.797857 325209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-21T23:00:43.152024+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-20T23:00:00+00:00 PythonOperator 2023-01-21T23:00:23.276627+00:00 2023-01-21T23:00:26.834486+00:00 0:00:03.557859 325206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-21T23:00:21.063747+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-19T23:00:00+00:00 EmrJobFlowSensor 2023-01-20T23:00:55.322618+00:00 2023-01-20T23:10:57.087003+00:00 0:10:01.764385 324582 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-20T23:00:52.234722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-20T23:00:34.322220+00:00 2023-01-20T23:00:35.091555+00:00 0:00:00.769335 324579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-20T23:00:32.195035+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-19T23:00:00+00:00 PythonOperator 2023-01-20T23:00:12.691910+00:00 2023-01-20T23:00:16.655046+00:00 0:00:03.963136 324576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-20T23:00:10.176920+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-18T23:00:00+00:00 EmrJobFlowSensor 2023-01-19T23:01:04.680629+00:00 2023-01-19T23:11:06.542691+00:00 0:10:01.862062 323940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-19T23:01:01.690266+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-19T23:00:42.536123+00:00 2023-01-19T23:00:43.276386+00:00 0:00:00.740263 323937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-19T23:00:39.619930+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-18T23:00:00+00:00 PythonOperator 2023-01-19T23:00:19.834673+00:00 2023-01-19T23:00:23.454363+00:00 0:00:03.619690 323934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-19T23:00:17.519107+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-17T23:00:00+00:00 EmrJobFlowSensor 2023-01-18T23:01:00.413835+00:00 2023-01-18T23:11:02.209647+00:00 0:10:01.795812 323313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-18T23:00:58.264370+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2023-01-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-01-18T23:00:42.919853+00:00 2023-01-18T23:00:43.902872+00:00 0:00:00.983019 323310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2023-01-18T23:00:38.249657+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2023-01-17T23:00:00+00:00 PythonOperator 2023-01-18T23:00:18.396907+00:00 2023-01-18T23:00:22.309890+00:00 0:00:03.912983 323307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-01-18T23:00:16.227727+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2023-01-16T23:00:00+00:00 EmrJobFlowSensor 2023-01-17T23:00:58.943429+00:00 2023-01-17T23:12:00.820067+00:00 0:11:01.876638 322700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-01-17T23:00:56.600706+00:00 2 default_pool