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-11-13T12:00:00+00:00 PythonOperator 2023-11-13T13:00:20.257181+00:00 2023-11-13T13:00:22.653825+00:00 0:00:02.396644 446052 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T13:00:18.101027+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T11:00:00+00:00 EmrJobFlowSensor 2023-11-13T12:00:54.059031+00:00 2023-11-13T12:25:57.809330+00:00 0:25:03.750299 446042 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T12:00:51.993607+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T12:00:33.977353+00:00 2023-11-13T12:00:34.959310+00:00 0:00:00.981957 446041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T12:00:31.975727+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T11:00:00+00:00 PythonOperator 2023-11-13T12:00:12.395796+00:00 2023-11-13T12:00:14.590100+00:00 0:00:02.194304 446040 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T12:00:09.953921+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T10:00:00+00:00 EmrJobFlowSensor 2023-11-13T11:00:57.040804+00:00 2023-11-13T11:26:00.787405+00:00 0:25:03.746601 446029 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T11:00:55.125952+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T11:00:35.047776+00:00 2023-11-13T11:00:36.185780+00:00 0:00:01.138004 446028 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T11:00:33.104131+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T10:00:00+00:00 PythonOperator 2023-11-13T11:00:15.248624+00:00 2023-11-13T11:00:17.895442+00:00 0:00:02.646818 446027 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T11:00:13.087715+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T09:00:00+00:00 EmrJobFlowSensor 2023-11-13T10:00:47.783033+00:00 2023-11-13T10:26:51.857133+00:00 0:26:04.074100 446016 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T10:00:45.777091+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T10:00:25.653802+00:00 2023-11-13T10:00:26.791156+00:00 0:00:01.137354 446015 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T10:00:23.754801+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T09:00:00+00:00 PythonOperator 2023-11-13T10:00:06.011887+00:00 2023-11-13T10:00:08.258049+00:00 0:00:02.246162 446014 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T10:00:03.737710+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T08:00:00+00:00 EmrJobFlowSensor 2023-11-13T09:01:03.079788+00:00 2023-11-13T09:27:07.607841+00:00 0:26:04.528053 446002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T09:01:01.056653+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T09:00:43.157276+00:00 2023-11-13T09:00:44.034654+00:00 0:00:00.877378 446001 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T09:00:40.986344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T08:00:00+00:00 PythonOperator 2023-11-13T09:00:21.142269+00:00 2023-11-13T09:00:23.290042+00:00 0:00:02.147773 446000 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T09:00:18.978604+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T07:00:00+00:00 EmrJobFlowSensor 2023-11-13T08:07:04.687343+00:00 2023-11-13T08:33:08.686118+00:00 0:26:03.998775 445992 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T08:07:02.717082+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T08:06:42.654843+00:00 2023-11-13T08:06:43.745685+00:00 0:00:01.090842 445990 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T08:06:40.698245+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T07:00:00+00:00 PythonOperator 2023-11-13T08:06:22.972743+00:00 2023-11-13T08:06:25.113031+00:00 0:00:02.140288 445988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T08:06:20.729399+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T06:00:00+00:00 EmrJobFlowSensor 2023-11-13T07:00:57.871734+00:00 2023-11-13T07:28:01.831012+00:00 0:27:03.959278 445978 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T07:00:55.784596+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T07:00:37.751421+00:00 2023-11-13T07:00:38.729784+00:00 0:00:00.978363 445977 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T07:00:35.752113+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T06:00:00+00:00 PythonOperator 2023-11-13T07:00:15.895731+00:00 2023-11-13T07:00:18.095121+00:00 0:00:02.199390 445976 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T07:00:13.730139+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T05:00:00+00:00 EmrJobFlowSensor 2023-11-13T06:01:04.945825+00:00 2023-11-13T06:27:09.050536+00:00 0:26:04.104711 445965 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T06:01:02.965282+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T06:00:44.967080+00:00 2023-11-13T06:00:46.032986+00:00 0:00:01.065906 445964 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T06:00:42.887367+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T05:00:00+00:00 PythonOperator 2023-11-13T06:00:22.878921+00:00 2023-11-13T06:00:25.050147+00:00 0:00:02.171226 445963 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T06:00:20.815827+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T04:00:00+00:00 EmrJobFlowSensor 2023-11-13T05:03:57.128792+00:00 2023-11-13T05:29:01.048417+00:00 0:25:03.919625 445953 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T05:03:55.237646+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T05:03:35.154170+00:00 2023-11-13T05:03:36.137564+00:00 0:00:00.983394 445952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T05:03:33.217165+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T04:00:00+00:00 PythonOperator 2023-11-13T05:03:15.255193+00:00 2023-11-13T05:03:17.420346+00:00 0:00:02.165153 445951 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T05:03:13.199606+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T03:00:00+00:00 EmrJobFlowSensor 2023-11-13T04:07:42.440808+00:00 2023-11-13T04:32:46.381201+00:00 0:25:03.940393 445942 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T04:07:40.514218+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T04:07:22.465316+00:00 2023-11-13T04:07:23.757297+00:00 0:00:01.291981 445939 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T04:07:20.490883+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T03:00:00+00:00 PythonOperator 2023-11-13T04:07:00.690732+00:00 2023-11-13T04:07:03.878228+00:00 0:00:03.187496 445936 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T04:06:58.518744+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T02:00:00+00:00 EmrJobFlowSensor 2023-11-13T03:05:43.364650+00:00 2023-11-13T03:30:47.080971+00:00 0:25:03.716321 445928 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T03:05:41.186822+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T03:05:21.756683+00:00 2023-11-13T03:05:22.780524+00:00 0:00:01.023841 445926 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T03:05:19.167770+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T02:00:00+00:00 PythonOperator 2023-11-13T03:05:02.146408+00:00 2023-11-13T03:05:04.367345+00:00 0:00:02.220937 445924 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T03:04:59.147760+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T01:00:00+00:00 EmrJobFlowSensor 2023-11-13T02:01:10.767072+00:00 2023-11-13T02:26:14.464090+00:00 0:25:03.697018 445914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T02:01:08.429898+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T02:00:31.935226+00:00 2023-11-13T02:00:32.914545+00:00 0:00:00.979319 445912 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T02:00:29.878044+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T01:00:00+00:00 PythonOperator 2023-11-13T02:00:10.605069+00:00 2023-11-13T02:00:12.825898+00:00 0:00:02.220829 445911 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T02:00:07.801959+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-13T00:00:00+00:00 EmrJobFlowSensor 2023-11-13T01:01:22.648262+00:00 2023-11-13T01:25:26.359150+00:00 0:24:03.710888 445894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T01:01:20.355352+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-13T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T01:00:37.376389+00:00 2023-11-13T01:00:38.377623+00:00 0:00:01.001234 445892 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T01:00:35.341159+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-13T00:00:00+00:00 PythonOperator 2023-11-13T01:00:17.582229+00:00 2023-11-13T01:00:19.777167+00:00 0:00:02.194938 445891 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T01:00:15.321832+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T23:00:00+00:00 EmrJobFlowSensor 2023-11-13T00:00:54.750343+00:00 2023-11-13T00:26:58.732167+00:00 0:26:03.981824 445880 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-13T00:00:52.792163+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-13T00:00:32.735938+00:00 2023-11-13T00:00:33.729786+00:00 0:00:00.993848 445879 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-13T00:00:30.760402+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T23:00:00+00:00 PythonOperator 2023-11-13T00:00:12.771779+00:00 2023-11-13T00:00:14.949368+00:00 0:00:02.177589 445878 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-13T00:00:10.743864+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T22:00:00+00:00 EmrJobFlowSensor 2023-11-12T23:01:00.869965+00:00 2023-11-12T23:27:05.084966+00:00 0:26:04.215001 445866 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T23:00:57.215900+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T23:00:37.142017+00:00 2023-11-12T23:00:38.371412+00:00 0:00:01.229395 445863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T23:00:35.191855+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T22:00:00+00:00 PythonOperator 2023-11-12T23:00:18.870483+00:00 2023-11-12T23:00:21.204141+00:00 0:00:02.333658 445862 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T23:00:15.175967+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T21:00:00+00:00 EmrJobFlowSensor 2023-11-12T22:00:57.961890+00:00 2023-11-12T22:24:01.418644+00:00 0:23:03.456754 445849 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T22:00:56.018575+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T22:00:35.987556+00:00 2023-11-12T22:00:37.052930+00:00 0:00:01.065374 445848 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T22:00:33.999473+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T21:00:00+00:00 PythonOperator 2023-11-12T22:00:16.086230+00:00 2023-11-12T22:00:18.393752+00:00 0:00:02.307522 445847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T22:00:13.982902+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T20:00:00+00:00 EmrJobFlowSensor 2023-11-12T21:00:49.041442+00:00 2023-11-12T21:25:52.690735+00:00 0:25:03.649293 445835 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T21:00:47.091767+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T21:00:29.058147+00:00 2023-11-12T21:00:30.152347+00:00 0:00:01.094200 445834 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T21:00:27.070721+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T20:00:00+00:00 PythonOperator 2023-11-12T21:00:07.071326+00:00 2023-11-12T21:00:09.237295+00:00 0:00:02.165969 445833 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T21:00:05.056256+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T19:00:00+00:00 EmrJobFlowSensor 2023-11-12T20:01:05.456001+00:00 2023-11-12T20:27:09.627096+00:00 0:26:04.171095 445821 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T20:01:03.380410+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T20:00:45.298845+00:00 2023-11-12T20:00:46.393995+00:00 0:00:01.095150 445820 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T20:00:43.309191+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T19:00:00+00:00 PythonOperator 2023-11-12T20:00:23.394059+00:00 2023-11-12T20:00:25.533052+00:00 0:00:02.138993 445819 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T20:00:21.289827+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T18:00:00+00:00 EmrJobFlowSensor 2023-11-12T19:00:58.063999+00:00 2023-11-12T19:27:01.900785+00:00 0:26:03.836786 445807 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T19:00:56.106292+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T19:00:36.102963+00:00 2023-11-12T19:00:37.058434+00:00 0:00:00.955471 445806 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T19:00:34.082981+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T18:00:00+00:00 PythonOperator 2023-11-12T19:00:16.165046+00:00 2023-11-12T19:00:18.350496+00:00 0:00:02.185450 445805 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T19:00:14.065240+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T17:00:00+00:00 EmrJobFlowSensor 2023-11-12T18:00:47.411299+00:00 2023-11-12T18:26:51.300544+00:00 0:26:03.889245 445794 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T18:00:45.446390+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T18:00:25.426220+00:00 2023-11-12T18:00:26.434249+00:00 0:00:01.008029 445793 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T18:00:23.425204+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T17:00:00+00:00 PythonOperator 2023-11-12T18:00:05.584246+00:00 2023-11-12T18:00:07.802505+00:00 0:00:02.218259 445792 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T18:00:03.406198+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T16:00:00+00:00 EmrJobFlowSensor 2023-11-12T17:01:05.467830+00:00 2023-11-12T17:26:09.173274+00:00 0:25:03.705444 445781 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T17:01:03.402364+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T17:00:43.456711+00:00 2023-11-12T17:00:44.511349+00:00 0:00:01.054638 445780 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T17:00:41.390060+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T16:00:00+00:00 PythonOperator 2023-11-12T17:00:21.568734+00:00 2023-11-12T17:00:23.833926+00:00 0:00:02.265192 445779 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T17:00:19.378171+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T15:00:00+00:00 EmrJobFlowSensor 2023-11-12T16:01:05.630095+00:00 2023-11-12T16:26:09.766499+00:00 0:25:04.136404 445769 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T16:01:03.378016+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T16:00:43.259989+00:00 2023-11-12T16:00:44.206381+00:00 0:00:00.946392 445768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T16:00:41.309344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T15:00:00+00:00 PythonOperator 2023-11-12T16:00:23.476902+00:00 2023-11-12T16:00:25.701687+00:00 0:00:02.224785 445767 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T16:00:21.290836+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T14:00:00+00:00 EmrJobFlowSensor 2023-11-12T15:01:01.955978+00:00 2023-11-12T15:26:05.871812+00:00 0:25:03.915834 445755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T15:00:59.998940+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T15:00:39.947140+00:00 2023-11-12T15:00:41.058630+00:00 0:00:01.111490 445754 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T15:00:37.988024+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T14:00:00+00:00 PythonOperator 2023-11-12T15:00:20.058258+00:00 2023-11-12T15:00:22.244565+00:00 0:00:02.186307 445753 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T15:00:17.964312+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T13:00:00+00:00 EmrJobFlowSensor 2023-11-12T14:01:53.559665+00:00 2023-11-12T14:27:57.389895+00:00 0:26:03.830230 445743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T14:01:51.590332+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T14:01:33.554738+00:00 2023-11-12T14:01:34.665018+00:00 0:00:01.110280 445742 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T14:01:31.571654+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T13:00:00+00:00 PythonOperator 2023-11-12T14:01:11.653845+00:00 2023-11-12T14:01:13.822557+00:00 0:00:02.168712 445741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T14:01:09.552240+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T12:00:00+00:00 EmrJobFlowSensor 2023-11-12T13:01:02.779318+00:00 2023-11-12T13:26:06.713683+00:00 0:25:03.934365 445729 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T13:01:00.694763+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T13:00:42.664418+00:00 2023-11-12T13:00:43.684422+00:00 0:00:01.020004 445728 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T13:00:40.686735+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T12:00:00+00:00 PythonOperator 2023-11-12T13:00:20.885537+00:00 2023-11-12T13:00:23.039456+00:00 0:00:02.153919 445727 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T13:00:18.596422+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T11:00:00+00:00 EmrJobFlowSensor 2023-11-12T12:00:45.646756+00:00 2023-11-12T12:25:49.369741+00:00 0:25:03.722985 445716 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T12:00:43.667497+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T12:00:25.650460+00:00 2023-11-12T12:00:26.700154+00:00 0:00:01.049694 445715 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T12:00:23.656559+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T11:00:00+00:00 PythonOperator 2023-11-12T12:00:03.839292+00:00 2023-11-12T12:00:06.084404+00:00 0:00:02.245112 445714 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T12:00:01.576244+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T10:00:00+00:00 EmrJobFlowSensor 2023-11-12T11:00:47.638852+00:00 2023-11-12T11:25:51.478706+00:00 0:25:03.839854 445704 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T11:00:45.682595+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T11:00:25.570667+00:00 2023-11-12T11:00:26.733259+00:00 0:00:01.162592 445703 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T11:00:23.662773+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T10:00:00+00:00 PythonOperator 2023-11-12T11:00:05.710737+00:00 2023-11-12T11:00:07.922225+00:00 0:00:02.211488 445702 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T11:00:03.645373+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T09:00:00+00:00 EmrJobFlowSensor 2023-11-12T10:00:50.833746+00:00 2023-11-12T10:24:54.901175+00:00 0:24:04.067429 445693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T10:00:48.856639+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T10:00:28.951945+00:00 2023-11-12T10:00:30.015689+00:00 0:00:01.063744 445692 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T10:00:26.957796+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T09:00:00+00:00 PythonOperator 2023-11-12T10:00:06.856974+00:00 2023-11-12T10:00:09.017965+00:00 0:00:02.160991 445691 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T10:00:04.817015+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T08:00:00+00:00 EmrJobFlowSensor 2023-11-12T09:00:48.645951+00:00 2023-11-12T09:25:52.642807+00:00 0:25:03.996856 445680 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T09:00:46.741185+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T09:00:26.792320+00:00 2023-11-12T09:00:27.755670+00:00 0:00:00.963350 445679 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T09:00:24.774904+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T08:00:00+00:00 PythonOperator 2023-11-12T09:00:07.057960+00:00 2023-11-12T09:00:09.174605+00:00 0:00:02.116645 445678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T09:00:04.762767+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T07:00:00+00:00 EmrJobFlowSensor 2023-11-12T08:08:40.451776+00:00 2023-11-12T08:34:44.596961+00:00 0:26:04.145185 445671 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T08:08:38.538324+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T08:08:20.454442+00:00 2023-11-12T08:08:21.496264+00:00 0:00:01.041822 445669 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T08:08:18.520456+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T07:00:00+00:00 PythonOperator 2023-11-12T08:07:58.751682+00:00 2023-11-12T08:08:00.901764+00:00 0:00:02.150082 445667 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T08:07:56.547040+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T06:00:00+00:00 EmrJobFlowSensor 2023-11-12T07:01:04.257789+00:00 2023-11-12T07:27:07.990293+00:00 0:26:03.732504 445657 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T07:01:02.256466+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T07:00:42.206151+00:00 2023-11-12T07:00:43.458232+00:00 0:00:01.252081 445656 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T07:00:40.183843+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T06:00:00+00:00 PythonOperator 2023-11-12T07:00:22.262085+00:00 2023-11-12T07:00:24.431433+00:00 0:00:02.169348 445655 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T07:00:20.168077+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T05:00:00+00:00 EmrJobFlowSensor 2023-11-12T06:00:59.392214+00:00 2023-11-12T06:26:03.518455+00:00 0:25:04.126241 445645 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T06:00:57.365540+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T06:00:39.350604+00:00 2023-11-12T06:00:40.472887+00:00 0:00:01.122283 445644 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T06:00:37.357929+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T05:00:00+00:00 PythonOperator 2023-11-12T06:00:17.478219+00:00 2023-11-12T06:00:19.651954+00:00 0:00:02.173735 445643 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T06:00:15.285833+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T04:00:00+00:00 EmrJobFlowSensor 2023-11-12T05:00:49.953317+00:00 2023-11-12T05:25:53.773339+00:00 0:25:03.820022 445633 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T05:00:47.994228+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T05:00:29.984971+00:00 2023-11-12T05:00:31.008347+00:00 0:00:01.023376 445632 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T05:00:27.987953+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T04:00:00+00:00 PythonOperator 2023-11-12T05:00:08.081786+00:00 2023-11-12T05:00:10.270274+00:00 0:00:02.188488 445631 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T05:00:05.995400+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T03:00:00+00:00 EmrJobFlowSensor 2023-11-12T04:00:51.562198+00:00 2023-11-12T04:25:55.397380+00:00 0:25:03.835182 445622 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T04:00:49.577237+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T04:00:31.465783+00:00 2023-11-12T04:00:32.577315+00:00 0:00:01.111532 445620 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T04:00:29.543579+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T03:00:00+00:00 PythonOperator 2023-11-12T04:00:09.562244+00:00 2023-11-12T04:00:11.783433+00:00 0:00:02.221189 445618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T04:00:07.522729+00:00 2 default_pool