Task Instances


  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T04:00:00+00:00 EmrJobFlowSensor 2023-11-06T05:00:53.890837+00:00 2023-11-06T05:24:57.459793+00:00 0:24:03.568956 443363 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T05:00:51.926014+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T05:00:33.846942+00:00 2023-11-06T05:00:34.923308+00:00 0:00:01.076366 443362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T05:00:31.904833+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T04:00:00+00:00 PythonOperator 2023-11-06T05:00:12.289455+00:00 2023-11-06T05:00:14.394648+00:00 0:00:02.105193 443360 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T05:00:09.946625+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T03:00:00+00:00 EmrJobFlowSensor 2023-11-06T04:00:58.542558+00:00 2023-11-06T04:25:02.156747+00:00 0:24:03.614189 443339 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T04:00:56.430716+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T04:00:38.570871+00:00 2023-11-06T04:00:39.625516+00:00 0:00:01.054645 443337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T04:00:36.452611+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T03:00:00+00:00 PythonOperator 2023-11-06T04:00:17.297758+00:00 2023-11-06T04:00:20.364908+00:00 0:00:03.067150 443334 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T04:00:14.392539+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T02:00:00+00:00 EmrJobFlowSensor 2023-11-06T03:00:58.269238+00:00 2023-11-06T03:26:02.049781+00:00 0:25:03.780543 443317 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T03:00:56.168634+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T03:00:38.338595+00:00 2023-11-06T03:00:39.380144+00:00 0:00:01.041549 443316 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T03:00:36.152492+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T02:00:00+00:00 PythonOperator 2023-11-06T03:00:16.341079+00:00 2023-11-06T03:00:18.617629+00:00 0:00:02.276550 443315 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T03:00:14.080437+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T01:00:00+00:00 EmrJobFlowSensor 2023-11-06T02:00:55.620574+00:00 2023-11-06T02:26:59.456997+00:00 0:26:03.836423 443298 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T02:00:53.532322+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T02:00:33.758852+00:00 2023-11-06T02:00:34.819315+00:00 0:00:01.060463 443297 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T02:00:31.476784+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T01:00:00+00:00 PythonOperator 2023-11-06T02:00:13.363719+00:00 2023-11-06T02:00:15.519459+00:00 0:00:02.155740 443296 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T02:00:11.427335+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T00:00:00+00:00 EmrJobFlowSensor 2023-11-06T01:00:53.114500+00:00 2023-11-06T01:23:56.660956+00:00 0:23:03.546456 443273 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T01:00:51.070805+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T01:00:31.070784+00:00 2023-11-06T01:00:32.171109+00:00 0:00:01.100325 443272 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T01:00:29.046405+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T00:00:00+00:00 PythonOperator 2023-11-06T01:00:09.171636+00:00 2023-11-06T01:00:11.338996+00:00 0:00:02.167360 443271 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T01:00:07.067834+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T23:00:00+00:00 EmrJobFlowSensor 2023-11-06T00:00:54.243531+00:00 2023-11-06T00:24:57.767737+00:00 0:24:03.524206 443254 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T00:00:52.311782+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T00:00:34.247152+00:00 2023-11-06T00:00:35.232919+00:00 0:00:00.985767 443253 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T00:00:32.289185+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T23:00:00+00:00 PythonOperator 2023-11-06T00:00:12.559066+00:00 2023-11-06T00:00:14.703040+00:00 0:00:02.143974 443252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T00:00:10.270769+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T22:00:00+00:00 EmrJobFlowSensor 2023-11-05T23:00:48.785257+00:00 2023-11-05T23:25:52.502642+00:00 0:25:03.717385 443234 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T23:00:45.247981+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T23:00:25.203482+00:00 2023-11-05T23:00:26.492143+00:00 0:00:01.288661 443231 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T23:00:23.228501+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T22:00:00+00:00 PythonOperator 2023-11-05T23:00:03.824886+00:00 2023-11-05T23:00:06.854286+00:00 0:00:03.029400 443228 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T23:00:01.337340+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T21:00:00+00:00 EmrJobFlowSensor 2023-11-05T22:00:46.742646+00:00 2023-11-05T22:21:50.059449+00:00 0:21:03.316803 443212 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T22:00:44.779775+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T22:00:27.106987+00:00 2023-11-05T22:00:28.084986+00:00 0:00:00.977999 443211 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T22:00:24.762564+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T21:00:00+00:00 PythonOperator 2023-11-05T22:00:04.881456+00:00 2023-11-05T22:00:07.034864+00:00 0:00:02.153408 443209 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T22:00:02.740868+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T20:00:00+00:00 EmrJobFlowSensor 2023-11-05T21:00:46.137952+00:00 2023-11-05T21:21:49.278500+00:00 0:21:03.140548 443195 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T21:00:44.173860+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T21:00:26.428884+00:00 2023-11-05T21:00:27.466275+00:00 0:00:01.037391 443193 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T21:00:24.157683+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T20:00:00+00:00 PythonOperator 2023-11-05T21:00:04.343922+00:00 2023-11-05T21:00:06.419068+00:00 0:00:02.075146 443191 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T21:00:02.139025+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T19:00:00+00:00 EmrJobFlowSensor 2023-11-05T20:00:52.260902+00:00 2023-11-05T20:23:55.767580+00:00 0:23:03.506678 443177 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T20:00:50.277488+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T20:00:30.186631+00:00 2023-11-05T20:00:31.116202+00:00 0:00:00.929571 443175 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T20:00:28.217435+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T19:00:00+00:00 PythonOperator 2023-11-05T20:00:10.320699+00:00 2023-11-05T20:00:13.403722+00:00 0:00:03.083023 443173 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T20:00:08.198245+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T18:00:00+00:00 EmrJobFlowSensor 2023-11-05T19:01:06.177439+00:00 2023-11-05T19:23:09.507446+00:00 0:22:03.330007 443156 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T19:01:04.170537+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T19:00:46.117360+00:00 2023-11-05T19:00:47.046289+00:00 0:00:00.928929 443155 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T19:00:44.132903+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T18:00:00+00:00 PythonOperator 2023-11-05T19:00:24.054489+00:00 2023-11-05T19:00:26.374461+00:00 0:00:02.319972 443154 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T19:00:22.115413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T17:00:00+00:00 EmrJobFlowSensor 2023-11-05T18:00:52.073057+00:00 2023-11-05T18:22:55.435068+00:00 0:22:03.362011 443137 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T18:00:50.045138+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T18:00:29.949703+00:00 2023-11-05T18:00:31.177670+00:00 0:00:01.227967 443136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T18:00:28.019644+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T17:00:00+00:00 PythonOperator 2023-11-05T18:00:10.159711+00:00 2023-11-05T18:00:12.308383+00:00 0:00:02.148672 443134 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T18:00:08.004978+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T16:00:00+00:00 EmrJobFlowSensor 2023-11-05T17:01:03.421741+00:00 2023-11-05T17:22:06.737576+00:00 0:21:03.315835 443119 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T17:01:01.451782+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T17:00:43.455437+00:00 2023-11-05T17:00:44.490501+00:00 0:00:01.035064 443118 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T17:00:41.431968+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T16:00:00+00:00 PythonOperator 2023-11-05T17:00:21.987611+00:00 2023-11-05T17:00:24.978230+00:00 0:00:02.990619 443116 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T17:00:19.463757+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T15:00:00+00:00 EmrJobFlowSensor 2023-11-05T16:00:50.350967+00:00 2023-11-05T16:24:53.999013+00:00 0:24:03.648046 443100 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T16:00:48.426272+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T16:00:30.362169+00:00 2023-11-05T16:00:31.297558+00:00 0:00:00.935389 443099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T16:00:28.406221+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T15:00:00+00:00 PythonOperator 2023-11-05T16:00:08.776409+00:00 2023-11-05T16:00:10.874082+00:00 0:00:02.097673 443097 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T16:00:06.443151+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T14:00:00+00:00 EmrJobFlowSensor 2023-11-05T15:00:47.444352+00:00 2023-11-05T15:24:50.958304+00:00 0:24:03.513952 443082 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T15:00:45.509641+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T15:00:27.460730+00:00 2023-11-05T15:00:28.399439+00:00 0:00:00.938709 443081 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T15:00:25.484913+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T14:00:00+00:00 PythonOperator 2023-11-05T15:00:05.919264+00:00 2023-11-05T15:00:08.051233+00:00 0:00:02.131969 443079 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T15:00:03.467752+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T13:00:00+00:00 EmrJobFlowSensor 2023-11-05T14:06:33.619253+00:00 2023-11-05T14:30:37.273353+00:00 0:24:03.654100 443068 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T14:06:29.965243+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T14:06:09.852754+00:00 2023-11-05T14:06:11.040680+00:00 0:00:01.187926 443065 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T14:06:07.918416+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T13:00:00+00:00 PythonOperator 2023-11-05T14:05:51.799973+00:00 2023-11-05T14:05:54.199259+00:00 0:00:02.399286 443063 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T14:05:47.966565+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T12:00:00+00:00 EmrJobFlowSensor 2023-11-05T13:00:57.646340+00:00 2023-11-05T13:25:01.288235+00:00 0:24:03.641895 443046 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T13:00:55.713669+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T13:00:35.836701+00:00 2023-11-05T13:00:36.817389+00:00 0:00:00.980688 443045 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T13:00:33.753900+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T12:00:00+00:00 PythonOperator 2023-11-05T13:00:13.949015+00:00 2023-11-05T13:00:16.088794+00:00 0:00:02.139779 443044 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T13:00:11.748965+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T11:00:00+00:00 EmrJobFlowSensor 2023-11-05T12:00:48.299006+00:00 2023-11-05T12:24:51.885210+00:00 0:24:03.586204 443029 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T12:00:46.331885+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T12:00:28.260328+00:00 2023-11-05T12:00:29.305532+00:00 0:00:01.045204 443028 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T12:00:26.311960+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T11:00:00+00:00 PythonOperator 2023-11-05T12:00:06.763299+00:00 2023-11-05T12:00:08.896690+00:00 0:00:02.133391 443027 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T12:00:04.330554+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T10:00:00+00:00 EmrJobFlowSensor 2023-11-05T11:01:04.445405+00:00 2023-11-05T11:25:08.051340+00:00 0:24:03.605935 443012 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T11:01:02.492814+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T11:00:44.450361+00:00 2023-11-05T11:00:45.601675+00:00 0:00:01.151314 443011 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T11:00:42.474300+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T10:00:00+00:00 PythonOperator 2023-11-05T11:00:24.285846+00:00 2023-11-05T11:00:26.452211+00:00 0:00:02.166365 443010 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T11:00:20.456349+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T09:00:00+00:00 EmrJobFlowSensor 2023-11-05T10:00:46.054510+00:00 2023-11-05T10:24:49.590575+00:00 0:24:03.536065 442996 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T10:00:44.046651+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T10:00:25.956994+00:00 2023-11-05T10:00:27.004400+00:00 0:00:01.047406 442995 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T10:00:23.971193+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T09:00:00+00:00 PythonOperator 2023-11-05T10:00:04.111042+00:00 2023-11-05T10:00:06.265945+00:00 0:00:02.154903 442993 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T10:00:01.951289+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T08:00:00+00:00 EmrJobFlowSensor 2023-11-05T09:00:55.334636+00:00 2023-11-05T09:24:59.024951+00:00 0:24:03.690315 442978 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T09:00:53.344634+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T09:00:33.342708+00:00 2023-11-05T09:00:34.519778+00:00 0:00:01.177070 442977 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T09:00:31.333629+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T08:00:00+00:00 PythonOperator 2023-11-05T09:00:13.443095+00:00 2023-11-05T09:00:15.548444+00:00 0:00:02.105349 442976 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T09:00:11.214222+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T07:00:00+00:00 EmrJobFlowSensor 2023-11-05T08:00:57.237106+00:00 2023-11-05T08:26:01.171074+00:00 0:25:03.933968 442959 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T08:00:55.164682+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T08:00:35.152772+00:00 2023-11-05T08:00:36.170523+00:00 0:00:01.017751 442958 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T08:00:33.138472+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T07:00:00+00:00 PythonOperator 2023-11-05T08:00:16.801597+00:00 2023-11-05T08:00:18.978460+00:00 0:00:02.176863 442957 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T08:00:13.057397+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T06:00:00+00:00 EmrJobFlowSensor 2023-11-05T07:00:59.099554+00:00 2023-11-05T07:25:02.920753+00:00 0:24:03.821199 442941 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T07:00:57.134684+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T07:00:39.127966+00:00 2023-11-05T07:00:40.025685+00:00 0:00:00.897719 442940 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T07:00:37.114886+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T06:00:00+00:00 PythonOperator 2023-11-05T07:00:17.246131+00:00 2023-11-05T07:00:19.503042+00:00 0:00:02.256911 442939 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T07:00:15.146506+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T05:00:00+00:00 EmrJobFlowSensor 2023-11-05T06:11:46.347308+00:00 2023-11-05T06:35:50.217938+00:00 0:24:03.870630 442926 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T06:11:44.404604+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T06:11:26.359559+00:00 2023-11-05T06:11:27.683985+00:00 0:00:01.324426 442924 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T06:11:24.384577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T05:00:00+00:00 PythonOperator 2023-11-05T06:11:04.792021+00:00 2023-11-05T06:11:07.191621+00:00 0:00:02.399600 442921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T06:11:02.368878+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T04:00:00+00:00 EmrJobFlowSensor 2023-11-05T05:01:05.132837+00:00 2023-11-05T05:24:08.528855+00:00 0:23:03.396018 442907 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T05:01:03.133948+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T05:00:43.197725+00:00 2023-11-05T05:00:44.277699+00:00 0:00:01.079974 442906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T05:00:41.053141+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T04:00:00+00:00 PythonOperator 2023-11-05T05:00:23.111480+00:00 2023-11-05T05:00:25.403039+00:00 0:00:02.291559 442905 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T05:00:21.047351+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T03:00:00+00:00 EmrJobFlowSensor 2023-11-05T04:14:24.930760+00:00 2023-11-05T04:37:28.525267+00:00 0:23:03.594507 442890 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T04:14:22.839155+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T04:14:02.965209+00:00 2023-11-05T04:14:04.337717+00:00 0:00:01.372508 442887 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T04:14:00.805038+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T03:00:00+00:00 PythonOperator 2023-11-05T04:13:46.368782+00:00 2023-11-05T04:13:49.394407+00:00 0:00:03.025625 442884 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T04:13:40.785911+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T02:00:00+00:00 EmrJobFlowSensor 2023-11-05T03:01:17.778135+00:00 2023-11-05T03:25:21.279052+00:00 0:24:03.500917 442866 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T03:01:15.687848+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T03:00:57.685575+00:00 2023-11-05T03:00:58.774155+00:00 0:00:01.088580 442865 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T03:00:55.669766+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T02:00:00+00:00 PythonOperator 2023-11-05T03:00:36.215574+00:00 2023-11-05T03:00:38.419274+00:00 0:00:02.203700 442863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T03:00:33.656765+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T01:00:00+00:00 EmrJobFlowSensor 2023-11-05T02:02:30.539780+00:00 2023-11-05T02:25:34.143726+00:00 0:23:03.603946 442847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T02:02:28.537904+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T02:02:10.481716+00:00 2023-11-05T02:02:11.467054+00:00 0:00:00.985338 442846 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T02:02:08.516963+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T01:00:00+00:00 PythonOperator 2023-11-05T02:01:48.819700+00:00 2023-11-05T02:01:50.958534+00:00 0:00:02.138834 442845 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T02:01:46.505473+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-05T00:00:00+00:00 EmrJobFlowSensor 2023-11-05T01:03:22.766421+00:00 2023-11-05T01:27:26.358186+00:00 0:24:03.591765 442823 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T01:03:20.801191+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-05T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T01:03:00.760418+00:00 2023-11-05T01:03:01.847739+00:00 0:00:01.087321 442822 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T01:02:58.782640+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-05T00:00:00+00:00 PythonOperator 2023-11-05T01:02:41.205274+00:00 2023-11-05T01:02:43.318423+00:00 0:00:02.113149 442820 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T01:02:38.821447+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T23:00:00+00:00 EmrJobFlowSensor 2023-11-05T00:01:02.267402+00:00 2023-11-05T00:25:05.923228+00:00 0:24:03.655826 442804 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-05T00:01:00.251913+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-05T00:00:40.343347+00:00 2023-11-05T00:00:41.352565+00:00 0:00:01.009218 442803 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-05T00:00:38.264036+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T23:00:00+00:00 PythonOperator 2023-11-05T00:00:20.723553+00:00 2023-11-05T00:00:22.814225+00:00 0:00:02.090672 442802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-05T00:00:18.265128+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T22:00:00+00:00 EmrJobFlowSensor 2023-11-04T23:00:53.745521+00:00 2023-11-04T23:25:57.406671+00:00 0:25:03.661150 442784 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T23:00:51.642030+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T23:00:33.664980+00:00 2023-11-04T23:00:34.573989+00:00 0:00:00.909009 442782 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T23:00:31.569234+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T22:00:00+00:00 PythonOperator 2023-11-04T23:00:11.752622+00:00 2023-11-04T23:00:13.878661+00:00 0:00:02.126039 442780 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T23:00:09.563150+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T21:00:00+00:00 EmrJobFlowSensor 2023-11-04T22:01:05.714473+00:00 2023-11-04T22:21:08.710843+00:00 0:20:02.996370 442763 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T22:01:03.702073+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T22:00:43.640240+00:00 2023-11-04T22:00:44.678072+00:00 0:00:01.037832 442762 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T22:00:41.682826+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T21:00:00+00:00 PythonOperator 2023-11-04T22:00:21.637770+00:00 2023-11-04T22:00:23.743677+00:00 0:00:02.105907 442761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T22:00:19.627317+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T20:00:00+00:00 EmrJobFlowSensor 2023-11-04T21:01:06.702086+00:00 2023-11-04T21:22:10.048434+00:00 0:21:03.346348 442747 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T21:01:04.461957+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T21:00:44.448750+00:00 2023-11-04T21:00:45.411997+00:00 0:00:00.963247 442745 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T21:00:42.441159+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T20:00:00+00:00 PythonOperator 2023-11-04T21:00:22.585018+00:00 2023-11-04T21:00:24.791843+00:00 0:00:02.206825 442743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T21:00:20.458620+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T19:00:00+00:00 EmrJobFlowSensor 2023-11-04T20:00:48.894441+00:00 2023-11-04T20:23:52.239695+00:00 0:23:03.345254 442728 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T20:00:46.761752+00:00 2 default_pool