Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T07:00:00+00:00 EmrJobFlowSensor 2023-12-17T08:00:48.565308+00:00 2023-12-17T08:25:52.222044+00:00 0:25:03.656736 458364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T08:00:46.861039+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T08:00:28.893733+00:00 2023-12-17T08:00:29.744366+00:00 0:00:00.850633 458362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T08:00:26.830665+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T07:00:00+00:00 PythonOperator 2023-12-17T08:00:06.985187+00:00 2023-12-17T08:00:08.541759+00:00 0:00:01.556572 458360 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T08:00:04.811934+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T06:00:00+00:00 EmrJobFlowSensor 2023-12-17T07:03:23.796278+00:00 2023-12-17T07:28:27.914423+00:00 0:25:04.118145 458347 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T07:03:21.686836+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T07:03:03.352878+00:00 2023-12-17T07:03:04.441222+00:00 0:00:01.088344 458345 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T07:03:01.662743+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T06:00:00+00:00 PythonOperator 2023-12-17T07:02:42.092072+00:00 2023-12-17T07:02:43.633063+00:00 0:00:01.540991 458343 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T07:02:39.693645+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T05:00:00+00:00 EmrJobFlowSensor 2023-12-17T06:01:04.266239+00:00 2023-12-17T06:26:08.071298+00:00 0:25:03.805059 458332 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T06:01:02.152051+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T06:00:41.846661+00:00 2023-12-17T06:00:42.754257+00:00 0:00:00.907596 458330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T06:00:40.085258+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T05:00:00+00:00 PythonOperator 2023-12-17T06:00:21.701933+00:00 2023-12-17T06:00:23.267652+00:00 0:00:01.565719 458328 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T06:00:20.011785+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T04:00:00+00:00 EmrJobFlowSensor 2023-12-17T05:00:52.758929+00:00 2023-12-17T05:25:56.998823+00:00 0:25:04.239894 458314 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T05:00:50.549555+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T05:00:32.725551+00:00 2023-12-17T05:00:33.604929+00:00 0:00:00.879378 458312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T05:00:30.486421+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T04:00:00+00:00 PythonOperator 2023-12-17T05:00:10.295105+00:00 2023-12-17T05:00:11.847035+00:00 0:00:01.551930 458309 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T05:00:08.412733+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T03:00:00+00:00 EmrJobFlowSensor 2023-12-17T04:00:51.917159+00:00 2023-12-17T04:25:56.109298+00:00 0:25:04.192139 458294 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T04:00:49.461393+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T04:00:31.497772+00:00 2023-12-17T04:00:32.700611+00:00 0:00:01.202839 458291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T04:00:29.392806+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T03:00:00+00:00 PythonOperator 2023-12-17T04:00:09.561271+00:00 2023-12-17T04:00:11.209063+00:00 0:00:01.647792 458288 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T04:00:07.361027+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T02:00:00+00:00 EmrJobFlowSensor 2023-12-17T03:00:58.343220+00:00 2023-12-17T03:26:02.195328+00:00 0:25:03.852108 458273 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T03:00:55.683092+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T03:00:35.874283+00:00 2023-12-17T03:00:36.869575+00:00 0:00:00.995292 458271 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T03:00:33.682710+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T02:00:00+00:00 PythonOperator 2023-12-17T03:00:15.787444+00:00 2023-12-17T03:00:17.388108+00:00 0:00:01.600664 458269 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T03:00:13.632225+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T01:00:00+00:00 EmrJobFlowSensor 2023-12-17T02:01:01.837777+00:00 2023-12-17T02:26:05.696374+00:00 0:25:03.858597 458255 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T02:01:00.127342+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T02:00:42.997339+00:00 2023-12-17T02:00:43.881826+00:00 0:00:00.884487 458254 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T02:00:40.105153+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T01:00:00+00:00 PythonOperator 2023-12-17T02:00:20.286181+00:00 2023-12-17T02:00:21.864523+00:00 0:00:01.578342 458251 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T02:00:18.085483+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T00:00:00+00:00 EmrJobFlowSensor 2023-12-17T01:00:52.634171+00:00 2023-12-17T01:25:56.629995+00:00 0:25:03.995824 458231 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T01:00:50.417925+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T01:00:30.681466+00:00 2023-12-17T01:00:31.661128+00:00 0:00:00.979662 458229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T01:00:28.396924+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T00:00:00+00:00 PythonOperator 2023-12-17T01:00:10.485405+00:00 2023-12-17T01:00:12.106666+00:00 0:00:01.621261 458227 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T01:00:08.377508+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T23:00:00+00:00 EmrJobFlowSensor 2023-12-17T00:00:58.953373+00:00 2023-12-17T00:26:02.823123+00:00 0:25:03.869750 458213 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T00:00:57.249479+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T00:00:39.775311+00:00 2023-12-17T00:00:40.770608+00:00 0:00:00.995297 458211 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T00:00:37.179268+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T23:00:00+00:00 PythonOperator 2023-12-17T00:00:16.867512+00:00 2023-12-17T00:00:18.435944+00:00 0:00:01.568432 458209 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T00:00:15.120369+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T22:00:00+00:00 EmrJobFlowSensor 2023-12-16T23:01:06.402879+00:00 2023-12-16T23:26:10.080472+00:00 0:25:03.677593 458194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T23:01:04.342744+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T23:00:44.077156+00:00 2023-12-16T23:00:45.060620+00:00 0:00:00.983464 458191 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T23:00:42.324597+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T22:00:00+00:00 PythonOperator 2023-12-16T23:00:24.366510+00:00 2023-12-16T23:00:25.821009+00:00 0:00:01.454499 458188 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T23:00:22.307125+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T21:00:00+00:00 EmrJobFlowSensor 2023-12-16T22:01:00.687584+00:00 2023-12-16T22:24:04.511285+00:00 0:23:03.823701 458172 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T22:00:58.491033+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T22:00:38.257071+00:00 2023-12-16T22:00:39.186306+00:00 0:00:00.929235 458170 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T22:00:36.460572+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T21:00:00+00:00 PythonOperator 2023-12-16T22:00:18.857859+00:00 2023-12-16T22:00:20.352061+00:00 0:00:01.494202 458168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T22:00:16.467216+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T20:00:00+00:00 EmrJobFlowSensor 2023-12-16T21:00:57.900725+00:00 2023-12-16T21:26:01.767140+00:00 0:25:03.866415 458154 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T21:00:56.075991+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T21:00:37.852072+00:00 2023-12-16T21:00:38.841538+00:00 0:00:00.989466 458152 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T21:00:36.065874+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T20:00:00+00:00 PythonOperator 2023-12-16T21:00:16.076542+00:00 2023-12-16T21:00:17.648563+00:00 0:00:01.572021 458150 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T21:00:14.052594+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T19:00:00+00:00 EmrJobFlowSensor 2023-12-16T20:00:53.486133+00:00 2023-12-16T20:27:57.519166+00:00 0:27:04.033033 458136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T20:00:51.281475+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T20:00:33.070859+00:00 2023-12-16T20:00:34.311597+00:00 0:00:01.240738 458134 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T20:00:31.281753+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T19:00:00+00:00 PythonOperator 2023-12-16T20:00:11.027568+00:00 2023-12-16T20:00:12.619014+00:00 0:00:01.591446 458132 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T20:00:09.235149+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T18:00:00+00:00 EmrJobFlowSensor 2023-12-16T19:01:38.761376+00:00 2023-12-16T19:27:42.827623+00:00 0:26:04.066247 458120 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T19:01:36.244050+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T19:00:40.790673+00:00 2023-12-16T19:00:41.787049+00:00 0:00:00.996376 458117 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T19:00:39.097449+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T18:00:00+00:00 PythonOperator 2023-12-16T19:00:19.164142+00:00 2023-12-16T19:00:20.710139+00:00 0:00:01.545997 458115 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T19:00:17.081284+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T17:00:00+00:00 EmrJobFlowSensor 2023-12-16T18:00:56.768432+00:00 2023-12-16T18:26:00.449148+00:00 0:25:03.680716 458101 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T18:00:54.666292+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T18:00:36.684153+00:00 2023-12-16T18:00:37.704585+00:00 0:00:01.020432 458099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T18:00:34.598507+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T17:00:00+00:00 PythonOperator 2023-12-16T18:00:14.356973+00:00 2023-12-16T18:00:15.954926+00:00 0:00:01.597953 458097 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T18:00:12.551324+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T16:00:00+00:00 EmrJobFlowSensor 2023-12-16T17:00:48.255712+00:00 2023-12-16T17:23:53.826461+00:00 0:23:05.570749 458084 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T17:00:46.477690+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T17:00:26.182472+00:00 2023-12-16T17:00:27.590008+00:00 0:00:01.407536 458082 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T17:00:24.463329+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T16:00:00+00:00 PythonOperator 2023-12-16T17:00:06.947248+00:00 2023-12-16T17:00:09.614077+00:00 0:00:02.666829 458080 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T17:00:04.466177+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T15:00:00+00:00 EmrJobFlowSensor 2023-12-16T16:02:56.630280+00:00 2023-12-16T16:28:00.492972+00:00 0:25:03.862692 458069 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T16:02:54.497940+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T16:02:36.561218+00:00 2023-12-16T16:02:37.465564+00:00 0:00:00.904346 458067 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T16:02:34.477328+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T15:00:00+00:00 PythonOperator 2023-12-16T16:02:14.883030+00:00 2023-12-16T16:02:16.481630+00:00 0:00:01.598600 458065 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T16:02:12.458358+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T14:00:00+00:00 EmrJobFlowSensor 2023-12-16T15:01:06.573191+00:00 2023-12-16T15:25:10.165465+00:00 0:24:03.592274 458056 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T15:01:04.911479+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T15:00:44.839634+00:00 2023-12-16T15:00:45.872666+00:00 0:00:01.033032 458054 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T15:00:42.954551+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T14:00:00+00:00 PythonOperator 2023-12-16T15:00:23.085088+00:00 2023-12-16T15:00:24.647097+00:00 0:00:01.562009 458052 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T15:00:20.809394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T13:00:00+00:00 EmrJobFlowSensor 2023-12-16T14:00:48.827580+00:00 2023-12-16T14:25:52.674590+00:00 0:25:03.847010 458038 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T14:00:47.163947+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T14:00:27.234227+00:00 2023-12-16T14:00:28.422143+00:00 0:00:01.187916 458036 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T14:00:25.145585+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T13:00:00+00:00 PythonOperator 2023-12-16T14:00:05.692396+00:00 2023-12-16T14:00:07.264693+00:00 0:00:01.572297 458034 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T14:00:03.178947+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T12:00:00+00:00 EmrJobFlowSensor 2023-12-16T13:11:06.270792+00:00 2023-12-16T13:35:10.054072+00:00 0:24:03.783280 458027 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T13:11:04.197880+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T13:10:46.259669+00:00 2023-12-16T13:10:47.395040+00:00 0:00:01.135371 458024 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T13:10:44.178491+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T12:00:00+00:00 PythonOperator 2023-12-16T13:10:24.064587+00:00 2023-12-16T13:10:25.589239+00:00 0:00:01.524652 458021 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T13:10:22.160413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T11:00:00+00:00 EmrJobFlowSensor 2023-12-16T12:01:06.872421+00:00 2023-12-16T12:26:10.940888+00:00 0:25:04.068467 458007 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T12:01:04.754665+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T12:00:44.758237+00:00 2023-12-16T12:00:45.681644+00:00 0:00:00.923407 458005 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T12:00:42.680927+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T11:00:00+00:00 PythonOperator 2023-12-16T12:00:24.753558+00:00 2023-12-16T12:00:27.215149+00:00 0:00:02.461591 458003 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T12:00:22.653234+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T10:00:00+00:00 EmrJobFlowSensor 2023-12-16T11:00:47.438477+00:00 2023-12-16T11:25:51.136361+00:00 0:25:03.697884 457988 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T11:00:45.751988+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T11:00:27.601892+00:00 2023-12-16T11:00:28.685514+00:00 0:00:01.083622 457986 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T11:00:25.749714+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T10:00:00+00:00 PythonOperator 2023-12-16T11:00:06.058280+00:00 2023-12-16T11:00:08.618683+00:00 0:00:02.560403 457984 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T11:00:03.682377+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T09:00:00+00:00 EmrJobFlowSensor 2023-12-16T10:02:31.952554+00:00 2023-12-16T10:27:35.875116+00:00 0:25:03.922562 457972 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T10:02:30.290221+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T10:02:12.367910+00:00 2023-12-16T10:02:13.379925+00:00 0:00:01.012015 457970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T10:02:10.271248+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T09:00:00+00:00 PythonOperator 2023-12-16T10:01:50.010455+00:00 2023-12-16T10:01:51.692933+00:00 0:00:01.682478 457968 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T10:01:48.255790+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T08:00:00+00:00 EmrJobFlowSensor 2023-12-16T09:00:53.350047+00:00 2023-12-16T09:25:57.130837+00:00 0:25:03.780790 457954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T09:00:51.653937+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T09:00:31.746145+00:00 2023-12-16T09:00:32.697789+00:00 0:00:00.951644 457952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T09:00:29.629618+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T08:00:00+00:00 PythonOperator 2023-12-16T09:00:12.041255+00:00 2023-12-16T09:00:13.552092+00:00 0:00:01.510837 457950 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T09:00:09.619398+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T07:00:00+00:00 EmrJobFlowSensor 2023-12-16T08:00:45.384667+00:00 2023-12-16T08:25:49.191302+00:00 0:25:03.806635 457935 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T08:00:43.574383+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T08:00:25.352311+00:00 2023-12-16T08:00:26.315364+00:00 0:00:00.963053 457933 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T08:00:23.574629+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T07:00:00+00:00 PythonOperator 2023-12-16T08:00:03.761610+00:00 2023-12-16T08:00:05.349043+00:00 0:00:01.587433 457931 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T08:00:01.510019+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T06:00:00+00:00 EmrJobFlowSensor 2023-12-16T07:01:03.960277+00:00 2023-12-16T07:26:07.993759+00:00 0:25:04.033482 457918 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T07:01:02.099785+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T07:00:41.854529+00:00 2023-12-16T07:00:42.955827+00:00 0:00:01.101298 457916 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T07:00:40.083471+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T06:00:00+00:00 PythonOperator 2023-12-16T07:00:22.342034+00:00 2023-12-16T07:00:23.922302+00:00 0:00:01.580268 457914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T07:00:20.070381+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T05:00:00+00:00 EmrJobFlowSensor 2023-12-16T06:01:43.868418+00:00 2023-12-16T06:26:47.661330+00:00 0:25:03.792912 457901 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T06:01:42.210918+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T06:01:23.860684+00:00 2023-12-16T06:01:24.896051+00:00 0:00:01.035367 457899 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T06:01:22.191555+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T05:00:00+00:00 PythonOperator 2023-12-16T06:01:02.721580+00:00 2023-12-16T06:01:04.370853+00:00 0:00:01.649273 457897 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T06:01:00.175922+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T04:00:00+00:00 EmrJobFlowSensor 2023-12-16T05:00:47.955849+00:00 2023-12-16T05:25:51.703698+00:00 0:25:03.747849 457887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T05:00:46.279005+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T05:00:26.259208+00:00 2023-12-16T05:00:27.162870+00:00 0:00:00.903662 457885 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T05:00:24.261611+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T04:00:00+00:00 PythonOperator 2023-12-16T05:00:04.371190+00:00 2023-12-16T05:00:06.010050+00:00 0:00:01.638860 457883 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T05:00:02.282676+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T03:00:00+00:00 EmrJobFlowSensor 2023-12-16T04:00:57.300438+00:00 2023-12-16T04:26:01.212353+00:00 0:25:03.911915 457870 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T04:00:55.627311+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T04:00:37.698150+00:00 2023-12-16T04:00:38.662389+00:00 0:00:00.964239 457867 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T04:00:35.612971+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T03:00:00+00:00 PythonOperator 2023-12-16T04:00:16.004632+00:00 2023-12-16T04:00:17.530500+00:00 0:00:01.525868 457864 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T04:00:13.652344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T02:00:00+00:00 EmrJobFlowSensor 2023-12-16T03:00:56.700539+00:00 2023-12-16T03:26:00.480219+00:00 0:25:03.779680 457849 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T03:00:54.768895+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T03:00:36.850130+00:00 2023-12-16T03:00:38.033456+00:00 0:00:01.183326 457847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T03:00:34.756937+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T02:00:00+00:00 PythonOperator 2023-12-16T03:00:14.961277+00:00 2023-12-16T03:00:16.537150+00:00 0:00:01.575873 457845 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T03:00:12.684464+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T01:00:00+00:00 EmrJobFlowSensor 2023-12-16T02:00:53.207208+00:00 2023-12-16T02:24:56.858884+00:00 0:24:03.651676 457831 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T02:00:51.367992+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T02:00:33.054633+00:00 2023-12-16T02:00:34.040647+00:00 0:00:00.986014 457829 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T02:00:31.288483+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T01:00:00+00:00 PythonOperator 2023-12-16T02:00:11.609207+00:00 2023-12-16T02:00:13.256815+00:00 0:00:01.647608 457827 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T02:00:09.280660+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-16T00:00:00+00:00 EmrJobFlowSensor 2023-12-16T01:00:50.816715+00:00 2023-12-16T01:25:54.686493+00:00 0:25:03.869778 457807 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T01:00:48.265763+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-16T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T01:00:29.036293+00:00 2023-12-16T01:00:29.983365+00:00 0:00:00.947072 457805 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T01:00:26.284065+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-16T00:00:00+00:00 PythonOperator 2023-12-16T01:00:08.105657+00:00 2023-12-16T01:00:09.730795+00:00 0:00:01.625138 457803 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T01:00:06.225003+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T23:00:00+00:00 EmrJobFlowSensor 2023-12-16T00:00:58.862826+00:00 2023-12-16T00:26:02.940057+00:00 0:25:04.077231 457791 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-16T00:00:56.528759+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-16T00:00:36.351713+00:00 2023-12-16T00:00:37.309105+00:00 0:00:00.957392 457788 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-16T00:00:34.508657+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T23:00:00+00:00 PythonOperator 2023-12-16T00:00:14.670064+00:00 2023-12-16T00:00:16.360223+00:00 0:00:01.690159 457786 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-16T00:00:12.490262+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T22:00:00+00:00 EmrJobFlowSensor 2023-12-15T23:00:58.570250+00:00 2023-12-15T23:27:02.939117+00:00 0:26:04.368867 457772 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T23:00:56.551753+00:00 2 default_pool