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 create_emr_steps 2023-11-17T18:00:00+00:00 PythonOperator 2023-11-17T19:00:07.920754+00:00 2023-11-17T19:00:10.096477+00:00 0:00:02.175723 447481 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T19:00:05.684415+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T17:00:00+00:00 EmrJobFlowSensor 2023-11-17T18:00:58.642811+00:00 2023-11-17T18:26:02.731017+00:00 0:25:04.088206 447469 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T18:00:56.554093+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T18:00:38.451160+00:00 2023-11-17T18:00:39.394118+00:00 0:00:00.942958 447468 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T18:00:36.457432+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T17:00:00+00:00 PythonOperator 2023-11-17T18:00:16.623623+00:00 2023-11-17T18:00:18.865241+00:00 0:00:02.241618 447467 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T18:00:14.465824+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T16:00:00+00:00 EmrJobFlowSensor 2023-11-17T17:00:50.907389+00:00 2023-11-17T17:24:54.977703+00:00 0:24:04.070314 447458 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T17:00:48.902021+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T17:00:29.147187+00:00 2023-11-17T17:00:30.224814+00:00 0:00:01.077627 447457 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T17:00:26.887392+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T16:00:00+00:00 PythonOperator 2023-11-17T17:00:08.852707+00:00 2023-11-17T17:00:11.024235+00:00 0:00:02.171528 447456 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T17:00:06.819834+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T15:00:00+00:00 EmrJobFlowSensor 2023-11-17T16:00:54.531804+00:00 2023-11-17T16:25:58.669612+00:00 0:25:04.137808 447444 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T16:00:52.592501+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T16:00:32.662629+00:00 2023-11-17T16:00:33.606332+00:00 0:00:00.943703 447443 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T16:00:30.583701+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T15:00:00+00:00 PythonOperator 2023-11-17T16:00:12.845405+00:00 2023-11-17T16:00:15.039631+00:00 0:00:02.194226 447442 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T16:00:10.587036+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T14:00:00+00:00 EmrJobFlowSensor 2023-11-17T15:01:01.779949+00:00 2023-11-17T15:26:06.037558+00:00 0:25:04.257609 447430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T15:00:59.844754+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T15:00:41.788032+00:00 2023-11-17T15:00:42.770704+00:00 0:00:00.982672 447429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T15:00:39.827096+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T14:00:00+00:00 PythonOperator 2023-11-17T15:00:20.156699+00:00 2023-11-17T15:00:22.586408+00:00 0:00:02.429709 447428 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T15:00:17.856724+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T13:00:00+00:00 EmrJobFlowSensor 2023-11-17T14:00:46.859974+00:00 2023-11-17T14:25:50.872220+00:00 0:25:04.012246 447416 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T14:00:44.863826+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T14:00:26.759003+00:00 2023-11-17T14:00:27.897014+00:00 0:00:01.138011 447415 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T14:00:24.788121+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T13:00:00+00:00 PythonOperator 2023-11-17T14:00:04.856436+00:00 2023-11-17T14:00:07.103535+00:00 0:00:02.247099 447414 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T14:00:02.769730+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T12:00:00+00:00 EmrJobFlowSensor 2023-11-17T13:01:00.082162+00:00 2023-11-17T13:26:04.164794+00:00 0:25:04.082632 447404 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T13:00:58.134695+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T13:00:38.189892+00:00 2023-11-17T13:00:39.089282+00:00 0:00:00.899390 447403 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T13:00:36.163198+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T12:00:00+00:00 PythonOperator 2023-11-17T13:00:18.349633+00:00 2023-11-17T13:00:20.501031+00:00 0:00:02.151398 447402 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T13:00:16.159712+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T11:00:00+00:00 EmrJobFlowSensor 2023-11-17T12:01:05.394507+00:00 2023-11-17T12:26:09.387611+00:00 0:25:03.993104 447391 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T12:01:03.258340+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T12:00:43.187258+00:00 2023-11-17T12:00:44.262937+00:00 0:00:01.075679 447390 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T12:00:41.199330+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T11:00:00+00:00 PythonOperator 2023-11-17T12:00:23.338200+00:00 2023-11-17T12:00:25.558147+00:00 0:00:02.219947 447389 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T12:00:21.180844+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T10:00:00+00:00 EmrJobFlowSensor 2023-11-17T11:01:05.640330+00:00 2023-11-17T11:25:09.256554+00:00 0:24:03.616224 447377 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T11:01:03.557811+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T11:00:45.569002+00:00 2023-11-17T11:00:46.611000+00:00 0:00:01.041998 447376 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T11:00:43.490246+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T10:00:00+00:00 PythonOperator 2023-11-17T11:00:23.601699+00:00 2023-11-17T11:00:25.781984+00:00 0:00:02.180285 447375 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T11:00:21.469668+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T09:00:00+00:00 EmrJobFlowSensor 2023-11-17T10:00:58.174484+00:00 2023-11-17T10:25:01.726104+00:00 0:24:03.551620 447363 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T10:00:56.246459+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T10:00:36.197834+00:00 2023-11-17T10:00:37.254886+00:00 0:00:01.057052 447362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T10:00:34.226744+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T09:00:00+00:00 PythonOperator 2023-11-17T10:00:14.590047+00:00 2023-11-17T10:00:17.022381+00:00 0:00:02.432334 447361 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T10:00:12.262394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T08:00:00+00:00 EmrJobFlowSensor 2023-11-17T09:06:46.766319+00:00 2023-11-17T09:28:49.904640+00:00 0:22:03.138321 447353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T09:06:44.770906+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T09:06:26.667814+00:00 2023-11-17T09:06:27.690024+00:00 0:00:01.022210 447351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T09:06:24.750771+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T08:00:00+00:00 PythonOperator 2023-11-17T09:06:05.060040+00:00 2023-11-17T09:06:07.417917+00:00 0:00:02.357877 447349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T09:06:02.734242+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T07:00:00+00:00 EmrJobFlowSensor 2023-11-17T08:01:44.572971+00:00 2023-11-17T08:24:48.087687+00:00 0:23:03.514716 447337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T08:01:42.642888+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T08:01:22.555385+00:00 2023-11-17T08:01:23.673559+00:00 0:00:01.118174 447336 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T08:01:20.615260+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T07:00:00+00:00 PythonOperator 2023-11-17T08:01:02.732904+00:00 2023-11-17T08:01:04.909635+00:00 0:00:02.176731 447335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T08:01:00.598935+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T06:00:00+00:00 EmrJobFlowSensor 2023-11-17T07:00:55.468198+00:00 2023-11-17T07:23:58.867829+00:00 0:23:03.399631 447323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T07:00:53.559400+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T07:00:35.700183+00:00 2023-11-17T07:00:36.939998+00:00 0:00:01.239815 447322 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T07:00:33.540936+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T06:00:00+00:00 PythonOperator 2023-11-17T07:00:13.681694+00:00 2023-11-17T07:00:15.861437+00:00 0:00:02.179743 447321 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T07:00:11.521611+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T05:00:00+00:00 EmrJobFlowSensor 2023-11-17T06:00:48.703578+00:00 2023-11-17T06:24:52.371102+00:00 0:24:03.667524 447310 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T06:00:46.770972+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T06:00:28.684195+00:00 2023-11-17T06:00:29.927952+00:00 0:00:01.243757 447309 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T06:00:26.755242+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T05:00:00+00:00 PythonOperator 2023-11-17T06:00:06.875681+00:00 2023-11-17T06:00:09.025001+00:00 0:00:02.149320 447308 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T06:00:04.734606+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T04:00:00+00:00 EmrJobFlowSensor 2023-11-17T05:00:57.444045+00:00 2023-11-17T05:24:00.920359+00:00 0:23:03.476314 447297 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T05:00:55.464059+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T05:00:35.463771+00:00 2023-11-17T05:00:36.505456+00:00 0:00:01.041685 447296 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T05:00:33.386717+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T04:00:00+00:00 PythonOperator 2023-11-17T05:00:15.566899+00:00 2023-11-17T05:00:17.743978+00:00 0:00:02.177079 447295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T05:00:13.386374+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T03:00:00+00:00 EmrJobFlowSensor 2023-11-17T04:01:01.264246+00:00 2023-11-17T04:23:05.008146+00:00 0:22:03.743900 447282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T04:00:59.333886+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T04:00:39.271763+00:00 2023-11-17T04:00:40.263023+00:00 0:00:00.991260 447280 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T04:00:37.314338+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T03:00:00+00:00 PythonOperator 2023-11-17T04:00:17.469534+00:00 2023-11-17T04:00:19.804517+00:00 0:00:02.334983 447278 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T04:00:15.292741+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T02:00:00+00:00 EmrJobFlowSensor 2023-11-17T03:00:57.071440+00:00 2023-11-17T03:24:00.600865+00:00 0:23:03.529425 447266 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T03:00:55.120045+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T03:00:37.063271+00:00 2023-11-17T03:00:38.198796+00:00 0:00:01.135525 447265 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T03:00:35.102827+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T02:00:00+00:00 PythonOperator 2023-11-17T03:00:15.229354+00:00 2023-11-17T03:00:17.403285+00:00 0:00:02.173931 447264 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T03:00:13.030288+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T01:00:00+00:00 EmrJobFlowSensor 2023-11-17T02:00:53.347599+00:00 2023-11-17T02:22:56.572277+00:00 0:22:03.224678 447252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T02:00:51.438361+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T02:00:33.460840+00:00 2023-11-17T02:00:34.417434+00:00 0:00:00.956594 447251 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T02:00:31.422732+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T01:00:00+00:00 PythonOperator 2023-11-17T02:00:11.764054+00:00 2023-11-17T02:00:13.887466+00:00 0:00:02.123412 447250 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T02:00:09.458624+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T00:00:00+00:00 EmrJobFlowSensor 2023-11-17T01:00:57.380575+00:00 2023-11-17T01:24:00.926214+00:00 0:23:03.545639 447232 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T01:00:55.366904+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T01:00:37.310853+00:00 2023-11-17T01:00:38.293470+00:00 0:00:00.982617 447231 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T01:00:35.242240+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T00:00:00+00:00 PythonOperator 2023-11-17T01:00:15.600475+00:00 2023-11-17T01:00:17.848453+00:00 0:00:02.247978 447230 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T01:00:13.272732+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T23:00:00+00:00 EmrJobFlowSensor 2023-11-17T00:01:00.220095+00:00 2023-11-17T00:27:04.263002+00:00 0:26:04.042907 447218 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T00:00:58.267072+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T00:00:38.347786+00:00 2023-11-17T00:00:39.412797+00:00 0:00:01.065011 447217 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T00:00:36.278222+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T23:00:00+00:00 PythonOperator 2023-11-17T00:00:16.470582+00:00 2023-11-17T00:00:18.648791+00:00 0:00:02.178209 447216 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T00:00:14.275618+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T22:00:00+00:00 EmrJobFlowSensor 2023-11-16T23:13:59.238005+00:00 2023-11-16T23:27:01.603539+00:00 0:13:02.365534 447209 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T23:13:57.305117+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T23:00:43.259116+00:00 2023-11-16T23:00:44.362104+00:00 0:00:01.102988 447199 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T23:00:41.328478+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T22:00:00+00:00 PythonOperator 2023-11-16T23:00:21.758208+00:00 2023-11-16T23:00:24.971449+00:00 0:00:03.213241 447197 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T23:00:19.360484+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T21:00:00+00:00 EmrJobFlowSensor 2023-11-16T22:01:05.557301+00:00 2023-11-16T22:24:08.877082+00:00 0:23:03.319781 447185 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T22:01:03.597020+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T22:00:45.612951+00:00 2023-11-16T22:00:46.709134+00:00 0:00:01.096183 447184 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T22:00:43.578842+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T21:00:00+00:00 PythonOperator 2023-11-16T22:00:23.974522+00:00 2023-11-16T22:00:26.252142+00:00 0:00:02.277620 447183 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T22:00:21.594161+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T20:00:00+00:00 EmrJobFlowSensor 2023-11-16T21:00:56.501986+00:00 2023-11-16T21:26:00.256931+00:00 0:25:03.754945 447171 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T21:00:54.563646+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T21:00:36.457511+00:00 2023-11-16T21:00:37.397274+00:00 0:00:00.939763 447170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T21:00:34.546603+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T20:00:00+00:00 PythonOperator 2023-11-16T21:00:14.899738+00:00 2023-11-16T21:00:17.596547+00:00 0:00:02.696809 447169 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T21:00:12.582676+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T19:00:00+00:00 EmrJobFlowSensor 2023-11-16T20:00:48.638944+00:00 2023-11-16T20:26:52.748194+00:00 0:26:04.109250 447157 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T20:00:46.701246+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T20:00:26.748873+00:00 2023-11-16T20:00:27.796569+00:00 0:00:01.047696 447156 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T20:00:24.690135+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T19:00:00+00:00 PythonOperator 2023-11-16T20:00:04.889162+00:00 2023-11-16T20:00:07.094891+00:00 0:00:02.205729 447155 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T20:00:02.675373+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T18:00:00+00:00 EmrJobFlowSensor 2023-11-16T19:01:02.567285+00:00 2023-11-16T19:27:06.624638+00:00 0:26:04.057353 447143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T19:01:00.660937+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T19:00:40.748692+00:00 2023-11-16T19:00:41.730429+00:00 0:00:00.981737 447142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T19:00:38.685436+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T18:00:00+00:00 PythonOperator 2023-11-16T19:00:20.956313+00:00 2023-11-16T19:00:23.138038+00:00 0:00:02.181725 447141 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T19:00:18.679221+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T17:00:00+00:00 EmrJobFlowSensor 2023-11-16T18:00:56.063471+00:00 2023-11-16T18:25:59.608800+00:00 0:25:03.545329 447129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T18:00:54.068295+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T18:00:35.973709+00:00 2023-11-16T18:00:37.059435+00:00 0:00:01.085726 447128 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T18:00:33.992959+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T17:00:00+00:00 PythonOperator 2023-11-16T18:00:14.242119+00:00 2023-11-16T18:00:16.420405+00:00 0:00:02.178286 447127 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T18:00:11.990394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T16:00:00+00:00 EmrJobFlowSensor 2023-11-16T17:01:04.653037+00:00 2023-11-16T17:25:08.295843+00:00 0:24:03.642806 447115 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T17:01:02.681935+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T17:00:44.619787+00:00 2023-11-16T17:00:45.618998+00:00 0:00:00.999211 447114 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T17:00:42.659840+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T16:00:00+00:00 PythonOperator 2023-11-16T17:00:23.078181+00:00 2023-11-16T17:00:25.290863+00:00 0:00:02.212682 447113 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T17:00:20.685582+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T15:00:00+00:00 EmrJobFlowSensor 2023-11-16T16:00:48.739464+00:00 2023-11-16T16:25:52.343403+00:00 0:25:03.603939 447101 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T16:00:46.807413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T16:00:26.857355+00:00 2023-11-16T16:00:27.889444+00:00 0:00:01.032089 447100 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T16:00:24.785348+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T15:00:00+00:00 PythonOperator 2023-11-16T16:00:05.058588+00:00 2023-11-16T16:00:07.323747+00:00 0:00:02.265159 447099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T16:00:02.782973+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T14:00:00+00:00 EmrJobFlowSensor 2023-11-16T15:00:58.876237+00:00 2023-11-16T15:26:02.586088+00:00 0:25:03.709851 447087 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T15:00:56.883989+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T15:00:36.958386+00:00 2023-11-16T15:00:37.971259+00:00 0:00:01.012873 447086 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T15:00:34.886032+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T14:00:00+00:00 PythonOperator 2023-11-16T15:00:15.227462+00:00 2023-11-16T15:00:17.441298+00:00 0:00:02.213836 447085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T15:00:12.796775+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T13:00:00+00:00 EmrJobFlowSensor 2023-11-16T14:00:57.664251+00:00 2023-11-16T14:27:01.822325+00:00 0:26:04.158074 447075 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T14:00:55.700469+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T14:00:35.715369+00:00 2023-11-16T14:00:36.792291+00:00 0:00:01.076922 447074 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T14:00:33.681322+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T13:00:00+00:00 PythonOperator 2023-11-16T14:00:15.933776+00:00 2023-11-16T14:00:18.135806+00:00 0:00:02.202030 447073 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T14:00:13.664467+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T12:00:00+00:00 EmrJobFlowSensor 2023-11-16T13:01:06.353176+00:00 2023-11-16T13:26:10.215732+00:00 0:25:03.862556 447062 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T13:01:04.400967+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T13:00:46.345690+00:00 2023-11-16T13:00:47.392851+00:00 0:00:01.047161 447061 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T13:00:44.381952+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T12:00:00+00:00 PythonOperator 2023-11-16T13:00:24.746471+00:00 2023-11-16T13:00:26.996395+00:00 0:00:02.249924 447060 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T13:00:22.457559+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T11:00:00+00:00 EmrJobFlowSensor 2023-11-16T12:00:47.996761+00:00 2023-11-16T12:25:51.671539+00:00 0:25:03.674778 447048 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T12:00:46.006127+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T12:00:25.943116+00:00 2023-11-16T12:00:27.031141+00:00 0:00:01.088025 447047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T12:00:23.987399+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T11:00:00+00:00 PythonOperator 2023-11-16T12:00:06.014926+00:00 2023-11-16T12:00:08.265206+00:00 0:00:02.250280 447046 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T12:00:03.944695+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T10:00:00+00:00 EmrJobFlowSensor 2023-11-16T11:01:00.469904+00:00 2023-11-16T11:25:04.313778+00:00 0:24:03.843874 447034 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T11:00:58.387488+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T11:00:40.356584+00:00 2023-11-16T11:00:41.378745+00:00 0:00:01.022161 447033 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T11:00:38.376543+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T10:00:00+00:00 PythonOperator 2023-11-16T11:00:18.357389+00:00 2023-11-16T11:00:20.525954+00:00 0:00:02.168565 447032 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T11:00:16.296116+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T09:00:00+00:00 EmrJobFlowSensor 2023-11-16T10:01:00.624059+00:00 2023-11-16T10:26:04.644879+00:00 0:25:04.020820 447020 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T10:00:58.594816+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T10:00:38.641748+00:00 2023-11-16T10:00:39.570274+00:00 0:00:00.928526 447019 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T10:00:36.584862+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T09:00:00+00:00 PythonOperator 2023-11-16T10:00:18.557658+00:00 2023-11-16T10:00:20.814743+00:00 0:00:02.257085 447018 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T10:00:16.513500+00:00 2 default_pool