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-11-16T08:00:00+00:00 EmrJobFlowSensor 2023-11-16T09:00:58.076789+00:00 2023-11-16T09:26:01.822921+00:00 0:25:03.746132 447006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T09:00:56.065452+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T09:00:36.015201+00:00 2023-11-16T09:00:37.095055+00:00 0:00:01.079854 447005 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T09:00:34.042918+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T08:00:00+00:00 PythonOperator 2023-11-16T09:00:14.081225+00:00 2023-11-16T09:00:16.358963+00:00 0:00:02.277738 447004 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T09:00:12.021862+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T07:00:00+00:00 EmrJobFlowSensor 2023-11-16T08:01:04.224016+00:00 2023-11-16T08:27:08.082035+00:00 0:26:03.858019 446993 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T08:01:02.236967+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T08:00:44.161434+00:00 2023-11-16T08:00:45.263674+00:00 0:00:01.102240 446992 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T08:00:42.217888+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T07:00:00+00:00 PythonOperator 2023-11-16T08:00:22.565201+00:00 2023-11-16T08:00:24.810486+00:00 0:00:02.245285 446991 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T08:00:20.199562+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T06:00:00+00:00 EmrJobFlowSensor 2023-11-16T07:00:58.347298+00:00 2023-11-16T07:28:02.311560+00:00 0:27:03.964262 446979 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T07:00:56.447877+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T07:00:38.456282+00:00 2023-11-16T07:00:39.448745+00:00 0:00:00.992463 446978 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T07:00:36.430244+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T06:00:00+00:00 PythonOperator 2023-11-16T07:00:16.685733+00:00 2023-11-16T07:00:18.927918+00:00 0:00:02.242185 446977 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T07:00:14.462459+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T05:00:00+00:00 EmrJobFlowSensor 2023-11-16T06:00:56.851447+00:00 2023-11-16T06:27:00.964877+00:00 0:26:04.113430 446965 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T06:00:54.916305+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T06:00:36.851446+00:00 2023-11-16T06:00:37.814746+00:00 0:00:00.963300 446964 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T06:00:34.897496+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T05:00:00+00:00 PythonOperator 2023-11-16T06:00:15.256740+00:00 2023-11-16T06:00:17.423822+00:00 0:00:02.167082 446963 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T06:00:12.887000+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T04:00:00+00:00 EmrJobFlowSensor 2023-11-16T05:00:53.035417+00:00 2023-11-16T05:25:57.009831+00:00 0:25:03.974414 446951 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T05:00:51.058199+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T05:00:33.001817+00:00 2023-11-16T05:00:34.007134+00:00 0:00:01.005317 446950 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T05:00:31.060747+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T04:00:00+00:00 PythonOperator 2023-11-16T05:00:11.115654+00:00 2023-11-16T05:00:13.310124+00:00 0:00:02.194470 446949 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T05:00:08.948444+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T03:00:00+00:00 EmrJobFlowSensor 2023-11-16T04:02:03.702620+00:00 2023-11-16T04:27:07.623128+00:00 0:25:03.920508 446937 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T04:02:01.732096+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T04:01:41.872513+00:00 2023-11-16T04:01:42.921699+00:00 0:00:01.049186 446935 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T04:01:39.711577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T03:00:00+00:00 PythonOperator 2023-11-16T04:01:21.635358+00:00 2023-11-16T04:01:23.822162+00:00 0:00:02.186804 446933 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T04:01:19.695391+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T02:00:00+00:00 EmrJobFlowSensor 2023-11-16T03:01:14.676034+00:00 2023-11-16T03:26:18.548323+00:00 0:25:03.872289 446920 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T03:01:12.700736+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T03:00:52.676874+00:00 2023-11-16T03:00:53.753956+00:00 0:00:01.077082 446919 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T03:00:50.680649+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T02:00:00+00:00 PythonOperator 2023-11-16T03:00:32.756642+00:00 2023-11-16T03:00:34.930570+00:00 0:00:02.173928 446918 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T03:00:30.661833+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T01:00:00+00:00 EmrJobFlowSensor 2023-11-16T02:02:11.858254+00:00 2023-11-16T02:26:15.493585+00:00 0:24:03.635331 446906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T02:02:09.923405+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T02:01:50.283884+00:00 2023-11-16T02:01:51.487542+00:00 0:00:01.203658 446905 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T02:01:47.947959+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T01:00:00+00:00 PythonOperator 2023-11-16T02:00:04.653637+00:00 2023-11-16T02:00:07.072560+00:00 0:00:02.418923 446903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T02:00:02.605106+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-16T00:00:00+00:00 EmrJobFlowSensor 2023-11-16T01:01:16.556462+00:00 2023-11-16T01:25:20.096440+00:00 0:24:03.539978 446886 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T01:01:14.586722+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-16T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T01:00:54.564671+00:00 2023-11-16T01:00:55.990162+00:00 0:00:01.425491 446885 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T01:00:52.560995+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-16T00:00:00+00:00 PythonOperator 2023-11-16T01:00:34.678657+00:00 2023-11-16T01:00:36.899162+00:00 0:00:02.220505 446884 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T01:00:32.551654+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T23:00:00+00:00 EmrJobFlowSensor 2023-11-16T00:01:32.639147+00:00 2023-11-16T00:27:36.290252+00:00 0:26:03.651105 446872 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-16T00:01:30.728463+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-16T00:01:12.702907+00:00 2023-11-16T00:01:13.828155+00:00 0:00:01.125248 446871 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-16T00:01:10.710555+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T23:00:00+00:00 PythonOperator 2023-11-16T00:00:50.972623+00:00 2023-11-16T00:00:53.266295+00:00 0:00:02.293672 446870 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-16T00:00:48.696701+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T22:00:00+00:00 EmrJobFlowSensor 2023-11-15T23:01:25.542862+00:00 2023-11-15T23:26:29.266470+00:00 0:25:03.723608 446858 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T23:01:23.576193+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T23:01:05.891595+00:00 2023-11-15T23:01:07.040314+00:00 0:00:01.148719 446856 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T23:01:03.558009+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T22:00:00+00:00 PythonOperator 2023-11-15T23:00:43.461040+00:00 2023-11-15T23:00:45.776933+00:00 0:00:02.315893 446854 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T23:00:41.539080+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T21:00:00+00:00 EmrJobFlowSensor 2023-11-15T22:01:18.350852+00:00 2023-11-15T22:24:21.836771+00:00 0:23:03.485919 446841 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T22:01:16.385350+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T22:00:56.352579+00:00 2023-11-15T22:00:58.047375+00:00 0:00:01.694796 446840 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T22:00:54.365743+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T21:00:00+00:00 PythonOperator 2023-11-15T22:00:36.361813+00:00 2023-11-15T22:00:38.548646+00:00 0:00:02.186833 446839 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T22:00:34.347974+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T20:00:00+00:00 EmrJobFlowSensor 2023-11-15T21:01:06.629340+00:00 2023-11-15T21:26:10.377772+00:00 0:25:03.748432 446827 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T21:01:04.687511+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T21:00:46.585256+00:00 2023-11-15T21:00:47.630247+00:00 0:00:01.044991 446826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T21:00:44.669432+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T20:00:00+00:00 PythonOperator 2023-11-15T21:00:25.254643+00:00 2023-11-15T21:00:27.572122+00:00 0:00:02.317479 446825 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T21:00:22.652519+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T19:00:00+00:00 EmrJobFlowSensor 2023-11-15T20:01:19.952864+00:00 2023-11-15T20:27:23.758998+00:00 0:26:03.806134 446813 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T20:01:17.989949+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T20:00:57.931501+00:00 2023-11-15T20:00:58.991474+00:00 0:00:01.059973 446812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T20:00:55.970019+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T19:00:00+00:00 PythonOperator 2023-11-15T20:00:37.945821+00:00 2023-11-15T20:00:40.140684+00:00 0:00:02.194863 446811 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T20:00:35.953067+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T18:00:00+00:00 EmrJobFlowSensor 2023-11-15T19:00:48.365991+00:00 2023-11-15T19:26:52.065201+00:00 0:26:03.699210 446799 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T19:00:46.369876+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T19:00:26.653987+00:00 2023-11-15T19:00:27.647659+00:00 0:00:00.993672 446798 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T19:00:24.350952+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T18:00:00+00:00 PythonOperator 2023-11-15T19:00:06.488275+00:00 2023-11-15T19:00:08.638960+00:00 0:00:02.150685 446796 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T19:00:04.389612+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T17:00:00+00:00 EmrJobFlowSensor 2023-11-15T18:01:17.050905+00:00 2023-11-15T18:27:21.136757+00:00 0:26:04.085852 446785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T18:01:15.143689+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T18:00:57.098649+00:00 2023-11-15T18:00:58.105495+00:00 0:00:01.006846 446784 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T18:00:55.124479+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T17:00:00+00:00 PythonOperator 2023-11-15T18:00:35.148228+00:00 2023-11-15T18:00:37.291186+00:00 0:00:02.142958 446783 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T18:00:33.106426+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T16:00:00+00:00 EmrJobFlowSensor 2023-11-15T17:00:46.471851+00:00 2023-11-15T17:23:50.282688+00:00 0:23:03.810837 446771 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T17:00:44.554035+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T17:00:24.551081+00:00 2023-11-15T17:00:25.525208+00:00 0:00:00.974127 446770 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T17:00:22.578765+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T16:00:00+00:00 PythonOperator 2023-11-15T17:00:04.590231+00:00 2023-11-15T17:00:06.802448+00:00 0:00:02.212217 446769 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T17:00:02.509154+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T15:00:00+00:00 EmrJobFlowSensor 2023-11-15T16:00:49.495884+00:00 2023-11-15T16:25:53.290310+00:00 0:25:03.794426 446757 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T16:00:47.501310+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T16:00:27.354085+00:00 2023-11-15T16:00:28.329111+00:00 0:00:00.975026 446756 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T16:00:25.429844+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T15:00:00+00:00 PythonOperator 2023-11-15T16:00:07.667180+00:00 2023-11-15T16:00:09.835664+00:00 0:00:02.168484 446755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T16:00:05.410426+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T14:00:00+00:00 EmrJobFlowSensor 2023-11-15T15:00:53.247311+00:00 2023-11-15T15:25:57.378472+00:00 0:25:04.131161 446743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T15:00:51.339854+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T15:00:31.308923+00:00 2023-11-15T15:00:32.367804+00:00 0:00:01.058881 446742 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T15:00:29.312271+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T14:00:00+00:00 PythonOperator 2023-11-15T15:00:11.389035+00:00 2023-11-15T15:00:13.525325+00:00 0:00:02.136290 446741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T15:00:09.293125+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T13:00:00+00:00 EmrJobFlowSensor 2023-11-15T14:01:03.056574+00:00 2023-11-15T14:26:07.281041+00:00 0:25:04.224467 446730 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T14:01:00.989703+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T14:00:42.946037+00:00 2023-11-15T14:00:43.929714+00:00 0:00:00.983677 446729 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T14:00:40.980064+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T13:00:00+00:00 PythonOperator 2023-11-15T14:00:20.978591+00:00 2023-11-15T14:00:23.120322+00:00 0:00:02.141731 446728 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T14:00:18.914119+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T12:00:00+00:00 EmrJobFlowSensor 2023-11-15T13:01:04.975248+00:00 2023-11-15T13:26:09.107251+00:00 0:25:04.132003 446717 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T13:01:02.978904+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T13:00:42.862234+00:00 2023-11-15T13:00:43.899520+00:00 0:00:01.037286 446716 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T13:00:40.900169+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T12:00:00+00:00 PythonOperator 2023-11-15T13:00:22.974346+00:00 2023-11-15T13:00:25.170963+00:00 0:00:02.196617 446715 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T13:00:20.882053+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T11:00:00+00:00 EmrJobFlowSensor 2023-11-15T12:01:33.845591+00:00 2023-11-15T12:26:37.821453+00:00 0:25:03.975862 446704 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T12:01:31.931744+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T12:01:11.848742+00:00 2023-11-15T12:01:12.934468+00:00 0:00:01.085726 446703 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T12:01:09.911786+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T11:00:00+00:00 PythonOperator 2023-11-15T12:00:52.156206+00:00 2023-11-15T12:00:54.339238+00:00 0:00:02.183032 446702 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T12:00:49.942023+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T10:00:00+00:00 EmrJobFlowSensor 2023-11-15T11:00:54.654171+00:00 2023-11-15T11:25:58.365728+00:00 0:25:03.711557 446690 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T11:00:52.711191+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T11:00:32.660373+00:00 2023-11-15T11:00:33.674495+00:00 0:00:01.014122 446689 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T11:00:30.694751+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T10:00:00+00:00 PythonOperator 2023-11-15T11:00:12.772906+00:00 2023-11-15T11:00:14.947069+00:00 0:00:02.174163 446688 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T11:00:10.675717+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T09:00:00+00:00 EmrJobFlowSensor 2023-11-15T10:01:03.548646+00:00 2023-11-15T10:26:07.413848+00:00 0:25:03.865202 446676 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T10:01:01.578688+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T10:00:41.453163+00:00 2023-11-15T10:00:42.439242+00:00 0:00:00.986079 446675 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T10:00:39.507048+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T09:00:00+00:00 PythonOperator 2023-11-15T10:00:21.564982+00:00 2023-11-15T10:00:23.765542+00:00 0:00:02.200560 446674 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T10:00:19.489900+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T08:00:00+00:00 EmrJobFlowSensor 2023-11-15T09:01:01.172833+00:00 2023-11-15T09:27:05.156627+00:00 0:26:03.983794 446662 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T09:00:59.093673+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T09:00:39.062113+00:00 2023-11-15T09:00:40.181724+00:00 0:00:01.119611 446661 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T09:00:37.085436+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T08:00:00+00:00 PythonOperator 2023-11-15T09:00:19.135636+00:00 2023-11-15T09:00:21.264791+00:00 0:00:02.129155 446660 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T09:00:17.030020+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T07:00:00+00:00 EmrJobFlowSensor 2023-11-15T08:00:49.440257+00:00 2023-11-15T08:25:53.294217+00:00 0:25:03.853960 446648 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T08:00:47.393776+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T08:00:27.449402+00:00 2023-11-15T08:00:28.428907+00:00 0:00:00.979505 446647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T08:00:25.384115+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T07:00:00+00:00 PythonOperator 2023-11-15T08:00:07.563327+00:00 2023-11-15T08:00:09.744867+00:00 0:00:02.181540 446646 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T08:00:05.389689+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T06:00:00+00:00 EmrJobFlowSensor 2023-11-15T07:00:59.042523+00:00 2023-11-15T07:27:02.885337+00:00 0:26:03.842814 446635 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T07:00:57.054440+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T07:00:36.965574+00:00 2023-11-15T07:00:38.056433+00:00 0:00:01.090859 446634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T07:00:34.982670+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T06:00:00+00:00 PythonOperator 2023-11-15T07:00:16.935829+00:00 2023-11-15T07:00:19.190400+00:00 0:00:02.254571 446633 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T07:00:14.946997+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T05:00:00+00:00 EmrJobFlowSensor 2023-11-15T06:02:59.747135+00:00 2023-11-15T06:29:03.755089+00:00 0:26:04.007954 446622 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T06:02:57.808577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T06:02:39.752164+00:00 2023-11-15T06:02:40.825551+00:00 0:00:01.073387 446621 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T06:02:37.788170+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T05:00:00+00:00 PythonOperator 2023-11-15T06:02:17.758147+00:00 2023-11-15T06:02:19.909079+00:00 0:00:02.150932 446620 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T06:02:15.767620+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T04:00:00+00:00 EmrJobFlowSensor 2023-11-15T05:01:02.648922+00:00 2023-11-15T05:26:06.432756+00:00 0:25:03.783834 446608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T05:01:00.651550+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T05:00:40.750360+00:00 2023-11-15T05:00:41.731519+00:00 0:00:00.981159 446607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T05:00:38.682434+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T04:00:00+00:00 PythonOperator 2023-11-15T05:00:20.996908+00:00 2023-11-15T05:00:23.121716+00:00 0:00:02.124808 446606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T05:00:18.670849+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T03:00:00+00:00 EmrJobFlowSensor 2023-11-15T04:00:53.739162+00:00 2023-11-15T04:26:57.489740+00:00 0:26:03.750578 446596 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T04:00:51.788170+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T04:00:33.671157+00:00 2023-11-15T04:00:34.706013+00:00 0:00:01.034856 446594 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T04:00:31.729207+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T03:00:00+00:00 PythonOperator 2023-11-15T04:00:11.976373+00:00 2023-11-15T04:00:14.125276+00:00 0:00:02.148903 446592 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T04:00:09.713338+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T02:00:00+00:00 EmrJobFlowSensor 2023-11-15T03:00:50.709962+00:00 2023-11-15T03:26:54.599892+00:00 0:26:03.889930 446579 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T03:00:48.679124+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T03:00:28.692867+00:00 2023-11-15T03:00:29.651832+00:00 0:00:00.958965 446578 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T03:00:26.660630+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T02:00:00+00:00 PythonOperator 2023-11-15T03:00:08.851636+00:00 2023-11-15T03:00:11.025793+00:00 0:00:02.174157 446577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T03:00:06.640849+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T01:00:00+00:00 EmrJobFlowSensor 2023-11-15T02:00:51.254076+00:00 2023-11-15T02:25:55.219339+00:00 0:25:03.965263 446565 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T02:00:49.284479+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T02:00:29.266067+00:00 2023-11-15T02:00:30.275402+00:00 0:00:01.009335 446564 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T02:00:27.262974+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T01:00:00+00:00 PythonOperator 2023-11-15T02:00:09.436069+00:00 2023-11-15T02:00:11.636612+00:00 0:00:02.200543 446563 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T02:00:07.245493+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-15T00:00:00+00:00 EmrJobFlowSensor 2023-11-15T01:00:52.750310+00:00 2023-11-15T01:25:56.437189+00:00 0:25:03.686879 446545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T01:00:50.765276+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-15T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-15T01:00:32.717001+00:00 2023-11-15T01:00:33.814383+00:00 0:00:01.097382 446544 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-15T01:00:30.748185+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-15T00:00:00+00:00 PythonOperator 2023-11-15T01:00:10.818041+00:00 2023-11-15T01:00:12.999515+00:00 0:00:02.181474 446543 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-15T01:00:08.729681+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-14T23:00:00+00:00 EmrJobFlowSensor 2023-11-15T00:00:48.638558+00:00 2023-11-15T00:25:52.523442+00:00 0:25:03.884884 446531 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-15T00:00:46.750230+00:00 2 default_pool