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-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T00:00:26.656047+00:00 2023-11-15T00:00:27.676077+00:00 0:00:01.020030 446530 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T00:00:24.731155+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T23:00:00+00:00 PythonOperator 2023-11-15T00:00:06.956700+00:00 2023-11-15T00:00:09.175276+00:00 0:00:02.218576 446529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T00:00:04.714868+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T22:00:00+00:00 EmrJobFlowSensor 2023-11-14T23:00:47.932675+00:00 2023-11-14T23:25:51.952047+00:00 0:25:04.019372 446516 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T23:00:45.965269+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T23:00:25.867881+00:00 2023-11-14T23:00:26.864921+00:00 0:00:00.997040 446514 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T23:00:23.938546+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T22:00:00+00:00 PythonOperator 2023-11-14T23:00:06.153587+00:00 2023-11-14T23:00:08.397984+00:00 0:00:02.244397 446512 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T23:00:03.920239+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T21:00:00+00:00 EmrJobFlowSensor 2023-11-14T22:01:03.257110+00:00 2023-11-14T22:24:06.991664+00:00 0:23:03.734554 446500 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T22:01:01.300590+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T22:00:41.276373+00:00 2023-11-14T22:00:42.181782+00:00 0:00:00.905409 446499 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T22:00:39.282794+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T21:00:00+00:00 PythonOperator 2023-11-14T22:00:21.403464+00:00 2023-11-14T22:00:23.638234+00:00 0:00:02.234770 446498 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T22:00:19.263367+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T20:00:00+00:00 EmrJobFlowSensor 2023-11-14T21:01:02.411561+00:00 2023-11-14T21:26:06.222539+00:00 0:25:03.810978 446486 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T21:01:00.392287+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T21:00:42.346991+00:00 2023-11-14T21:00:43.399936+00:00 0:00:01.052945 446485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T21:00:40.376985+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T20:00:00+00:00 PythonOperator 2023-11-14T21:00:20.554316+00:00 2023-11-14T21:00:22.703648+00:00 0:00:02.149332 446484 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T21:00:18.357570+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T19:00:00+00:00 EmrJobFlowSensor 2023-11-14T20:01:02.904124+00:00 2023-11-14T20:27:06.803069+00:00 0:26:03.898945 446472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T20:01:00.896911+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T20:00:40.780423+00:00 2023-11-14T20:00:41.812709+00:00 0:00:01.032286 446471 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T20:00:38.873932+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T19:00:00+00:00 PythonOperator 2023-11-14T20:00:20.959303+00:00 2023-11-14T20:00:23.150871+00:00 0:00:02.191568 446470 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T20:00:18.858027+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T18:00:00+00:00 EmrJobFlowSensor 2023-11-14T19:00:57.312347+00:00 2023-11-14T19:28:01.309067+00:00 0:27:03.996720 446458 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T19:00:55.348743+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T19:00:37.258545+00:00 2023-11-14T19:00:38.336236+00:00 0:00:01.077691 446457 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T19:00:35.328158+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T18:00:00+00:00 PythonOperator 2023-11-14T19:00:15.557372+00:00 2023-11-14T19:00:17.665337+00:00 0:00:02.107965 446456 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T19:00:13.309749+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T17:00:00+00:00 EmrJobFlowSensor 2023-11-14T18:00:47.579567+00:00 2023-11-14T18:26:51.472866+00:00 0:26:03.893299 446444 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T18:00:45.590059+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T18:00:25.541193+00:00 2023-11-14T18:00:26.668207+00:00 0:00:01.127014 446443 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T18:00:23.570869+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T17:00:00+00:00 PythonOperator 2023-11-14T18:00:05.891319+00:00 2023-11-14T18:00:08.140608+00:00 0:00:02.249289 446442 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T18:00:03.549897+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T16:00:00+00:00 EmrJobFlowSensor 2023-11-14T17:00:55.454263+00:00 2023-11-14T17:24:58.987123+00:00 0:24:03.532860 446431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T17:00:53.520428+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T17:00:33.562913+00:00 2023-11-14T17:00:34.624773+00:00 0:00:01.061860 446430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T17:00:31.554083+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T16:00:00+00:00 PythonOperator 2023-11-14T17:00:11.770390+00:00 2023-11-14T17:00:13.934778+00:00 0:00:02.164388 446429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T17:00:09.490920+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T15:00:00+00:00 EmrJobFlowSensor 2023-11-14T16:01:03.662157+00:00 2023-11-14T16:26:07.357040+00:00 0:25:03.694883 446417 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T16:01:01.700318+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T16:00:43.656162+00:00 2023-11-14T16:00:44.765244+00:00 0:00:01.109082 446416 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T16:00:41.686010+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T15:00:00+00:00 PythonOperator 2023-11-14T16:00:21.769028+00:00 2023-11-14T16:00:23.983950+00:00 0:00:02.214922 446415 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T16:00:19.664729+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T14:00:00+00:00 EmrJobFlowSensor 2023-11-14T15:06:29.440590+00:00 2023-11-14T15:31:33.268838+00:00 0:25:03.828248 446408 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T15:06:27.488357+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T15:06:09.517514+00:00 2023-11-14T15:06:10.528975+00:00 0:00:01.011461 446406 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T15:06:07.470050+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T14:00:00+00:00 PythonOperator 2023-11-14T15:05:47.363309+00:00 2023-11-14T15:05:49.522557+00:00 0:00:02.159248 446404 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T15:05:45.448847+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T13:00:00+00:00 EmrJobFlowSensor 2023-11-14T14:00:49.545671+00:00 2023-11-14T14:25:53.192615+00:00 0:25:03.646944 446391 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T14:00:47.564001+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T14:00:29.498812+00:00 2023-11-14T14:00:30.741778+00:00 0:00:01.242966 446390 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T14:00:27.496204+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T13:00:00+00:00 PythonOperator 2023-11-14T14:00:07.636328+00:00 2023-11-14T14:00:09.883509+00:00 0:00:02.247181 446389 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T14:00:05.439337+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T12:00:00+00:00 EmrJobFlowSensor 2023-11-14T13:01:06.245749+00:00 2023-11-14T13:26:09.946469+00:00 0:25:03.700720 446377 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T13:01:04.247029+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T13:00:46.217580+00:00 2023-11-14T13:00:47.189166+00:00 0:00:00.971586 446376 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T13:00:44.230683+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T12:00:00+00:00 PythonOperator 2023-11-14T13:00:24.511004+00:00 2023-11-14T13:00:26.658628+00:00 0:00:02.147624 446375 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T13:00:22.262455+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T11:00:00+00:00 EmrJobFlowSensor 2023-11-14T12:00:46.956080+00:00 2023-11-14T12:26:51.040812+00:00 0:26:04.084732 446364 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T12:00:45.016657+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T12:00:26.968426+00:00 2023-11-14T12:00:28.000396+00:00 0:00:01.031970 446363 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T12:00:24.995381+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T11:00:00+00:00 PythonOperator 2023-11-14T12:00:05.062922+00:00 2023-11-14T12:00:07.334718+00:00 0:00:02.271796 446362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T12:00:02.978440+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T10:00:00+00:00 EmrJobFlowSensor 2023-11-14T11:00:53.677533+00:00 2023-11-14T11:26:57.594317+00:00 0:26:03.916784 446350 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T11:00:51.656319+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T11:00:33.594091+00:00 2023-11-14T11:00:34.577684+00:00 0:00:00.983593 446349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T11:00:31.611258+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T10:00:00+00:00 PythonOperator 2023-11-14T11:00:11.648262+00:00 2023-11-14T11:00:13.775092+00:00 0:00:02.126830 446348 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T11:00:09.592126+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T09:00:00+00:00 EmrJobFlowSensor 2023-11-14T10:00:50.445656+00:00 2023-11-14T10:25:54.184830+00:00 0:25:03.739174 446337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T10:00:48.511208+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T10:00:30.457251+00:00 2023-11-14T10:00:31.679323+00:00 0:00:01.222072 446336 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T10:00:28.492276+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T09:00:00+00:00 PythonOperator 2023-11-14T10:00:08.564953+00:00 2023-11-14T10:00:10.774498+00:00 0:00:02.209545 446335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T10:00:06.473170+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T08:00:00+00:00 EmrJobFlowSensor 2023-11-14T09:00:49.645795+00:00 2023-11-14T09:25:53.572255+00:00 0:25:03.926460 446323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T09:00:47.692066+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T09:00:27.575582+00:00 2023-11-14T09:00:28.606380+00:00 0:00:01.030798 446322 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T09:00:25.659045+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T08:00:00+00:00 PythonOperator 2023-11-14T09:00:07.665333+00:00 2023-11-14T09:00:09.881577+00:00 0:00:02.216244 446321 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T09:00:05.644814+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T07:00:00+00:00 EmrJobFlowSensor 2023-11-14T08:00:50.648964+00:00 2023-11-14T08:27:55.007065+00:00 0:27:04.358101 446309 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T08:00:48.742020+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T08:00:30.694434+00:00 2023-11-14T08:00:32.037700+00:00 0:00:01.343266 446308 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T08:00:28.723259+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T07:00:00+00:00 PythonOperator 2023-11-14T08:00:08.748647+00:00 2023-11-14T08:00:10.878163+00:00 0:00:02.129516 446307 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T08:00:06.703268+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T06:00:00+00:00 EmrJobFlowSensor 2023-11-14T07:01:04.997591+00:00 2023-11-14T07:28:08.982267+00:00 0:27:03.984676 446295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T07:01:03.055760+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T07:00:42.875494+00:00 2023-11-14T07:00:43.845626+00:00 0:00:00.970132 446294 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T07:00:40.944314+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T06:00:00+00:00 PythonOperator 2023-11-14T07:00:22.967934+00:00 2023-11-14T07:00:25.115939+00:00 0:00:02.148005 446293 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T07:00:20.921507+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T05:00:00+00:00 EmrJobFlowSensor 2023-11-14T06:00:59.024385+00:00 2023-11-14T06:28:02.967144+00:00 0:27:03.942759 446281 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T06:00:56.876892+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T06:00:38.878647+00:00 2023-11-14T06:00:39.914249+00:00 0:00:01.035602 446280 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T06:00:36.859245+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T05:00:00+00:00 PythonOperator 2023-11-14T06:00:17.024710+00:00 2023-11-14T06:00:19.194416+00:00 0:00:02.169706 446279 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T06:00:14.839414+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T04:00:00+00:00 EmrJobFlowSensor 2023-11-14T05:00:45.561266+00:00 2023-11-14T05:26:49.503336+00:00 0:26:03.942070 446268 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T05:00:43.648858+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T05:00:25.546698+00:00 2023-11-14T05:00:26.574779+00:00 0:00:01.028081 446267 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T05:00:23.632139+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T04:00:00+00:00 PythonOperator 2023-11-14T05:00:03.860817+00:00 2023-11-14T05:00:06.062517+00:00 0:00:02.201700 446266 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T05:00:01.613989+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T03:00:00+00:00 EmrJobFlowSensor 2023-11-14T04:01:07.344841+00:00 2023-11-14T04:26:11.096605+00:00 0:25:03.751764 446254 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T04:01:05.255978+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T04:00:45.235316+00:00 2023-11-14T04:00:46.274937+00:00 0:00:01.039621 446252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T04:00:43.097150+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T03:00:00+00:00 PythonOperator 2023-11-14T04:00:25.054447+00:00 2023-11-14T04:00:28.224882+00:00 0:00:03.170435 446250 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T04:00:23.088932+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T02:00:00+00:00 EmrJobFlowSensor 2023-11-14T03:07:47.457877+00:00 2023-11-14T03:32:51.412716+00:00 0:25:03.954839 446243 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T03:07:45.522157+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T03:07:27.815104+00:00 2023-11-14T03:07:28.747401+00:00 0:00:00.932297 446241 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T03:07:25.505538+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T02:00:00+00:00 PythonOperator 2023-11-14T03:07:05.804782+00:00 2023-11-14T03:07:08.008030+00:00 0:00:02.203248 446239 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T03:07:03.489124+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T01:00:00+00:00 EmrJobFlowSensor 2023-11-14T02:01:07.088862+00:00 2023-11-14T02:25:10.804067+00:00 0:24:03.715205 446230 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T02:01:05.086555+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T02:00:45.133083+00:00 2023-11-14T02:00:46.216929+00:00 0:00:01.083846 446229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T02:00:43.027720+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T01:00:00+00:00 PythonOperator 2023-11-14T02:00:25.795121+00:00 2023-11-14T02:00:28.082735+00:00 0:00:02.287614 446228 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T02:00:23.009416+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T00:00:00+00:00 EmrJobFlowSensor 2023-11-14T01:00:54.756008+00:00 2023-11-14T01:25:58.619195+00:00 0:25:03.863187 446212 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T01:00:52.690675+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-14T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T01:00:34.549250+00:00 2023-11-14T01:00:35.566540+00:00 0:00:01.017290 446211 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T01:00:32.613829+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-14T00:00:00+00:00 PythonOperator 2023-11-14T01:00:12.664684+00:00 2023-11-14T01:00:14.831018+00:00 0:00:02.166334 446210 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T01:00:10.595578+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T23:00:00+00:00 EmrJobFlowSensor 2023-11-14T00:00:56.214149+00:00 2023-11-14T00:25:59.959293+00:00 0:25:03.745144 446200 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-14T00:00:54.195030+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-14T00:00:34.149959+00:00 2023-11-14T00:00:35.279092+00:00 0:00:01.129133 446199 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-14T00:00:32.175557+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T23:00:00+00:00 PythonOperator 2023-11-14T00:00:14.260222+00:00 2023-11-14T00:00:16.464644+00:00 0:00:02.204422 446198 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-14T00:00:12.159197+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T22:00:00+00:00 EmrJobFlowSensor 2023-11-13T23:00:46.634984+00:00 2023-11-13T23:25:50.339497+00:00 0:25:03.704513 446186 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T23:00:44.761561+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T23:00:24.781015+00:00 2023-11-13T23:00:25.828733+00:00 0:00:01.047718 446184 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T23:00:22.768111+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T22:00:00+00:00 PythonOperator 2023-11-13T23:00:04.964965+00:00 2023-11-13T23:00:07.272143+00:00 0:00:02.307178 446182 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T23:00:02.779706+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T21:00:00+00:00 EmrJobFlowSensor 2023-11-13T22:00:56.930164+00:00 2023-11-13T22:24:00.702953+00:00 0:23:03.772789 446171 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T22:00:54.991692+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T22:00:34.933755+00:00 2023-11-13T22:00:36.022057+00:00 0:00:01.088302 446170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T22:00:32.972316+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T21:00:00+00:00 PythonOperator 2023-11-13T22:00:15.077298+00:00 2023-11-13T22:00:17.237073+00:00 0:00:02.159775 446169 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T22:00:12.954428+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T20:00:00+00:00 EmrJobFlowSensor 2023-11-13T21:00:57.237214+00:00 2023-11-13T21:27:01.109142+00:00 0:26:03.871928 446157 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T21:00:55.266598+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T21:00:37.202449+00:00 2023-11-13T21:00:38.242272+00:00 0:00:01.039823 446156 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T21:00:35.249345+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T20:00:00+00:00 PythonOperator 2023-11-13T21:00:15.475817+00:00 2023-11-13T21:00:17.689450+00:00 0:00:02.213633 446155 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T21:00:13.227828+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T19:00:00+00:00 EmrJobFlowSensor 2023-11-13T20:04:34.755592+00:00 2023-11-13T20:31:38.864574+00:00 0:27:04.108982 446144 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T20:04:32.845406+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T20:04:14.745427+00:00 2023-11-13T20:04:15.787864+00:00 0:00:01.042437 446143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T20:04:12.826548+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T19:00:00+00:00 PythonOperator 2023-11-13T20:03:52.850112+00:00 2023-11-13T20:03:55.008313+00:00 0:00:02.158201 446142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T20:03:50.806494+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T18:00:00+00:00 EmrJobFlowSensor 2023-11-13T19:00:48.349043+00:00 2023-11-13T19:27:52.459749+00:00 0:27:04.110706 446130 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T19:00:46.380654+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T19:00:28.252690+00:00 2023-11-13T19:00:29.224132+00:00 0:00:00.971442 446129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T19:00:26.302744+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T18:00:00+00:00 PythonOperator 2023-11-13T19:00:06.431585+00:00 2023-11-13T19:00:08.631889+00:00 0:00:02.200304 446128 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T19:00:04.281970+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T17:00:00+00:00 EmrJobFlowSensor 2023-11-13T18:06:06.525532+00:00 2023-11-13T18:32:10.449473+00:00 0:26:03.923941 446119 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T18:06:04.511297+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T18:05:46.480951+00:00 2023-11-13T18:05:47.511851+00:00 0:00:01.030900 446117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T18:05:44.494438+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T17:00:00+00:00 PythonOperator 2023-11-13T18:05:24.746554+00:00 2023-11-13T18:05:26.974606+00:00 0:00:02.228052 446115 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T18:05:22.521993+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T16:00:00+00:00 EmrJobFlowSensor 2023-11-13T17:07:28.350506+00:00 2023-11-13T17:24:31.066296+00:00 0:17:02.715790 446104 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T17:07:26.275110+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T17:00:35.744720+00:00 2023-11-13T17:00:36.956453+00:00 0:00:01.211733 446102 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T17:00:33.669909+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T16:00:00+00:00 PythonOperator 2023-11-13T17:00:13.664205+00:00 2023-11-13T17:00:15.815282+00:00 0:00:02.151077 446101 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T17:00:11.650156+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T15:00:00+00:00 EmrJobFlowSensor 2023-11-13T16:00:56.379314+00:00 2023-11-13T16:26:00.099388+00:00 0:25:03.720074 446091 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T16:00:54.286913+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T16:00:34.202427+00:00 2023-11-13T16:00:35.530468+00:00 0:00:01.328041 446090 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T16:00:32.249585+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T15:00:00+00:00 PythonOperator 2023-11-13T16:00:14.255355+00:00 2023-11-13T16:00:16.431865+00:00 0:00:02.176510 446089 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T16:00:12.231971+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T14:00:00+00:00 EmrJobFlowSensor 2023-11-13T15:02:01.758347+00:00 2023-11-13T15:28:05.753244+00:00 0:26:03.994897 446079 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T15:01:59.823138+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T15:01:41.753647+00:00 2023-11-13T15:01:42.671882+00:00 0:00:00.918235 446078 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T15:01:39.805769+00:00 2 default_pool