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 exchange-dsp-reporting_v002 check_cluster_status 2023-12-09T04:00:00+00:00 EmrJobFlowSensor 2023-12-10T04:00:58.790494+00:00 2023-12-10T04:11:00.477492+00:00 0:10:01.686998 454788 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T04:00:57.172160+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-09T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T04:00:37.018132+00:00 2023-12-10T04:00:38.095324+00:00 0:00:01.077192 454785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T04:00:35.129513+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-09T04:00:00+00:00 PythonOperator 2023-12-10T04:00:16.810525+00:00 2023-12-10T04:00:17.677290+00:00 0:00:00.866765 454782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T04:00:15.114075+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-08T04:00:00+00:00 EmrJobFlowSensor 2023-12-09T04:00:48.969545+00:00 2023-12-09T04:11:50.843616+00:00 0:11:01.874071 454314 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T04:00:47.280584+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T04:00:28.834043+00:00 2023-12-09T04:00:29.722650+00:00 0:00:00.888607 454311 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T04:00:27.217447+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-08T04:00:00+00:00 PythonOperator 2023-12-09T04:00:07.167829+00:00 2023-12-09T04:00:08.033686+00:00 0:00:00.865857 454308 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T04:00:05.203812+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-07T04:00:00+00:00 EmrJobFlowSensor 2023-12-08T04:00:59.797080+00:00 2023-12-08T04:11:01.582290+00:00 0:10:01.785210 453834 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T04:00:57.793929+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-07T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T04:00:39.624613+00:00 2023-12-08T04:00:40.432113+00:00 0:00:00.807500 453832 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T04:00:37.719419+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-07T04:00:00+00:00 PythonOperator 2023-12-08T04:00:17.296263+00:00 2023-12-08T04:00:18.145401+00:00 0:00:00.849138 453829 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T04:00:15.698352+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-06T04:00:00+00:00 EmrJobFlowSensor 2023-12-07T14:37:07.929408+00:00 2023-12-07T14:47:09.722779+00:00 0:10:01.793371 453529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T14:37:05.951270+00:00 3 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-05T04:00:00+00:00 EmrJobFlowSensor 2023-12-07T14:37:07.584021+00:00 2023-12-07T14:47:09.339541+00:00 0:10:01.755520 453528 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T14:37:05.951239+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-05T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:36:46.214864+00:00 2023-12-07T14:36:46.999144+00:00 0:00:00.784280 453526 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:36:43.925002+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-06T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:36:45.498114+00:00 2023-12-07T14:36:46.349317+00:00 0:00:00.851203 453525 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:36:43.925036+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-06T04:00:00+00:00 PythonOperator 2023-12-07T14:36:26.170855+00:00 2023-12-07T14:36:27.227156+00:00 0:00:01.056301 453523 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:36:23.908555+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-05T04:00:00+00:00 PythonOperator 2023-12-07T14:36:25.505087+00:00 2023-12-07T14:36:26.339184+00:00 0:00:00.834097 453522 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:36:23.908519+00:00 3 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-04T04:00:00+00:00 EmrJobFlowSensor 2023-12-05T04:01:00.708362+00:00 2023-12-05T04:11:02.616185+00:00 0:10:01.907823 452490 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-05T04:00:58.848792+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-04T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-05T04:00:38.791102+00:00 2023-12-05T04:00:39.562714+00:00 0:00:00.771612 452489 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-05T04:00:36.833543+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-04T04:00:00+00:00 PythonOperator 2023-12-05T04:00:16.832000+00:00 2023-12-05T04:00:17.678281+00:00 0:00:00.846281 452488 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-05T04:00:14.862509+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-03T04:00:00+00:00 EmrJobFlowSensor 2023-12-04T04:00:50.281441+00:00 2023-12-04T04:11:52.371030+00:00 0:11:02.089589 452227 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-04T04:00:48.629798+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-03T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-04T04:00:28.530041+00:00 2023-12-04T04:00:29.418636+00:00 0:00:00.888595 452226 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-04T04:00:26.611166+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-03T04:00:00+00:00 PythonOperator 2023-12-04T04:00:06.817900+00:00 2023-12-04T04:00:07.876298+00:00 0:00:01.058398 452225 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-04T04:00:04.591682+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-02T04:00:00+00:00 EmrJobFlowSensor 2023-12-03T04:00:56.401941+00:00 2023-12-03T04:10:58.199855+00:00 0:10:01.797914 451961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-03T04:00:54.811485+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-02T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-03T04:00:34.859928+00:00 2023-12-03T04:00:35.722025+00:00 0:00:00.862097 451960 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-03T04:00:32.858736+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-02T04:00:00+00:00 PythonOperator 2023-12-03T04:00:14.749849+00:00 2023-12-03T04:00:15.643392+00:00 0:00:00.893543 451959 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-03T04:00:12.778941+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-12-01T04:00:00+00:00 EmrJobFlowSensor 2023-12-02T04:00:55.190827+00:00 2023-12-02T04:11:57.145822+00:00 0:11:01.954995 451698 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-02T04:00:53.474051+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-12-01T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-02T04:00:33.320301+00:00 2023-12-02T04:00:34.171799+00:00 0:00:00.851498 451697 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-02T04:00:31.457817+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-12-01T04:00:00+00:00 PythonOperator 2023-12-02T04:00:13.252733+00:00 2023-12-02T04:00:14.112698+00:00 0:00:00.859965 451696 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-02T04:00:11.387256+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-30T04:00:00+00:00 EmrJobFlowSensor 2023-12-01T04:00:45.254376+00:00 2023-12-01T04:10:46.983101+00:00 0:10:01.728725 451429 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-01T04:00:43.593498+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-30T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-01T04:00:25.289608+00:00 2023-12-01T04:00:26.144817+00:00 0:00:00.855209 451428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-01T04:00:23.585417+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-30T04:00:00+00:00 PythonOperator 2023-12-01T04:00:03.321576+00:00 2023-12-01T04:00:04.192823+00:00 0:00:00.871247 451427 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-01T04:00:01.530020+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-29T04:00:00+00:00 EmrJobFlowSensor 2023-11-30T04:00:49.809534+00:00 2023-11-30T04:10:51.598650+00:00 0:10:01.789116 451154 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-30T04:00:47.912719+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-29T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-30T04:00:27.848260+00:00 2023-11-30T04:00:28.632043+00:00 0:00:00.783783 451153 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-30T04:00:25.892017+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-29T04:00:00+00:00 PythonOperator 2023-11-30T04:00:07.612905+00:00 2023-11-30T04:00:08.455056+00:00 0:00:00.842151 451152 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-30T04:00:05.875877+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-28T04:00:00+00:00 EmrJobFlowSensor 2023-11-29T04:01:06.828381+00:00 2023-11-29T04:11:08.680933+00:00 0:10:01.852552 450884 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-29T04:01:05.074414+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-28T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-29T04:00:44.914410+00:00 2023-11-29T04:00:45.869578+00:00 0:00:00.955168 450883 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-29T04:00:43.003454+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-28T04:00:00+00:00 PythonOperator 2023-11-29T04:00:23.041232+00:00 2023-11-29T04:00:24.114891+00:00 0:00:01.073659 450882 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-29T04:00:20.995000+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-27T04:00:00+00:00 EmrJobFlowSensor 2023-11-28T04:05:35.155164+00:00 2023-11-28T04:15:36.861319+00:00 0:10:01.706155 450614 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-28T04:05:33.205644+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-27T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-28T04:05:15.141131+00:00 2023-11-28T04:05:16.001373+00:00 0:00:00.860242 450612 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-28T04:05:13.186814+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-27T04:00:00+00:00 PythonOperator 2023-11-28T04:04:53.006103+00:00 2023-11-28T04:04:53.820572+00:00 0:00:00.814469 450611 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-28T04:04:51.213727+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-26T04:00:00+00:00 EmrJobFlowSensor 2023-11-27T04:01:04.490314+00:00 2023-11-27T04:11:06.306955+00:00 0:10:01.816641 450338 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-27T04:01:02.583045+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-26T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-27T04:00:44.498956+00:00 2023-11-27T04:00:45.322422+00:00 0:00:00.823466 450337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-27T04:00:42.565701+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-26T04:00:00+00:00 PythonOperator 2023-11-27T04:00:22.747752+00:00 2023-11-27T04:00:23.678461+00:00 0:00:00.930709 450336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-27T04:00:20.578882+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-25T04:00:00+00:00 EmrJobFlowSensor 2023-11-26T04:00:49.645392+00:00 2023-11-26T04:10:51.393820+00:00 0:10:01.748428 450070 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-26T04:00:47.662917+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-25T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-26T04:00:27.185699+00:00 2023-11-26T04:00:28.151388+00:00 0:00:00.965689 450069 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-26T04:00:25.589425+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-25T04:00:00+00:00 PythonOperator 2023-11-26T04:00:05.436757+00:00 2023-11-26T04:00:06.365574+00:00 0:00:00.928817 450068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-26T04:00:03.553955+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-24T04:00:00+00:00 EmrJobFlowSensor 2023-11-25T04:01:18.141547+00:00 2023-11-25T04:11:19.881918+00:00 0:10:01.740371 449800 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-25T04:01:16.466702+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-24T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-25T04:00:56.060090+00:00 2023-11-25T04:00:56.905507+00:00 0:00:00.845417 449799 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-25T04:00:54.446501+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-24T04:00:00+00:00 PythonOperator 2023-11-25T04:00:36.198630+00:00 2023-11-25T04:00:37.035252+00:00 0:00:00.836622 449798 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-25T04:00:34.426305+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-23T04:00:00+00:00 EmrJobFlowSensor 2023-11-24T04:01:05.486620+00:00 2023-11-24T04:11:07.378797+00:00 0:10:01.892177 449529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-24T04:01:03.537313+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-23T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-24T04:00:45.502527+00:00 2023-11-24T04:00:46.649200+00:00 0:00:01.146673 449528 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-24T04:00:43.517806+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-23T04:00:00+00:00 PythonOperator 2023-11-24T04:00:23.722273+00:00 2023-11-24T04:00:24.571464+00:00 0:00:00.849191 449527 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-24T04:00:21.572303+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-22T04:00:00+00:00 EmrJobFlowSensor 2023-11-23T04:01:01.796599+00:00 2023-11-23T04:11:03.683551+00:00 0:10:01.886952 449258 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-23T04:01:00.196899+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-22T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-23T04:00:41.741707+00:00 2023-11-23T04:00:42.583412+00:00 0:00:00.841705 449257 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-23T04:00:40.148828+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-22T04:00:00+00:00 PythonOperator 2023-11-23T04:00:19.892925+00:00 2023-11-23T04:00:20.739032+00:00 0:00:00.846107 449256 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-23T04:00:18.129663+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-21T04:00:00+00:00 EmrJobFlowSensor 2023-11-22T04:01:32.693761+00:00 2023-11-22T04:12:34.577525+00:00 0:11:01.883764 448976 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-22T04:01:31.096209+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-21T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-22T04:01:11.269374+00:00 2023-11-22T04:01:12.146436+00:00 0:00:00.877062 448974 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-22T04:01:09.063799+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-21T04:00:00+00:00 PythonOperator 2023-11-22T04:00:17.821771+00:00 2023-11-22T04:00:18.644888+00:00 0:00:00.823117 448970 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-22T04:00:16.116093+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-20T04:00:00+00:00 EmrJobFlowSensor 2023-11-21T04:00:57.553932+00:00 2023-11-21T04:11:59.512947+00:00 0:11:01.959015 448636 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T04:00:55.649535+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-20T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T04:00:37.538945+00:00 2023-11-21T04:00:38.372881+00:00 0:00:00.833936 448634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T04:00:35.633927+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-20T04:00:00+00:00 PythonOperator 2023-11-21T04:00:15.308185+00:00 2023-11-21T04:00:16.125173+00:00 0:00:00.816988 448632 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T04:00:13.608982+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-18T04:00:00+00:00 EmrJobFlowSensor 2023-11-20T10:47:55.344513+00:00 2023-11-20T10:57:57.306829+00:00 0:10:01.962316 448324 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T10:47:53.359733+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-18T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T10:47:33.425536+00:00 2023-11-20T10:47:34.275574+00:00 0:00:00.850038 448323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T10:47:31.384695+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-18T04:00:00+00:00 PythonOperator 2023-11-20T10:47:11.115948+00:00 2023-11-20T10:47:11.972211+00:00 0:00:00.856263 448322 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T10:47:09.324961+00:00 3 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-19T04:00:00+00:00 EmrJobFlowSensor 2023-11-20T10:36:08.446379+00:00 2023-11-20T10:46:10.241146+00:00 0:10:01.794767 448320 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T10:36:06.491077+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-19T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T10:35:46.003118+00:00 2023-11-20T10:35:47.201139+00:00 0:00:01.198021 448319 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T10:35:44.422321+00:00 3 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-19T04:00:00+00:00 PythonOperator 2023-11-20T10:35:26.139116+00:00 2023-11-20T10:35:26.994665+00:00 0:00:00.855549 448318 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T10:35:24.403431+00:00 3 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-17T04:00:00+00:00 EmrJobFlowSensor 2023-11-18T04:01:06.233329+00:00 2023-11-18T04:11:08.175245+00:00 0:10:01.941916 447619 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T04:01:04.334855+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-17T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T04:00:46.573735+00:00 2023-11-18T04:00:47.367289+00:00 0:00:00.793554 447617 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T04:00:44.318677+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-17T04:00:00+00:00 PythonOperator 2023-11-18T04:00:24.784725+00:00 2023-11-18T04:00:25.791320+00:00 0:00:01.006595 447615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T04:00:22.355638+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-16T04:00:00+00:00 EmrJobFlowSensor 2023-11-17T04:01:03.434591+00:00 2023-11-17T04:11:05.177417+00:00 0:10:01.742826 447283 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T04:01:01.337628+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-16T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T04:00:43.235179+00:00 2023-11-17T04:00:44.085274+00:00 0:00:00.850095 447281 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T04:00:41.318579+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-16T04:00:00+00:00 PythonOperator 2023-11-17T04:00:21.497672+00:00 2023-11-17T04:00:22.492608+00:00 0:00:00.994936 447279 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T04:00:19.298189+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-15T04:00:00+00:00 EmrJobFlowSensor 2023-11-16T04:01:53.607915+00:00 2023-11-16T04:11:55.430804+00:00 0:10:01.822889 446936 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T04:01:51.721901+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-15T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T04:01:33.587452+00:00 2023-11-16T04:01:34.354165+00:00 0:00:00.766713 446934 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T04:01:31.701327+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-15T04:00:00+00:00 PythonOperator 2023-11-16T04:01:12.016084+00:00 2023-11-16T04:01:13.026347+00:00 0:00:01.010263 446932 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T04:01:09.742955+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-14T04:00:00+00:00 EmrJobFlowSensor 2023-11-15T04:00:47.760710+00:00 2023-11-15T04:10:49.534703+00:00 0:10:01.773993 446595 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T04:00:45.789092+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-14T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T04:00:25.590138+00:00 2023-11-15T04:00:26.420806+00:00 0:00:00.830668 446593 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T04:00:23.724439+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-14T04:00:00+00:00 PythonOperator 2023-11-15T04:00:05.959418+00:00 2023-11-15T04:00:07.007368+00:00 0:00:01.047950 446591 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T04:00:03.709709+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-13T04:00:00+00:00 EmrJobFlowSensor 2023-11-14T04:00:49.178284+00:00 2023-11-14T04:11:51.048450+00:00 0:11:01.870166 446253 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T04:00:47.156312+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-13T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T04:00:27.858207+00:00 2023-11-14T04:00:28.764507+00:00 0:00:00.906300 446251 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T04:00:25.108351+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-13T04:00:00+00:00 PythonOperator 2023-11-14T04:00:07.227808+00:00 2023-11-14T04:00:08.232270+00:00 0:00:01.004462 446249 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T04:00:05.065190+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-12T04:00:00+00:00 EmrJobFlowSensor 2023-11-13T04:07:48.399750+00:00 2023-11-13T04:18:50.233731+00:00 0:11:01.833981 445944 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T04:07:46.514913+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-12T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T04:07:26.688755+00:00 2023-11-13T04:07:27.479233+00:00 0:00:00.790478 445941 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T04:07:24.494433+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-12T04:00:00+00:00 PythonOperator 2023-11-13T04:07:06.675339+00:00 2023-11-13T04:07:07.643556+00:00 0:00:00.968217 445938 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T04:07:04.478327+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-11T04:00:00+00:00 EmrJobFlowSensor 2023-11-12T04:00:59.559174+00:00 2023-11-12T04:12:01.575261+00:00 0:11:02.016087 445623 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T04:00:57.586936+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-11T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T04:00:39.509690+00:00 2023-11-12T04:00:40.356654+00:00 0:00:00.846964 445621 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T04:00:37.563063+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-11T04:00:00+00:00 PythonOperator 2023-11-12T04:00:17.439515+00:00 2023-11-12T04:00:18.417616+00:00 0:00:00.978101 445619 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T04:00:15.532719+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-10T04:00:00+00:00 EmrJobFlowSensor 2023-11-11T04:00:59.900006+00:00 2023-11-11T04:12:01.856400+00:00 0:11:01.956394 445316 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T04:00:58.041046+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-10T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T04:00:37.904431+00:00 2023-11-11T04:00:38.754330+00:00 0:00:00.849899 445314 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T04:00:36.022017+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-10T04:00:00+00:00 PythonOperator 2023-11-11T04:00:18.223578+00:00 2023-11-11T04:00:19.287192+00:00 0:00:01.063614 445312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T04:00:16.004395+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-09T04:00:00+00:00 EmrJobFlowSensor 2023-11-10T04:01:01.906825+00:00 2023-11-10T04:11:03.740357+00:00 0:10:01.833532 444994 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T04:00:59.954054+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-09T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T04:00:39.905135+00:00 2023-11-10T04:00:40.843544+00:00 0:00:00.938409 444993 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T04:00:37.884173+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-09T04:00:00+00:00 PythonOperator 2023-11-10T04:00:19.890993+00:00 2023-11-10T04:00:20.858697+00:00 0:00:00.967704 444992 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T04:00:17.869140+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-08T04:00:00+00:00 EmrJobFlowSensor 2023-11-09T04:00:50.922484+00:00 2023-11-09T04:11:52.696274+00:00 0:11:01.773790 444729 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-09T04:00:49.055845+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-09T04:00:30.945978+00:00 2023-11-09T04:00:31.778227+00:00 0:00:00.832249 444728 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-09T04:00:29.044514+00:00 2 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-08T04:00:00+00:00 PythonOperator 2023-11-09T04:00:09.143738+00:00 2023-11-09T04:00:10.090363+00:00 0:00:00.946625 444726 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-09T04:00:07.017380+00:00 2 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-03T04:00:00+00:00 EmrJobFlowSensor 2023-11-08T04:33:43.228849+00:00 2023-11-08T04:44:45.128607+00:00 0:11:01.899758 444351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T04:33:41.348697+00:00 8 default_pool
success exchange-dsp-reporting_v002 create_cluster_and_add_emr_steps 2023-11-03T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T04:33:31.097087+00:00 2023-11-08T04:33:31.939434+00:00 0:00:00.842347 444350 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T14:58:40.703536+00:00 4 default_pool
success exchange-dsp-reporting_v002 create_emr_steps 2023-11-03T04:00:00+00:00 PythonOperator 2023-11-08T04:33:24.712740+00:00 2023-11-08T04:33:26.016078+00:00 0:00:01.303338 444348 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T04:33:21.331919+00:00 4 default_pool
success exchange-dsp-reporting_v002 check_cluster_status 2023-11-02T02:00:00+00:00 EmrJobFlowSensor 2023-11-08T04:10:06.130645+00:00 2023-11-08T04:21:08.091050+00:00 0:11:01.960405 444340 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T04:10:04.086988+00:00 14 default_pool