Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T20:00:00+00:00 PythonOperator 2023-12-08T21:00:05.250213+00:00 2023-12-08T21:00:07.115391+00:00 0:00:01.865178 454167 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T21:00:03.068806+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T19:00:00+00:00 EmrJobFlowSensor 2023-12-08T20:00:54.968309+00:00 2023-12-08T20:28:59.080462+00:00 0:28:04.112153 454150 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T20:00:53.041505+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T20:00:32.871156+00:00 2023-12-08T20:00:34.164920+00:00 0:00:01.293764 454148 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T20:00:31.077091+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T19:00:00+00:00 PythonOperator 2023-12-08T20:00:12.877434+00:00 2023-12-08T20:00:14.505816+00:00 0:00:01.628382 454146 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T20:00:11.067714+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T18:00:00+00:00 EmrJobFlowSensor 2023-12-08T19:00:48.258811+00:00 2023-12-08T19:28:52.377277+00:00 0:28:04.118466 454127 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T19:00:46.372400+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T19:00:26.350636+00:00 2023-12-08T19:00:27.355453+00:00 0:00:01.004817 454125 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T19:00:24.349615+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T18:00:00+00:00 PythonOperator 2023-12-08T19:00:04.730108+00:00 2023-12-08T19:00:06.728869+00:00 0:00:01.998761 454123 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T19:00:02.399847+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T17:00:00+00:00 EmrJobFlowSensor 2023-12-08T18:06:39.787125+00:00 2023-12-08T18:33:43.794497+00:00 0:27:04.007372 454110 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T18:06:37.790176+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T18:06:19.745522+00:00 2023-12-08T18:06:20.659725+00:00 0:00:00.914203 454107 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T18:06:17.772346+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T17:00:00+00:00 PythonOperator 2023-12-08T18:05:57.657571+00:00 2023-12-08T18:05:59.321511+00:00 0:00:01.663940 454104 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T18:05:55.750935+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T16:00:00+00:00 EmrJobFlowSensor 2023-12-08T17:01:27.561038+00:00 2023-12-08T17:24:31.283103+00:00 0:23:03.722065 454085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T17:01:25.673110+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T17:01:05.494640+00:00 2023-12-08T17:01:06.629180+00:00 0:00:01.134540 454083 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T17:01:03.652509+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T16:00:00+00:00 PythonOperator 2023-12-08T17:00:45.330792+00:00 2023-12-08T17:00:47.070761+00:00 0:00:01.739969 454081 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T17:00:43.633115+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T15:00:00+00:00 EmrJobFlowSensor 2023-12-08T16:02:39.989892+00:00 2023-12-08T16:25:43.560295+00:00 0:23:03.570403 454064 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T16:02:38.131228+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T16:02:17.761436+00:00 2023-12-08T16:02:18.787363+00:00 0:00:01.025927 454062 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T16:02:16.111724+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T15:00:00+00:00 PythonOperator 2023-12-08T16:01:57.999463+00:00 2023-12-08T16:01:59.667690+00:00 0:00:01.668227 454060 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T16:01:56.090040+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T14:00:00+00:00 EmrJobFlowSensor 2023-12-08T15:04:55.717790+00:00 2023-12-08T15:29:59.475698+00:00 0:25:03.757908 454043 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T15:04:53.953418+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T15:04:35.899540+00:00 2023-12-08T15:04:36.929318+00:00 0:00:01.029778 454041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T15:04:33.935303+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T14:00:00+00:00 PythonOperator 2023-12-08T15:04:13.929577+00:00 2023-12-08T15:04:15.560894+00:00 0:00:01.631317 454039 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T15:04:11.915593+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T13:00:00+00:00 EmrJobFlowSensor 2023-12-08T14:00:49.498616+00:00 2023-12-08T14:25:53.377664+00:00 0:25:03.879048 454022 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T14:00:47.489507+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T14:00:27.770605+00:00 2023-12-08T14:00:28.847337+00:00 0:00:01.076732 454020 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T14:00:25.410236+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T13:00:00+00:00 PythonOperator 2023-12-08T14:00:07.311375+00:00 2023-12-08T14:00:08.941451+00:00 0:00:01.630076 454018 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T14:00:05.391821+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T12:00:00+00:00 EmrJobFlowSensor 2023-12-08T13:04:48.953145+00:00 2023-12-08T13:29:52.548194+00:00 0:25:03.595049 454003 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T13:04:47.328629+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T13:04:29.377611+00:00 2023-12-08T13:04:30.224099+00:00 0:00:00.846488 454002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T13:04:27.312720+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T12:00:00+00:00 PythonOperator 2023-12-08T13:00:08.394103+00:00 2023-12-08T13:00:10.083249+00:00 0:00:01.689146 453997 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T13:00:06.242945+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T11:00:00+00:00 EmrJobFlowSensor 2023-12-08T12:41:15.567638+00:00 2023-12-08T13:03:18.989846+00:00 0:22:03.422208 453993 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T12:41:13.876773+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T12:40:53.666021+00:00 2023-12-08T12:40:54.676530+00:00 0:00:01.010509 453992 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T12:40:51.859508+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T11:00:00+00:00 PythonOperator 2023-12-08T12:17:10.446287+00:00 2023-12-08T12:17:12.145706+00:00 0:00:01.699419 453986 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T12:17:08.513754+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T10:00:00+00:00 EmrJobFlowSensor 2023-12-08T12:17:10.154457+00:00 2023-12-08T12:40:13.737582+00:00 0:23:03.583125 453985 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T12:17:08.513730+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T12:16:48.149097+00:00 2023-12-08T12:16:49.121521+00:00 0:00:00.972424 453983 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T12:16:46.468991+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T09:00:00+00:00 EmrJobFlowSensor 2023-12-08T11:54:41.549842+00:00 2023-12-08T12:16:44.866108+00:00 0:22:03.316266 453970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T11:54:39.569854+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T10:00:00+00:00 PythonOperator 2023-12-08T11:54:41.353975+00:00 2023-12-08T11:54:43.063674+00:00 0:00:01.709699 453969 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T11:54:39.569892+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T11:54:21.772503+00:00 2023-12-08T11:54:22.841119+00:00 0:00:01.068616 453968 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T11:54:19.420802+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T08:00:00+00:00 EmrJobFlowSensor 2023-12-08T10:28:05.390418+00:00 2023-12-08T11:54:17.619917+00:00 1:26:12.229499 453950 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T10:28:03.275266+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T09:00:00+00:00 PythonOperator 2023-12-08T10:28:04.939190+00:00 2023-12-08T10:28:06.853492+00:00 0:00:01.914302 453949 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T10:28:03.275291+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T10:27:45.074277+00:00 2023-12-08T10:27:46.054632+00:00 0:00:00.980355 453948 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T10:27:43.259096+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T08:00:00+00:00 PythonOperator 2023-12-08T09:00:06.055551+00:00 2023-12-08T09:00:07.806566+00:00 0:00:01.751015 453920 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T09:00:03.595202+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T07:00:00+00:00 EmrJobFlowSensor 2023-12-08T08:41:07.887145+00:00 2023-12-08T10:27:22.452945+00:00 1:46:14.565800 453917 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T08:41:06.204929+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T08:40:46.298272+00:00 2023-12-08T08:40:47.204777+00:00 0:00:00.906505 453916 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T08:40:44.198190+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T07:00:00+00:00 PythonOperator 2023-12-08T08:00:06.084607+00:00 2023-12-08T08:00:09.195496+00:00 0:00:03.110889 453902 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T08:00:03.182095+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T06:00:00+00:00 EmrJobFlowSensor 2023-12-08T07:01:22.790883+00:00 2023-12-08T08:40:36.704759+00:00 1:39:13.913876 453889 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T07:01:20.813086+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T07:01:02.456820+00:00 2023-12-08T07:01:03.541703+00:00 0:00:01.084883 453888 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T07:01:00.792876+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T06:00:00+00:00 PythonOperator 2023-12-08T07:00:40.890270+00:00 2023-12-08T07:00:42.531115+00:00 0:00:01.640845 453886 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T07:00:38.777173+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T05:00:00+00:00 EmrJobFlowSensor 2023-12-08T06:00:53.432356+00:00 2023-12-08T06:24:57.081312+00:00 0:24:03.648956 453872 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T06:00:51.817760+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T06:00:33.453572+00:00 2023-12-08T06:00:34.406206+00:00 0:00:00.952634 453871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T06:00:31.785944+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T05:00:00+00:00 PythonOperator 2023-12-08T06:00:11.891758+00:00 2023-12-08T06:00:13.565701+00:00 0:00:01.673943 453869 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T06:00:09.767381+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T04:00:00+00:00 EmrJobFlowSensor 2023-12-08T05:01:01.476954+00:00 2023-12-08T05:23:05.049250+00:00 0:22:03.572296 453853 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T05:00:59.580861+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T05:00:39.248537+00:00 2023-12-08T05:00:40.434588+00:00 0:00:01.186051 453852 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T05:00:37.564996+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T04:00:00+00:00 PythonOperator 2023-12-08T05:00:19.636059+00:00 2023-12-08T05:00:21.270282+00:00 0:00:01.634223 453850 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T05:00:17.545248+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T03:00:00+00:00 EmrJobFlowSensor 2023-12-08T04:00:49.834173+00:00 2023-12-08T04:22:53.209360+00:00 0:22:03.375187 453833 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T04:00:47.785740+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T04:00:27.646006+00:00 2023-12-08T04:00:28.591820+00:00 0:00:00.945814 453831 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T04:00:25.710910+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T03:00:00+00:00 PythonOperator 2023-12-08T04:00:07.592368+00:00 2023-12-08T04:00:09.236546+00:00 0:00:01.644178 453828 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T04:00:05.696238+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T02:00:00+00:00 EmrJobFlowSensor 2023-12-08T03:00:59.837549+00:00 2023-12-08T03:23:03.361557+00:00 0:22:03.524008 453812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T03:00:57.906541+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T03:00:39.830230+00:00 2023-12-08T03:00:40.780821+00:00 0:00:00.950591 453811 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T03:00:37.884527+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T02:00:00+00:00 PythonOperator 2023-12-08T03:00:18.447638+00:00 2023-12-08T03:00:20.133903+00:00 0:00:01.686265 453810 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T03:00:15.867526+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T01:00:00+00:00 EmrJobFlowSensor 2023-12-08T02:01:03.371943+00:00 2023-12-08T02:23:06.724541+00:00 0:22:03.352598 453793 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T02:01:01.449812+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T02:00:43.536228+00:00 2023-12-08T02:00:44.457319+00:00 0:00:00.921091 453792 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T02:00:41.427615+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T01:00:00+00:00 PythonOperator 2023-12-08T02:00:21.063085+00:00 2023-12-08T02:00:22.818262+00:00 0:00:01.755177 453791 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T02:00:19.406597+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T00:00:00+00:00 EmrJobFlowSensor 2023-12-08T01:00:55.929264+00:00 2023-12-08T01:22:59.714627+00:00 0:22:03.785363 453768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T01:00:53.782602+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T01:00:33.475776+00:00 2023-12-08T01:00:34.543621+00:00 0:00:01.067845 453767 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T01:00:31.699898+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T00:00:00+00:00 PythonOperator 2023-12-08T01:00:13.465058+00:00 2023-12-08T01:00:15.362191+00:00 0:00:01.897133 453765 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T01:00:11.666526+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T23:00:00+00:00 EmrJobFlowSensor 2023-12-08T00:00:48.275595+00:00 2023-12-08T00:22:51.625574+00:00 0:22:03.349979 453747 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T00:00:46.282968+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T00:00:28.213279+00:00 2023-12-08T00:00:29.115023+00:00 0:00:00.901744 453745 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T00:00:26.176603+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T23:00:00+00:00 PythonOperator 2023-12-08T00:00:05.920200+00:00 2023-12-08T00:00:07.637920+00:00 0:00:01.717720 453743 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T00:00:04.127365+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T22:00:00+00:00 EmrJobFlowSensor 2023-12-07T23:00:55.395748+00:00 2023-12-07T23:22:58.770955+00:00 0:22:03.375207 453726 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T23:00:53.412543+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T23:00:33.470759+00:00 2023-12-07T23:00:34.582529+00:00 0:00:01.111770 453723 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T23:00:31.325195+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T22:00:00+00:00 PythonOperator 2023-12-07T23:00:13.663975+00:00 2023-12-07T23:00:15.639534+00:00 0:00:01.975559 453720 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T23:00:11.303698+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T21:00:00+00:00 EmrJobFlowSensor 2023-12-07T22:01:02.460965+00:00 2023-12-07T22:24:06.247149+00:00 0:23:03.786184 453700 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T22:01:00.302301+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T22:00:42.261233+00:00 2023-12-07T22:00:43.577576+00:00 0:00:01.316343 453698 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T22:00:40.234433+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T21:00:00+00:00 PythonOperator 2023-12-07T22:00:20.393695+00:00 2023-12-07T22:00:23.225635+00:00 0:00:02.831940 453696 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T22:00:18.223135+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T20:00:00+00:00 EmrJobFlowSensor 2023-12-07T21:01:05.167984+00:00 2023-12-07T21:26:09.151100+00:00 0:25:03.983116 453678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T21:01:03.227471+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T21:00:45.285719+00:00 2023-12-07T21:00:46.544362+00:00 0:00:01.258643 453676 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T21:00:43.210393+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T20:00:00+00:00 PythonOperator 2023-12-07T21:00:23.221326+00:00 2023-12-07T21:00:25.214262+00:00 0:00:01.992936 453674 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T21:00:21.172819+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T19:00:00+00:00 EmrJobFlowSensor 2023-12-07T20:01:21.931189+00:00 2023-12-07T20:28:26.003609+00:00 0:27:04.072420 453656 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T20:01:19.396254+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T20:00:44.276323+00:00 2023-12-07T20:00:45.396907+00:00 0:00:01.120584 453653 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T20:00:42.315758+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T19:00:00+00:00 PythonOperator 2023-12-07T20:00:23.995055+00:00 2023-12-07T20:00:25.685771+00:00 0:00:01.690716 453651 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T20:00:22.299499+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T18:00:00+00:00 EmrJobFlowSensor 2023-12-07T19:00:58.689471+00:00 2023-12-07T19:29:03.193772+00:00 0:28:04.504301 453633 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T19:00:56.668943+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T19:00:38.348889+00:00 2023-12-07T19:00:39.339170+00:00 0:00:00.990281 453631 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T19:00:36.654065+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T18:00:00+00:00 PythonOperator 2023-12-07T19:00:16.377337+00:00 2023-12-07T19:00:18.008385+00:00 0:00:01.631048 453629 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T19:00:14.585445+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T17:00:00+00:00 EmrJobFlowSensor 2023-12-07T18:00:55.171360+00:00 2023-12-07T18:26:59.044170+00:00 0:26:03.872810 453610 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T18:00:53.066197+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T18:00:33.182110+00:00 2023-12-07T18:00:34.250677+00:00 0:00:01.068567 453608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T18:00:31.059981+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T17:00:00+00:00 PythonOperator 2023-12-07T18:00:13.097935+00:00 2023-12-07T18:00:15.051622+00:00 0:00:01.953687 453606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T18:00:10.974164+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T16:00:00+00:00 EmrJobFlowSensor 2023-12-07T17:32:34.775523+00:00 2023-12-07T17:56:38.534962+00:00 0:24:03.759439 453602 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T17:32:32.773593+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T17:32:14.908645+00:00 2023-12-07T17:32:15.960356+00:00 0:00:01.051711 453601 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T17:32:12.757941+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T15:00:00+00:00 EmrJobFlowSensor 2023-12-07T17:08:48.278156+00:00 2023-12-07T17:31:51.805478+00:00 0:23:03.527322 453593 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T17:08:46.247776+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T16:00:00+00:00 PythonOperator 2023-12-07T17:08:47.938861+00:00 2023-12-07T17:08:49.625968+00:00 0:00:01.687107 453592 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T17:08:46.247803+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T17:08:26.070717+00:00 2023-12-07T17:08:27.127888+00:00 0:00:01.057171 453591 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T17:08:24.287221+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T14:00:00+00:00 EmrJobFlowSensor 2023-12-07T16:43:04.899213+00:00 2023-12-07T17:08:09.047096+00:00 0:25:04.147883 453579 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T16:43:02.855724+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T15:00:00+00:00 PythonOperator 2023-12-07T16:43:04.559185+00:00 2023-12-07T16:43:06.274051+00:00 0:00:01.714866 453578 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T16:43:02.855750+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T16:42:42.571574+00:00 2023-12-07T16:42:43.591853+00:00 0:00:01.020279 453577 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T16:42:40.835409+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T13:00:00+00:00 EmrJobFlowSensor 2023-12-07T16:19:27.372884+00:00 2023-12-07T16:42:30.977213+00:00 0:23:03.604329 453574 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T16:19:25.367204+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T14:00:00+00:00 PythonOperator 2023-12-07T16:19:27.064403+00:00 2023-12-07T16:19:28.704670+00:00 0:00:01.640267 453573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T16:19:25.367232+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T16:19:05.491773+00:00 2023-12-07T16:19:06.673867+00:00 0:00:01.182094 453572 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T16:19:03.348341+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T12:00:00+00:00 EmrJobFlowSensor 2023-12-07T15:53:40.599943+00:00 2023-12-07T16:18:44.464725+00:00 0:25:03.864782 453558 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T15:53:38.589962+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T13:00:00+00:00 PythonOperator 2023-12-07T15:53:40.239086+00:00 2023-12-07T15:53:41.998661+00:00 0:00:01.759575 453557 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T15:53:38.589990+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T15:53:18.354786+00:00 2023-12-07T15:53:19.311214+00:00 0:00:00.956428 453556 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T15:53:16.572562+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T12:00:00+00:00 PythonOperator 2023-12-07T15:31:00.826753+00:00 2023-12-07T15:31:02.781585+00:00 0:00:01.954832 453552 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T15:30:58.687230+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T11:00:00+00:00 EmrJobFlowSensor 2023-12-07T15:31:00.459269+00:00 2023-12-07T15:53:03.901938+00:00 0:22:03.442669 453551 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T15:30:58.687202+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T15:30:38.388242+00:00 2023-12-07T15:30:39.419665+00:00 0:00:01.031423 453550 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T15:30:36.616948+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T11:00:00+00:00 PythonOperator 2023-12-07T15:04:12.596857+00:00 2023-12-07T15:04:14.524790+00:00 0:00:01.927933 453539 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T15:04:10.584372+00:00 2 default_pool