Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T10:00:00+00:00 EmrJobFlowSensor 2023-12-24T11:00:52.535710+00:00 2023-12-24T11:25:56.382418+00:00 0:25:03.846708 461432 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T11:00:50.902766+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T11:00:30.565154+00:00 2023-12-24T11:00:31.588158+00:00 0:00:01.023004 461430 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T11:00:28.861725+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T10:00:00+00:00 PythonOperator 2023-12-24T11:00:09.244012+00:00 2023-12-24T11:00:10.835474+00:00 0:00:01.591462 461428 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T11:00:06.867290+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T09:00:00+00:00 EmrJobFlowSensor 2023-12-24T10:00:56.000148+00:00 2023-12-24T10:26:00.035663+00:00 0:25:04.035515 461415 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T10:00:54.348663+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T10:00:34.161579+00:00 2023-12-24T10:00:35.073596+00:00 0:00:00.912017 461413 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T10:00:32.382119+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T09:00:00+00:00 PythonOperator 2023-12-24T10:00:12.552265+00:00 2023-12-24T10:00:14.201646+00:00 0:00:01.649381 461411 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T10:00:10.360972+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T08:00:00+00:00 EmrJobFlowSensor 2023-12-24T09:00:59.242179+00:00 2023-12-24T09:26:03.287106+00:00 0:25:04.044927 461396 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T09:00:57.554002+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T09:00:39.251360+00:00 2023-12-24T09:00:40.198169+00:00 0:00:00.946809 461394 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T09:00:37.539346+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T08:00:00+00:00 PythonOperator 2023-12-24T09:00:18.221743+00:00 2023-12-24T09:00:19.816236+00:00 0:00:01.594493 461393 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T09:00:15.480682+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T07:00:00+00:00 EmrJobFlowSensor 2023-12-24T08:01:02.114608+00:00 2023-12-24T08:26:06.236587+00:00 0:25:04.121979 461379 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T08:00:59.972941+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T08:00:41.674630+00:00 2023-12-24T08:00:42.558277+00:00 0:00:00.883647 461377 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T08:00:39.953456+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T07:00:00+00:00 PythonOperator 2023-12-24T08:00:19.610854+00:00 2023-12-24T08:00:21.227801+00:00 0:00:01.616947 461375 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T08:00:17.937322+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T06:00:00+00:00 EmrJobFlowSensor 2023-12-24T07:01:01.994534+00:00 2023-12-24T07:26:05.884633+00:00 0:25:03.890099 461361 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T07:00:59.936212+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T07:00:42.052708+00:00 2023-12-24T07:00:43.262668+00:00 0:00:01.209960 461359 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T07:00:39.921500+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T06:00:00+00:00 PythonOperator 2023-12-24T07:00:19.555648+00:00 2023-12-24T07:00:21.116190+00:00 0:00:01.560542 461357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T07:00:17.903704+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T05:00:00+00:00 EmrJobFlowSensor 2023-12-24T06:01:00.351169+00:00 2023-12-24T06:26:04.691411+00:00 0:25:04.340242 461344 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T06:00:58.646194+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T06:00:39.472532+00:00 2023-12-24T06:00:40.346413+00:00 0:00:00.873881 461342 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T06:00:36.625984+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T05:00:00+00:00 PythonOperator 2023-12-24T06:00:16.904403+00:00 2023-12-24T06:00:18.533006+00:00 0:00:01.628603 461340 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T06:00:14.615346+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T04:00:00+00:00 EmrJobFlowSensor 2023-12-24T05:01:24.235583+00:00 2023-12-24T05:26:28.027317+00:00 0:25:03.791734 461327 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T05:01:22.101624+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T05:01:02.792681+00:00 2023-12-24T05:01:03.727844+00:00 0:00:00.935163 461325 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T05:01:00.102424+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T04:00:00+00:00 PythonOperator 2023-12-24T05:00:41.763475+00:00 2023-12-24T05:00:43.302309+00:00 0:00:01.538834 461323 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T05:00:40.063682+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T03:00:00+00:00 EmrJobFlowSensor 2023-12-24T04:01:06.144237+00:00 2023-12-24T04:26:10.203332+00:00 0:25:04.059095 461308 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T04:01:04.475640+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T04:00:44.171877+00:00 2023-12-24T04:00:45.142687+00:00 0:00:00.970810 461305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T04:00:42.452973+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T03:00:00+00:00 PythonOperator 2023-12-24T04:00:22.474413+00:00 2023-12-24T04:00:24.031010+00:00 0:00:01.556597 461302 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T04:00:20.437605+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T02:00:00+00:00 EmrJobFlowSensor 2023-12-24T03:00:57.082728+00:00 2023-12-24T03:26:01.136205+00:00 0:25:04.053477 461288 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T03:00:54.960238+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T03:00:34.845732+00:00 2023-12-24T03:00:35.777350+00:00 0:00:00.931618 461286 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T03:00:32.987730+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T02:00:00+00:00 PythonOperator 2023-12-24T03:00:13.063420+00:00 2023-12-24T03:00:14.827930+00:00 0:00:01.764510 461284 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T03:00:10.929477+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T01:00:00+00:00 EmrJobFlowSensor 2023-12-24T02:00:46.150336+00:00 2023-12-24T02:25:50.030295+00:00 0:25:03.879959 461269 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T02:00:44.134973+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T02:00:24.473123+00:00 2023-12-24T02:00:25.464744+00:00 0:00:00.991621 461267 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T02:00:22.166612+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T01:00:00+00:00 PythonOperator 2023-12-24T02:00:04.622416+00:00 2023-12-24T02:00:06.310697+00:00 0:00:01.688281 461265 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T02:00:02.100040+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T00:00:00+00:00 EmrJobFlowSensor 2023-12-24T01:05:07.163342+00:00 2023-12-24T01:29:10.846967+00:00 0:24:03.683625 461246 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T01:05:05.364972+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T01:04:45.055251+00:00 2023-12-24T01:04:46.141746+00:00 0:00:01.086495 461244 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T01:04:43.289013+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T00:00:00+00:00 PythonOperator 2023-12-24T01:04:25.643815+00:00 2023-12-24T01:04:27.377418+00:00 0:00:01.733603 461242 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T01:04:23.239756+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T23:00:00+00:00 EmrJobFlowSensor 2023-12-24T00:00:57.349327+00:00 2023-12-24T00:26:01.039510+00:00 0:25:03.690183 461227 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T00:00:55.652250+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T00:00:37.686680+00:00 2023-12-24T00:00:38.620080+00:00 0:00:00.933400 461225 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T00:00:35.597354+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T23:00:00+00:00 PythonOperator 2023-12-24T00:00:15.513703+00:00 2023-12-24T00:00:17.079823+00:00 0:00:01.566120 461223 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T00:00:13.578814+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T22:00:00+00:00 EmrJobFlowSensor 2023-12-23T23:00:56.853828+00:00 2023-12-23T23:26:00.739868+00:00 0:25:03.886040 461210 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T23:00:54.761138+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T23:00:36.358774+00:00 2023-12-23T23:00:37.402487+00:00 0:00:01.043713 461207 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T23:00:34.727267+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T22:00:00+00:00 PythonOperator 2023-12-23T23:00:14.772436+00:00 2023-12-23T23:00:16.382576+00:00 0:00:01.610140 461204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T23:00:12.709618+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T21:00:00+00:00 EmrJobFlowSensor 2023-12-23T22:01:00.790803+00:00 2023-12-23T22:24:04.507013+00:00 0:23:03.716210 461188 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T22:00:58.747188+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T22:00:38.356556+00:00 2023-12-23T22:00:39.378829+00:00 0:00:01.022273 461186 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T22:00:36.724660+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T21:00:00+00:00 PythonOperator 2023-12-23T22:00:19.046490+00:00 2023-12-23T22:00:20.562240+00:00 0:00:01.515750 461184 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T22:00:16.708877+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T20:00:00+00:00 EmrJobFlowSensor 2023-12-23T21:01:04.382620+00:00 2023-12-23T21:27:08.223001+00:00 0:26:03.840381 461171 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T21:01:02.664311+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T21:00:42.673215+00:00 2023-12-23T21:00:43.570431+00:00 0:00:00.897216 461169 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T21:00:40.625376+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T20:00:00+00:00 PythonOperator 2023-12-23T21:00:23.062505+00:00 2023-12-23T21:00:24.643420+00:00 0:00:01.580915 461167 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T21:00:20.609969+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T19:00:00+00:00 EmrJobFlowSensor 2023-12-23T20:01:04.347510+00:00 2023-12-23T20:28:08.581281+00:00 0:27:04.233771 461153 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T20:01:02.260924+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T20:00:41.963260+00:00 2023-12-23T20:00:42.903600+00:00 0:00:00.940340 461151 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T20:00:40.242015+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T19:00:00+00:00 PythonOperator 2023-12-23T20:00:20.482036+00:00 2023-12-23T20:00:22.066772+00:00 0:00:01.584736 461149 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T20:00:18.276973+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T18:00:00+00:00 EmrJobFlowSensor 2023-12-23T19:01:03.900186+00:00 2023-12-23T19:28:07.945265+00:00 0:27:04.045079 461135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T19:01:02.193598+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T19:00:41.855411+00:00 2023-12-23T19:00:42.860096+00:00 0:00:01.004685 461132 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T19:00:40.155378+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T18:00:00+00:00 PythonOperator 2023-12-23T19:00:20.849938+00:00 2023-12-23T19:00:22.443052+00:00 0:00:01.593114 461131 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T19:00:18.254107+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T17:00:00+00:00 EmrJobFlowSensor 2023-12-23T18:01:04.658253+00:00 2023-12-23T18:27:08.689230+00:00 0:26:04.030977 461117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T18:01:02.615704+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T18:00:42.859212+00:00 2023-12-23T18:00:43.817657+00:00 0:00:00.958445 461115 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T18:00:40.659254+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T17:00:00+00:00 PythonOperator 2023-12-23T18:00:20.775439+00:00 2023-12-23T18:00:22.388608+00:00 0:00:01.613169 461113 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T18:00:18.585398+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T16:00:00+00:00 EmrJobFlowSensor 2023-12-23T17:01:00.728119+00:00 2023-12-23T17:25:04.493517+00:00 0:24:03.765398 461099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T17:00:58.651526+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T17:00:39.321301+00:00 2023-12-23T17:00:40.164101+00:00 0:00:00.842800 461097 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T17:00:36.678780+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T16:00:00+00:00 PythonOperator 2023-12-23T17:00:18.862162+00:00 2023-12-23T17:00:20.389907+00:00 0:00:01.527745 461095 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T17:00:16.661808+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T15:00:00+00:00 EmrJobFlowSensor 2023-12-23T16:07:58.068595+00:00 2023-12-23T16:34:02.584185+00:00 0:26:04.515590 461085 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T16:07:56.389819+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T16:07:36.261754+00:00 2023-12-23T16:07:37.270958+00:00 0:00:01.009204 461082 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T16:07:34.375377+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T15:00:00+00:00 PythonOperator 2023-12-23T16:07:16.485474+00:00 2023-12-23T16:07:18.120349+00:00 0:00:01.634875 461079 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T16:07:14.361342+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T14:00:00+00:00 EmrJobFlowSensor 2023-12-23T15:00:58.449120+00:00 2023-12-23T15:27:02.704511+00:00 0:26:04.255391 461064 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T15:00:56.358848+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T15:00:38.485557+00:00 2023-12-23T15:00:39.423372+00:00 0:00:00.937815 461062 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T15:00:36.341910+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T14:00:00+00:00 PythonOperator 2023-12-23T15:00:16.562276+00:00 2023-12-23T15:00:18.131204+00:00 0:00:01.568928 461060 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T15:00:14.260107+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T13:00:00+00:00 EmrJobFlowSensor 2023-12-23T14:07:25.754312+00:00 2023-12-23T14:31:29.884728+00:00 0:24:04.130416 461052 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T14:07:24.044706+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T14:07:05.650219+00:00 2023-12-23T14:07:06.673809+00:00 0:00:01.023590 461049 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T14:07:04.023441+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T13:00:00+00:00 PythonOperator 2023-12-23T14:06:43.670240+00:00 2023-12-23T14:06:45.330050+00:00 0:00:01.659810 461046 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T14:06:42.008844+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T12:00:00+00:00 EmrJobFlowSensor 2023-12-23T13:01:40.520502+00:00 2023-12-23T13:26:44.330212+00:00 0:25:03.809710 461032 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T13:01:38.451870+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T13:01:20.060412+00:00 2023-12-23T13:01:21.147454+00:00 0:00:01.087042 461030 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T13:01:18.425175+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T12:00:00+00:00 PythonOperator 2023-12-23T13:00:58.559057+00:00 2023-12-23T13:01:00.127036+00:00 0:00:01.567979 461028 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T13:00:56.409691+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T11:00:00+00:00 EmrJobFlowSensor 2023-12-23T12:00:55.768058+00:00 2023-12-23T12:25:59.622882+00:00 0:25:03.854824 461016 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T12:00:54.024591+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T12:00:33.782389+00:00 2023-12-23T12:00:34.912857+00:00 0:00:01.130468 461014 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T12:00:32.061010+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T11:00:00+00:00 PythonOperator 2023-12-23T12:00:14.571302+00:00 2023-12-23T12:00:16.213274+00:00 0:00:01.641972 461012 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T12:00:12.052450+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T10:00:00+00:00 EmrJobFlowSensor 2023-12-23T11:00:53.058096+00:00 2023-12-23T11:25:57.187334+00:00 0:25:04.129238 461003 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T11:00:51.278280+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T11:00:31.417302+00:00 2023-12-23T11:00:32.594924+00:00 0:00:01.177622 461001 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T11:00:29.256821+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T10:00:00+00:00 PythonOperator 2023-12-23T11:00:11.202452+00:00 2023-12-23T11:00:12.791521+00:00 0:00:01.589069 460999 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T11:00:09.187191+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T09:00:00+00:00 EmrJobFlowSensor 2023-12-23T10:03:14.978857+00:00 2023-12-23T10:27:18.807661+00:00 0:24:03.828804 460990 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T10:03:13.285496+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T10:02:55.376666+00:00 2023-12-23T10:02:56.227022+00:00 0:00:00.850356 460988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T10:02:53.252415+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T09:00:00+00:00 PythonOperator 2023-12-23T10:02:33.295387+00:00 2023-12-23T10:02:34.862836+00:00 0:00:01.567449 460986 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T10:02:31.233468+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T08:00:00+00:00 EmrJobFlowSensor 2023-12-23T09:01:03.546045+00:00 2023-12-23T09:26:07.177018+00:00 0:25:03.630973 460974 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T09:01:01.851910+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T09:00:42.785532+00:00 2023-12-23T09:00:43.677863+00:00 0:00:00.892331 460972 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T09:00:39.880010+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T08:00:00+00:00 PythonOperator 2023-12-23T09:00:22.061232+00:00 2023-12-23T09:00:23.641245+00:00 0:00:01.580013 460970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T09:00:19.872211+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T07:00:00+00:00 EmrJobFlowSensor 2023-12-23T08:00:50.103257+00:00 2023-12-23T08:25:53.806241+00:00 0:25:03.702984 460958 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T08:00:47.867864+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T08:00:27.564247+00:00 2023-12-23T08:00:28.537425+00:00 0:00:00.973178 460956 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T08:00:25.855134+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T07:00:00+00:00 PythonOperator 2023-12-23T08:00:07.864735+00:00 2023-12-23T08:00:09.476774+00:00 0:00:01.612039 460954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T08:00:05.786232+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T06:00:00+00:00 EmrJobFlowSensor 2023-12-23T07:01:34.104800+00:00 2023-12-23T07:27:38.083966+00:00 0:26:03.979166 460941 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T07:01:32.400366+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T07:01:14.066355+00:00 2023-12-23T07:01:15.027340+00:00 0:00:00.960985 460939 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T07:01:12.381344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T06:00:00+00:00 PythonOperator 2023-12-23T07:00:52.649849+00:00 2023-12-23T07:00:54.170907+00:00 0:00:01.521058 460937 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T07:00:50.361728+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T05:00:00+00:00 EmrJobFlowSensor 2023-12-23T06:00:56.114047+00:00 2023-12-23T06:25:59.895823+00:00 0:25:03.781776 460925 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T06:00:54.284866+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T06:00:34.470493+00:00 2023-12-23T06:00:35.372075+00:00 0:00:00.901582 460923 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T06:00:32.272922+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T05:00:00+00:00 PythonOperator 2023-12-23T06:00:12.337481+00:00 2023-12-23T06:00:13.968635+00:00 0:00:01.631154 460921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T06:00:10.204980+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T04:00:00+00:00 EmrJobFlowSensor 2023-12-23T05:00:49.068593+00:00 2023-12-23T05:25:52.832942+00:00 0:25:03.764349 460909 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T05:00:46.949562+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T05:00:26.864054+00:00 2023-12-23T05:00:28.046773+00:00 0:00:01.182719 460906 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T05:00:24.983477+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T04:00:00+00:00 PythonOperator 2023-12-23T05:00:04.964017+00:00 2023-12-23T05:00:06.519931+00:00 0:00:01.555914 460904 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T05:00:02.909554+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T03:00:00+00:00 EmrJobFlowSensor 2023-12-23T04:00:53.659766+00:00 2023-12-23T04:25:57.501064+00:00 0:25:03.841298 460890 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T04:00:51.555972+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T04:00:31.770472+00:00 2023-12-23T04:00:32.732874+00:00 0:00:00.962402 460887 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T04:00:29.555692+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T03:00:00+00:00 PythonOperator 2023-12-23T04:00:11.357584+00:00 2023-12-23T04:00:12.935593+00:00 0:00:01.578009 460884 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T04:00:09.577128+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T02:00:00+00:00 EmrJobFlowSensor 2023-12-23T03:00:49.497969+00:00 2023-12-23T03:25:53.247527+00:00 0:25:03.749558 460870 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T03:00:47.460059+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-23T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T03:00:27.590381+00:00 2023-12-23T03:00:28.510753+00:00 0:00:00.920372 460868 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T03:00:25.438514+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-23T02:00:00+00:00 PythonOperator 2023-12-23T03:00:05.856342+00:00 2023-12-23T03:00:07.491790+00:00 0:00:01.635448 460866 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T03:00:03.465586+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-23T01:00:00+00:00 EmrJobFlowSensor 2023-12-23T02:00:58.745186+00:00 2023-12-23T02:26:02.500760+00:00 0:25:03.755574 460854 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-23T02:00:56.971817+00:00 2 default_pool