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 create_cluster_and_add_emr_steps 2022-11-07T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-08T23:00:41.588622+00:00 2022-11-08T23:00:42.334622+00:00 0:00:00.746000 282005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-08T23:00:39.295808+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-07T23:00:00+00:00 PythonOperator 2022-11-08T23:00:22.343445+00:00 2022-11-08T23:00:28.261801+00:00 0:00:05.918356 282003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-08T23:00:19.199140+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-06T23:00:00+00:00 EmrJobFlowSensor 2022-11-07T23:00:47.492246+00:00 2022-11-07T23:11:49.233813+00:00 0:11:01.741567 281371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-07T23:00:44.916696+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-06T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-07T23:00:25.361571+00:00 2022-11-07T23:00:26.746573+00:00 0:00:01.385002 281368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-07T23:00:22.921779+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-06T23:00:00+00:00 PythonOperator 2022-11-07T23:00:05.215278+00:00 2022-11-07T23:00:08.444824+00:00 0:00:03.229546 281365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-07T23:00:02.898057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-05T23:00:00+00:00 EmrJobFlowSensor 2022-11-06T23:01:04.539323+00:00 2022-11-06T23:12:06.460197+00:00 0:11:01.920874 280740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-06T23:01:02.191233+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-05T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-06T23:00:42.289415+00:00 2022-11-06T23:00:43.040213+00:00 0:00:00.750798 280736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-06T23:00:40.019615+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-05T23:00:00+00:00 PythonOperator 2022-11-06T23:00:22.229822+00:00 2022-11-06T23:00:25.368981+00:00 0:00:03.139159 280733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-06T23:00:19.966916+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-04T23:00:00+00:00 EmrJobFlowSensor 2022-11-05T23:01:06.006680+00:00 2022-11-05T23:13:07.993050+00:00 0:12:01.986370 280105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-05T23:01:03.804921+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-04T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-05T23:00:43.789344+00:00 2022-11-05T23:00:44.569073+00:00 0:00:00.779729 280103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-05T23:00:41.672595+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-04T23:00:00+00:00 PythonOperator 2022-11-05T23:00:23.776191+00:00 2022-11-05T23:00:27.133615+00:00 0:00:03.357424 280101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-05T23:00:21.654081+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-03T23:00:00+00:00 EmrJobFlowSensor 2022-11-04T23:01:02.207976+00:00 2022-11-04T23:12:03.917682+00:00 0:11:01.709706 279479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-04T23:00:59.973174+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-03T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-04T23:00:40.415783+00:00 2022-11-04T23:00:41.192662+00:00 0:00:00.776879 279476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-04T23:00:37.951518+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-03T23:00:00+00:00 PythonOperator 2022-11-04T23:00:18.803071+00:00 2022-11-04T23:00:21.966451+00:00 0:00:03.163380 279473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-04T23:00:16.003009+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-02T23:00:00+00:00 EmrJobFlowSensor 2022-11-03T23:01:02.411474+00:00 2022-11-03T23:19:04.977232+00:00 0:18:02.565758 278850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-03T23:01:00.223940+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-02T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-03T23:00:40.268904+00:00 2022-11-03T23:00:41.046355+00:00 0:00:00.777451 278847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-03T23:00:38.062535+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-02T23:00:00+00:00 PythonOperator 2022-11-03T23:00:20.370854+00:00 2022-11-03T23:00:22.413132+00:00 0:00:02.042278 278844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-03T23:00:18.041275+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-11-01T23:00:00+00:00 EmrJobFlowSensor 2022-11-02T23:00:47.949571+00:00 2022-11-02T23:11:49.701362+00:00 0:11:01.751791 278219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-02T23:00:45.603498+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-11-01T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-02T23:00:27.902905+00:00 2022-11-02T23:00:28.625476+00:00 0:00:00.722571 278216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-02T23:00:25.523232+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-11-01T23:00:00+00:00 PythonOperator 2022-11-02T23:00:06.121150+00:00 2022-11-02T23:00:08.303960+00:00 0:00:02.182810 278213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-02T23:00:03.500726+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-31T23:00:00+00:00 EmrJobFlowSensor 2022-11-01T23:01:00.070294+00:00 2022-11-01T23:12:02.197978+00:00 0:11:02.127684 277586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-11-01T23:00:57.832934+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-31T23:00:00+00:00 EmrCreateJobFlowOperator 2022-11-01T23:00:39.951434+00:00 2022-11-01T23:00:40.682716+00:00 0:00:00.731282 277584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-11-01T23:00:37.812972+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-31T23:00:00+00:00 PythonOperator 2022-11-01T23:00:19.954486+00:00 2022-11-01T23:00:23.014707+00:00 0:00:03.060221 277581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-11-01T23:00:15.796247+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-30T23:00:00+00:00 EmrJobFlowSensor 2022-10-31T23:00:54.334811+00:00 2022-10-31T23:11:56.179192+00:00 0:11:01.844381 276950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-31T23:00:51.919505+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-30T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-31T23:00:32.428730+00:00 2022-10-31T23:00:33.469626+00:00 0:00:01.040896 276947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-31T23:00:29.878105+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-30T23:00:00+00:00 PythonOperator 2022-10-31T23:00:12.024908+00:00 2022-10-31T23:00:15.097985+00:00 0:00:03.073077 276944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-31T23:00:09.863135+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-29T23:00:00+00:00 EmrJobFlowSensor 2022-10-30T23:01:24.445029+00:00 2022-10-30T23:10:25.981237+00:00 0:09:01.536208 276321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-30T23:01:21.651293+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-29T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-30T23:00:44.562234+00:00 2022-10-30T23:00:46.032802+00:00 0:00:01.470568 276318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-30T23:00:39.987705+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-29T23:00:00+00:00 PythonOperator 2022-10-30T23:00:20.409157+00:00 2022-10-30T23:00:23.496937+00:00 0:00:03.087780 276314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-30T23:00:17.909234+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-28T23:00:00+00:00 EmrJobFlowSensor 2022-10-29T23:00:58.027481+00:00 2022-10-29T23:11:59.760389+00:00 0:11:01.732908 275691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-29T23:00:55.721057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-28T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-29T23:00:37.282928+00:00 2022-10-29T23:00:38.422186+00:00 0:00:01.139258 275688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-29T23:00:33.709589+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-28T23:00:00+00:00 PythonOperator 2022-10-29T23:00:15.960038+00:00 2022-10-29T23:00:18.010762+00:00 0:00:02.050724 275685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-29T23:00:13.602799+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-27T23:00:00+00:00 EmrJobFlowSensor 2022-10-28T23:00:59.715063+00:00 2022-10-28T23:13:01.911347+00:00 0:12:02.196284 275068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-28T23:00:57.486866+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-27T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-28T23:00:40.010125+00:00 2022-10-28T23:00:41.836927+00:00 0:00:01.826802 275065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-28T23:00:35.491765+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-27T23:00:00+00:00 PythonOperator 2022-10-28T23:00:16.393651+00:00 2022-10-28T23:00:22.329671+00:00 0:00:05.936020 275062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-28T23:00:13.457341+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-26T23:00:00+00:00 EmrJobFlowSensor 2022-10-27T23:00:56.024433+00:00 2022-10-27T23:11:58.067593+00:00 0:11:02.043160 274442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-27T23:00:53.515523+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-26T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-27T23:00:35.831108+00:00 2022-10-27T23:00:36.685049+00:00 0:00:00.853941 274439 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-27T23:00:33.499372+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-26T23:00:00+00:00 PythonOperator 2022-10-27T23:00:14.032001+00:00 2022-10-27T23:00:17.259046+00:00 0:00:03.227045 274436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-27T23:00:11.350484+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-25T23:00:00+00:00 EmrJobFlowSensor 2022-10-26T23:00:48.211530+00:00 2022-10-26T23:12:50.131441+00:00 0:12:01.919911 273814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-26T23:00:45.989016+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-25T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-26T23:00:26.408257+00:00 2022-10-26T23:00:27.302652+00:00 0:00:00.894395 273811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-26T23:00:24.002379+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-25T23:00:00+00:00 PythonOperator 2022-10-26T23:00:06.072919+00:00 2022-10-26T23:00:07.941150+00:00 0:00:01.868231 273808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-26T23:00:03.939302+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-24T23:00:00+00:00 EmrJobFlowSensor 2022-10-25T23:00:48.509462+00:00 2022-10-25T23:11:50.347773+00:00 0:11:01.838311 273195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-25T23:00:45.962593+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-24T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-25T23:00:26.327922+00:00 2022-10-25T23:00:27.241789+00:00 0:00:00.913867 273192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-25T23:00:24.005612+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-24T23:00:00+00:00 PythonOperator 2022-10-25T23:00:06.259930+00:00 2022-10-25T23:00:09.497819+00:00 0:00:03.237889 273189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-25T23:00:03.927732+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-23T23:00:00+00:00 EmrJobFlowSensor 2022-10-24T23:00:48.162855+00:00 2022-10-24T23:10:49.824432+00:00 0:10:01.661577 272568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-24T23:00:45.887586+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-23T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-24T23:00:26.104460+00:00 2022-10-24T23:00:26.869413+00:00 0:00:00.764953 272566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-24T23:00:23.807209+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-23T23:00:00+00:00 PythonOperator 2022-10-24T23:00:06.313129+00:00 2022-10-24T23:00:09.380932+00:00 0:00:03.067803 272563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-24T23:00:03.728839+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-22T23:00:00+00:00 EmrJobFlowSensor 2022-10-23T23:01:19.213854+00:00 2022-10-23T23:12:21.086413+00:00 0:11:01.872559 271919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-23T23:01:16.975604+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-22T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-23T23:00:59.092687+00:00 2022-10-23T23:01:00.202009+00:00 0:00:01.109322 271917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-23T23:00:56.956722+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-22T23:00:00+00:00 PythonOperator 2022-10-23T23:00:37.696636+00:00 2022-10-23T23:00:43.564404+00:00 0:00:05.867768 271915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-23T23:00:34.940264+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-21T23:00:00+00:00 EmrJobFlowSensor 2022-10-22T23:01:02.343158+00:00 2022-10-22T23:12:04.202262+00:00 0:11:01.859104 271266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-22T23:01:00.173717+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-21T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-22T23:00:42.530516+00:00 2022-10-22T23:00:43.740209+00:00 0:00:01.209693 271264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-22T23:00:40.139643+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-21T23:00:00+00:00 PythonOperator 2022-10-22T23:00:20.674986+00:00 2022-10-22T23:00:22.587957+00:00 0:00:01.912971 271262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-22T23:00:18.118473+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-20T23:00:00+00:00 EmrJobFlowSensor 2022-10-21T23:00:49.998423+00:00 2022-10-21T23:11:51.838135+00:00 0:11:01.839712 270616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-21T23:00:47.827068+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-20T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-21T23:00:30.033544+00:00 2022-10-21T23:00:30.867775+00:00 0:00:00.834231 270614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-21T23:00:27.802446+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-20T23:00:00+00:00 PythonOperator 2022-10-21T23:00:07.989582+00:00 2022-10-21T23:00:11.106457+00:00 0:00:03.116875 270611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-21T23:00:05.695909+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-19T23:00:00+00:00 EmrJobFlowSensor 2022-10-20T23:01:03.825197+00:00 2022-10-20T23:11:05.539033+00:00 0:10:01.713836 269964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-20T23:01:01.630900+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-19T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-20T23:00:43.906709+00:00 2022-10-20T23:00:44.722322+00:00 0:00:00.815613 269962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-20T23:00:41.576935+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-19T23:00:00+00:00 PythonOperator 2022-10-20T23:00:21.788357+00:00 2022-10-20T23:00:24.719046+00:00 0:00:02.930689 269960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-20T23:00:19.558148+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-18T23:00:00+00:00 EmrJobFlowSensor 2022-10-19T23:00:49.794326+00:00 2022-10-19T23:11:51.625895+00:00 0:11:01.831569 269311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-19T23:00:47.506651+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-18T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-19T23:00:29.793831+00:00 2022-10-19T23:00:30.713697+00:00 0:00:00.919866 269309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-19T23:00:27.508177+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-18T23:00:00+00:00 PythonOperator 2022-10-19T23:00:07.837350+00:00 2022-10-19T23:00:12.858962+00:00 0:00:05.021612 269306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-19T23:00:05.423574+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-17T23:00:00+00:00 EmrJobFlowSensor 2022-10-18T23:00:48.665283+00:00 2022-10-18T23:10:50.447133+00:00 0:10:01.781850 268653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-18T23:00:46.298218+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-17T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-18T23:00:28.265138+00:00 2022-10-18T23:00:29.000189+00:00 0:00:00.735051 268651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-18T23:00:26.128865+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-17T23:00:00+00:00 PythonOperator 2022-10-18T23:00:06.622047+00:00 2022-10-18T23:00:09.740286+00:00 0:00:03.118239 268648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-18T23:00:04.133156+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-16T23:00:00+00:00 EmrJobFlowSensor 2022-10-17T23:00:56.511205+00:00 2022-10-17T23:10:58.401187+00:00 0:10:01.889982 268005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-17T23:00:54.290869+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-16T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-17T23:00:34.799968+00:00 2022-10-17T23:00:35.566918+00:00 0:00:00.766950 268003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-17T23:00:32.390452+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-16T23:00:00+00:00 PythonOperator 2022-10-17T23:00:14.529644+00:00 2022-10-17T23:00:16.518937+00:00 0:00:01.989293 268001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-17T23:00:12.149065+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-15T23:00:00+00:00 EmrJobFlowSensor 2022-10-16T23:01:03.113793+00:00 2022-10-16T23:12:05.211300+00:00 0:11:02.097507 267355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-16T23:01:00.308382+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-15T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-16T23:00:42.748493+00:00 2022-10-16T23:00:43.474431+00:00 0:00:00.725938 267353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-16T23:00:40.208277+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-15T23:00:00+00:00 PythonOperator 2022-10-16T23:00:20.540310+00:00 2022-10-16T23:00:22.515313+00:00 0:00:01.975003 267350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-16T23:00:18.185035+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-14T23:00:00+00:00 EmrJobFlowSensor 2022-10-15T23:01:04.766848+00:00 2022-10-15T23:11:06.594284+00:00 0:10:01.827436 266703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-15T23:01:02.290868+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-14T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-15T23:00:42.478498+00:00 2022-10-15T23:00:43.256478+00:00 0:00:00.777980 266701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-15T23:00:40.220526+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-14T23:00:00+00:00 PythonOperator 2022-10-15T23:00:22.644759+00:00 2022-10-15T23:00:26.922961+00:00 0:00:04.278202 266699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-15T23:00:20.217791+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-13T23:00:00+00:00 EmrJobFlowSensor 2022-10-14T23:00:52.233728+00:00 2022-10-14T23:10:54.287609+00:00 0:10:02.053881 266054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-14T23:00:50.092401+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-13T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-14T23:00:30.653796+00:00 2022-10-14T23:00:31.417594+00:00 0:00:00.763798 266052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-14T23:00:28.035118+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-13T23:00:00+00:00 PythonOperator 2022-10-14T23:00:10.246068+00:00 2022-10-14T23:00:13.310348+00:00 0:00:03.064280 266049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-14T23:00:07.990673+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-12T23:00:00+00:00 EmrJobFlowSensor 2022-10-13T23:00:46.230681+00:00 2022-10-13T23:10:47.982266+00:00 0:10:01.751585 265400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-13T23:00:43.851859+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-12T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-13T23:00:26.137120+00:00 2022-10-13T23:00:26.883140+00:00 0:00:00.746020 265398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-13T23:00:23.906026+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-12T23:00:00+00:00 PythonOperator 2022-10-13T23:00:04.006971+00:00 2022-10-13T23:00:06.952457+00:00 0:00:02.945486 265395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-13T23:00:01.796877+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-11T23:00:00+00:00 EmrJobFlowSensor 2022-10-12T23:01:11.909380+00:00 2022-10-12T23:11:13.696927+00:00 0:10:01.787547 264751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-12T23:01:09.468013+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-11T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-12T23:00:49.861706+00:00 2022-10-12T23:00:50.695755+00:00 0:00:00.834049 264748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-12T23:00:47.510332+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-11T23:00:00+00:00 PythonOperator 2022-10-12T23:00:31.889983+00:00 2022-10-12T23:00:35.146357+00:00 0:00:03.256374 264746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-12T23:00:27.078427+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-10T23:00:00+00:00 EmrJobFlowSensor 2022-10-11T23:01:01.139498+00:00 2022-10-11T23:11:02.976183+00:00 0:10:01.836685 264106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-11T23:00:58.723333+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-10T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-11T23:00:40.990122+00:00 2022-10-11T23:00:41.871908+00:00 0:00:00.881786 264103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-11T23:00:38.646374+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-10T23:00:00+00:00 PythonOperator 2022-10-11T23:00:18.891313+00:00 2022-10-11T23:00:20.892588+00:00 0:00:02.001275 264100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-11T23:00:16.607447+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-09T23:00:00+00:00 EmrJobFlowSensor 2022-10-10T23:00:59.382025+00:00 2022-10-10T23:11:01.175189+00:00 0:10:01.793164 263467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-10T23:00:57.197363+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-09T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-10T23:00:37.329069+00:00 2022-10-10T23:00:38.091712+00:00 0:00:00.762643 263464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-10T23:00:35.097707+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-09T23:00:00+00:00 PythonOperator 2022-10-10T23:00:18.732883+00:00 2022-10-10T23:00:22.346360+00:00 0:00:03.613477 263461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-10T23:00:15.082580+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-08T23:00:00+00:00 EmrJobFlowSensor 2022-10-09T23:00:47.650709+00:00 2022-10-09T23:11:49.574814+00:00 0:11:01.924105 262813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-09T23:00:45.337208+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-08T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-09T23:00:28.078773+00:00 2022-10-09T23:00:28.833992+00:00 0:00:00.755219 262811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-09T23:00:25.248235+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-08T23:00:00+00:00 PythonOperator 2022-10-09T23:00:05.672200+00:00 2022-10-09T23:00:07.762063+00:00 0:00:02.089863 262807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-09T23:00:03.234425+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-07T23:00:00+00:00 EmrJobFlowSensor 2022-10-08T23:00:50.189908+00:00 2022-10-08T23:10:51.873258+00:00 0:10:01.683350 262140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-08T23:00:48.087221+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-07T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-08T23:00:28.584171+00:00 2022-10-08T23:00:29.312674+00:00 0:00:00.728503 262138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-08T23:00:26.067223+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-07T23:00:00+00:00 PythonOperator 2022-10-08T23:00:07.630096+00:00 2022-10-08T23:00:09.467853+00:00 0:00:01.837757 262135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-08T23:00:04.113611+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-06T23:00:00+00:00 EmrJobFlowSensor 2022-10-07T23:00:52.091219+00:00 2022-10-07T23:11:54.026780+00:00 0:11:01.935561 261463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-07T23:00:49.948061+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-06T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-07T23:00:32.476171+00:00 2022-10-07T23:00:33.400877+00:00 0:00:00.924706 261460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-07T23:00:29.938201+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2022-10-06T23:00:00+00:00 PythonOperator 2022-10-07T23:00:10.126524+00:00 2022-10-07T23:00:15.519730+00:00 0:00:05.393206 261457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2022-10-07T23:00:07.899826+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2022-10-05T23:00:00+00:00 EmrJobFlowSensor 2022-10-06T23:00:54.325045+00:00 2022-10-06T23:10:56.152258+00:00 0:10:01.827213 260983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2022-10-06T23:00:52.010336+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2022-10-05T23:00:00+00:00 EmrCreateJobFlowOperator 2022-10-06T23:00:34.027831+00:00 2022-10-06T23:00:34.753220+00:00 0:00:00.725389 260981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2022-10-06T23:00:31.930941+00:00 2 default_pool