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_v002 check_cluster_status 2023-09-18T15:14:58.031002+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-09-10T02:59:21.796553+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-18T15:14:58.031002+00:00 EmrCreateJobFlowOperator airflow 2 default 2023-09-18T15:15:34.007764+00:00 1 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-03T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T19:10:03.353677+00:00 2023-11-07T19:10:04.722477+00:00 0:00:01.368800 444152 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-03T10:00:00+00:00 PythonOperator 2023-11-07T19:09:50.939968+00:00 2023-11-07T19:09:53.060643+00:00 0:00:02.120675 444151 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-03T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T18:37:44.330843+00:00 2023-11-07T18:37:45.281641+00:00 0:00:00.950798 444138 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-03T07:00:00+00:00 PythonOperator 2023-11-07T18:37:34.435397+00:00 2023-11-07T18:37:36.527487+00:00 0:00:02.092090 444137 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-02T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T18:16:50.058051+00:00 2023-11-07T18:16:51.137026+00:00 0:00:01.078975 444129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T18:16:47.536384+00:00 4 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-02T10:00:00+00:00 PythonOperator 2023-11-07T18:16:42.628759+00:00 2023-11-07T18:16:44.699323+00:00 0:00:02.070564 444128 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T14:40:19.158561+00:00 4 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T11:00:00+00:00 EmrJobFlowSensor 2023-11-07T13:11:43.353893+00:00 2023-11-07T13:28:45.936748+00:00 0:17:02.582855 444016 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 3 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T13:11:36.717731+00:00 2023-11-07T13:11:37.739552+00:00 0:00:01.021821 444015 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 3 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T11:00:00+00:00 PythonOperator 2023-11-07T13:11:25.167164+00:00 2023-11-07T13:11:27.242905+00:00 0:00:02.075741 444014 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 3 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T06:02:53.982946+00:00 2023-11-02T06:02:54.932107+00:00 0:00:00.949161 441559 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 4 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T13:00:00+00:00 PythonOperator 2023-11-02T06:02:38.930979+00:00 2023-11-02T06:02:40.972908+00:00 0:00:02.041929 441558 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 4 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T13:00:00+00:00 EmrJobFlowSensor 2023-11-02T05:27:30.626102+00:00 2023-11-02T05:39:32.466985+00:00 0:12:01.840883 441550 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 3 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T22:00:00+00:00 EmrJobFlowSensor 2023-11-02T04:25:04.435794+00:00 2023-11-02T05:24:12.033992+00:00 0:59:07.598198 441535 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T04:24:56.935383+00:00 2023-11-02T04:24:58.052062+00:00 0:00:01.116679 441534 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T22:00:00+00:00 PythonOperator 2023-11-02T04:24:49.722749+00:00 2023-11-02T04:24:51.849474+00:00 0:00:02.126725 441533 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T21:00:00+00:00 EmrJobFlowSensor 2023-11-02T04:17:36.726244+00:00 441532 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T04:17:28.471131+00:00 2023-11-02T04:17:29.607831+00:00 0:00:01.136700 441531 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T21:00:00+00:00 PythonOperator 2023-11-02T04:17:18.440818+00:00 2023-11-02T04:17:20.506246+00:00 0:00:02.065428 441530 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T20:00:00+00:00 EmrJobFlowSensor 2023-11-02T04:07:17.143161+00:00 441529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T04:04:05.702846+00:00 2023-11-02T04:04:06.767145+00:00 0:00:01.064299 441524 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T20:00:00+00:00 PythonOperator 2023-11-02T04:03:49.033136+00:00 2023-11-02T04:03:51.105980+00:00 0:00:02.072844 441523 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T19:00:00+00:00 EmrJobFlowSensor 2023-11-02T03:55:21.032628+00:00 441520 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T03:55:13.383402+00:00 2023-11-02T03:55:14.728422+00:00 0:00:01.345020 441519 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T19:00:00+00:00 PythonOperator 2023-11-02T03:55:05.930581+00:00 2023-11-02T03:55:07.993310+00:00 0:00:02.062729 441518 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T18:00:00+00:00 EmrJobFlowSensor 2023-11-02T03:39:34.350910+00:00 441517 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T03:38:49.011898+00:00 2023-11-02T03:38:49.964880+00:00 0:00:00.952982 441516 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T18:00:00+00:00 PythonOperator 2023-11-02T03:38:41.528971+00:00 2023-11-02T03:38:43.609375+00:00 0:00:02.080404 441515 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T17:00:00+00:00 EmrJobFlowSensor 2023-11-02T03:30:03.067584+00:00 441513 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T03:29:53.893553+00:00 2023-11-02T03:29:55.063264+00:00 0:00:01.169711 441512 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T17:00:00+00:00 PythonOperator 2023-11-02T03:29:43.449830+00:00 2023-11-02T03:29:45.486413+00:00 0:00:02.036583 441511 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T16:00:00+00:00 EmrJobFlowSensor 2023-11-02T03:29:20.368328+00:00 441510 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T03:25:15.068072+00:00 2023-11-02T03:25:16.126982+00:00 0:00:01.058910 441509 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T16:00:00+00:00 PythonOperator 2023-11-02T03:24:49.968959+00:00 2023-11-02T03:24:51.965322+00:00 0:00:01.996363 441508 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T15:00:00+00:00 EmrJobFlowSensor 2023-11-02T03:22:44.917808+00:00 2023-11-02T03:24:45.573181+00:00 0:02:00.655373 441505 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T03:22:25.353730+00:00 2023-11-02T03:22:26.790512+00:00 0:00:01.436782 441504 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T15:00:00+00:00 PythonOperator 2023-11-02T03:22:08.949029+00:00 2023-11-02T03:22:10.867201+00:00 0:00:01.918172 441503 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T14:00:00+00:00 EmrJobFlowSensor 2023-11-02T03:20:25.794659+00:00 441502 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T03:19:22.133449+00:00 2023-11-02T03:19:23.233349+00:00 0:00:01.099900 441501 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T14:00:00+00:00 PythonOperator 2023-11-02T03:19:14.832548+00:00 2023-11-02T03:19:16.950191+00:00 0:00:02.117643 441500 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T12:00:00+00:00 EmrJobFlowSensor 2023-11-02T03:13:23.066994+00:00 441494 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-01T12:17:40.307881+00:00 3 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T03:09:49.218330+00:00 2023-11-02T03:09:50.306936+00:00 0:00:01.088606 441492 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-01T12:17:20.293396+00:00 3 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T12:00:00+00:00 PythonOperator 2023-11-02T03:09:39.026479+00:00 2023-11-02T03:09:41.092814+00:00 0:00:02.066335 441491 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-01T12:16:58.271009+00:00 3 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T10:00:00+00:00 EmrJobFlowSensor 2023-11-02T01:01:31.183566+00:00 441448 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T00:50:36.336673+00:00 2023-11-02T00:50:37.490676+00:00 0:00:01.154003 441445 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T10:00:00+00:00 PythonOperator 2023-11-02T00:50:28.146558+00:00 2023-11-02T00:50:30.315471+00:00 0:00:02.168913 441444 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T09:00:00+00:00 EmrJobFlowSensor 2023-11-02T00:37:58.636781+00:00 441443 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T00:37:38.925206+00:00 2023-11-02T00:37:39.900028+00:00 0:00:00.974822 441442 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T09:00:00+00:00 PythonOperator 2023-11-02T00:37:31.024635+00:00 2023-11-02T00:37:33.070532+00:00 0:00:02.045897 441441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T08:00:00+00:00 EmrJobFlowSensor 2023-11-02T00:30:25.303056+00:00 2023-11-02T00:30:25.769371+00:00 0:00:00.466315 441439 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T23:00:00+00:00 EmrJobFlowSensor 2023-11-02T00:12:18.366493+00:00 2023-11-02T00:36:22.077144+00:00 0:24:03.710651 441433 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T00:12:16.448666+00:00 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T00:11:56.330369+00:00 2023-11-02T00:11:57.491565+00:00 0:00:01.161196 441432 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T00:11:54.430562+00:00 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T23:00:00+00:00 PythonOperator 2023-11-02T00:11:34.638284+00:00 2023-11-02T00:11:36.720443+00:00 0:00:02.082159 441431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T00:11:32.465338+00:00 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-01T23:37:21.925259+00:00 2023-11-01T23:37:22.821267+00:00 0:00:00.896008 441421 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T08:00:00+00:00 PythonOperator 2023-11-01T23:37:09.126890+00:00 2023-11-01T23:37:11.262015+00:00 0:00:02.135125 441420 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-11-01T07:00:00+00:00 EmrJobFlowSensor 2023-11-01T23:35:04.228770+00:00 2023-11-01T23:35:04.731196+00:00 0:00:00.502426 441419 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-11-01T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-01T23:09:51.154987+00:00 2023-11-01T23:09:52.132167+00:00 0:00:00.977180 441414 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-01T23:09:49.054847+00:00 3 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-11-01T07:00:00+00:00 PythonOperator 2023-11-01T23:09:31.153583+00:00 2023-11-01T23:09:33.255689+00:00 0:00:02.102106 441413 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-01T23:09:28.991658+00:00 3 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-10-06T03:17:07.782850+00:00 EmrJobFlowSensor 2023-10-06T03:45:35.753657+00:00 2023-10-06T03:45:36.276905+00:00 0:00:00.523248 431933 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-06T03:45:33.691592+00:00 6 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-09-03T08:00:00+00:00 EmrJobFlowSensor 2023-10-06T03:44:11.869146+00:00 2023-10-06T04:38:19.782242+00:00 0:54:07.913096 431932 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-10-06T03:44:09.507621+00:00 166 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-03T08:00:00+00:00 EmrCreateJobFlowOperator 2023-10-06T03:37:27.294746+00:00 2023-10-06T03:37:28.184015+00:00 0:00:00.889269 431929 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-06T03:37:25.251874+00:00 52 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-03T08:00:00+00:00 PythonOperator 2023-10-06T03:37:05.272659+00:00 2023-10-06T03:37:07.456807+00:00 0:00:02.184148 431927 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-06T03:37:03.230905+00:00 53 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-10-06T03:17:07.782850+00:00 EmrCreateJobFlowOperator 2023-10-06T03:17:52.753644+00:00 2023-10-06T03:17:53.761580+00:00 0:00:01.007936 431922 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-10-06T03:17:50.692507+00:00 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-10-06T03:17:07.782850+00:00 PythonOperator 2023-10-06T03:17:32.777550+00:00 2023-10-06T03:17:34.855514+00:00 0:00:02.077964 431921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-10-06T03:17:30.605798+00:00 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-09-19T03:17:06.816888+00:00 EmrJobFlowSensor 2023-09-19T03:18:46.873971+00:00 2023-09-19T03:19:47.679143+00:00 0:01:00.805172 425458 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-19T03:18:44.845543+00:00 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-19T03:17:06.816888+00:00 EmrCreateJobFlowOperator 2023-09-19T03:18:26.952882+00:00 2023-09-19T03:18:27.927507+00:00 0:00:00.974625 425457 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-19T03:18:24.829641+00:00 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-19T03:17:06.816888+00:00 PythonOperator 2023-09-19T03:17:26.997505+00:00 2023-09-19T03:17:29.185308+00:00 0:00:02.187803 425455 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-19T03:17:24.810208+00:00 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-18T15:14:58.031002+00:00 PythonOperator 2023-09-18T15:15:16.209747+00:00 2023-09-18T15:15:18.207452+00:00 0:00:01.997705 425225 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-18T15:15:13.999943+00:00 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-18T07:28:27.619898+00:00 EmrCreateJobFlowOperator 2023-09-18T15:14:11.846884+00:00 2023-09-18T15:14:12.842490+00:00 0:00:00.995606 425224 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-18T15:14:09.884276+00:00 3 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-18T07:28:27.619898+00:00 PythonOperator 2023-09-18T15:13:51.984715+00:00 2023-09-18T15:13:53.936663+00:00 0:00:01.951948 425223 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-18T15:13:49.867062+00:00 3 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-09-18T07:28:27.619898+00:00 EmrJobFlowSensor 2023-09-18T07:48:11.850668+00:00 2023-09-18T07:48:12.356439+00:00 0:00:00.505771 425112 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-18T07:48:09.693147+00:00 6 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-09-07T11:00:00+00:00 EmrJobFlowSensor 2023-09-11T03:03:39.911061+00:00 2023-09-11T03:04:40.440452+00:00 0:01:00.529391 422387 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-07T11:00:00+00:00 EmrCreateJobFlowOperator 2023-09-11T03:03:34.005048+00:00 2023-09-11T03:03:35.121285+00:00 0:00:01.116237 422386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-07T11:00:00+00:00 PythonOperator 2023-09-11T03:03:20.776644+00:00 2023-09-11T03:03:22.582640+00:00 0:00:01.805996 422385 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-09-02T01:00:00+00:00 EmrJobFlowSensor 2023-09-11T03:02:57.005363+00:00 2023-09-11T03:02:57.563110+00:00 0:00:00.557747 422383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-09-01T00:00:00+00:00 EmrJobFlowSensor 2023-09-11T03:02:42.514322+00:00 2023-09-11T03:02:42.926946+00:00 0:00:00.412624 422382 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-02T01:00:00+00:00 EmrCreateJobFlowOperator 2023-09-11T02:05:47.756606+00:00 2023-09-11T02:05:48.686252+00:00 0:00:00.929646 422364 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-02T01:00:00+00:00 PythonOperator 2023-09-11T02:05:23.753713+00:00 2023-09-11T02:05:25.618419+00:00 0:00:01.864706 422363 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-01T00:00:00+00:00 EmrCreateJobFlowOperator 2023-09-11T01:29:56.627951+00:00 2023-09-11T01:29:57.958031+00:00 0:00:01.330080 422347 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-01T00:00:00+00:00 PythonOperator 2023-09-11T01:29:42.624460+00:00 2023-09-11T01:29:45.073616+00:00 0:00:02.449156 422346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-11T01:28:53.530463+00:00 PythonOperator 2023-09-11T01:29:00.323419+00:00 2023-09-11T01:29:02.210042+00:00 0:00:01.886623 422345 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-11T01:28:58.267477+00:00 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-10T02:59:21.796553+00:00 EmrCreateJobFlowOperator 2023-09-10T03:00:03.402629+00:00 2023-09-10T03:00:04.375880+00:00 0:00:00.973251 422005 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-10T03:00:00.622180+00:00 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-10T02:59:21.796553+00:00 PythonOperator 2023-09-10T02:59:42.641727+00:00 2023-09-10T02:59:44.491107+00:00 0:00:01.849380 422004 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-10T02:59:40.572145+00:00 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2022-03-10T09:00:00+00:00 EmrJobFlowSensor 2023-09-10T02:59:08.331877+00:00 2023-09-10T02:59:08.851374+00:00 0:00:00.519497 422003 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2022-03-10T09:00:00+00:00 EmrCreateJobFlowOperator 2023-09-10T02:26:59.988020+00:00 2023-09-10T02:27:00.979244+00:00 0:00:00.991224 421995 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2022-03-10T09:00:00+00:00 PythonOperator 2023-09-10T02:26:39.748346+00:00 2023-09-10T02:26:41.582756+00:00 0:00:01.834410 421994 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v002 check_cluster_status 2023-09-08T14:44:06.455528+00:00 EmrJobFlowSensor 2023-09-08T14:45:28.789185+00:00 2023-09-08T14:46:29.654769+00:00 0:01:00.865584 421457 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-09-08T14:45:26.053511+00:00 2 default_pool
success exchange-trade-summary_v002 create_cluster_and_add_emr_steps 2023-09-08T14:44:06.455528+00:00 EmrCreateJobFlowOperator 2023-09-08T14:45:06.198478+00:00 2023-09-08T14:45:07.196140+00:00 0:00:00.997662 421456 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-09-08T14:45:04.034250+00:00 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-08T14:44:06.455528+00:00 PythonOperator 2023-09-08T14:44:46.132053+00:00 2023-09-08T14:44:47.962674+00:00 0:00:01.830621 421455 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-08T14:44:44.015480+00:00 2 default_pool
success exchange-trade-summary_v002 create_emr_steps 2023-09-07T11:39:28.805545+00:00 PythonOperator 2023-09-08T14:28:37.882019+00:00 2023-09-08T14:28:39.838946+00:00 0:00:01.956927 421451 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-09-08T14:28:35.976733+00:00 14 default_pool