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-21T14:00:00+00:00 PythonOperator 2023-12-21T15:00:07.172836+00:00 2023-12-21T15:00:08.769646+00:00 0:00:01.596810 460219 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T15:00:05.339547+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T13:00:00+00:00 EmrJobFlowSensor 2023-12-21T14:01:53.114554+00:00 2023-12-21T14:26:57.118081+00:00 0:25:04.003527 460205 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T14:01:50.955544+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T14:01:33.473073+00:00 2023-12-21T14:01:34.653454+00:00 0:00:01.180381 460203 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T14:01:30.942502+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T13:00:00+00:00 PythonOperator 2023-12-21T14:00:06.790242+00:00 2023-12-21T14:00:08.384511+00:00 0:00:01.594269 460200 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T14:00:04.964024+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T12:00:00+00:00 EmrJobFlowSensor 2023-12-21T13:03:36.280075+00:00 2023-12-21T13:29:40.117304+00:00 0:26:03.837229 460189 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T13:03:34.594880+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T13:03:14.550504+00:00 2023-12-21T13:03:15.510155+00:00 0:00:00.959651 460187 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T13:03:12.550645+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T12:00:00+00:00 PythonOperator 2023-12-21T13:02:54.192281+00:00 2023-12-21T13:02:55.796784+00:00 0:00:01.604503 460185 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T13:02:52.534019+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T11:00:00+00:00 EmrJobFlowSensor 2023-12-21T12:14:48.415052+00:00 2023-12-21T12:39:52.223640+00:00 0:25:03.808588 460177 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T12:14:46.705207+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T12:14:27.058184+00:00 2023-12-21T12:14:27.956010+00:00 0:00:00.897826 460174 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T12:14:24.659274+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T11:00:00+00:00 PythonOperator 2023-12-21T12:14:06.552610+00:00 2023-12-21T12:14:08.161106+00:00 0:00:01.608496 460171 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T12:14:04.639452+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T10:00:00+00:00 EmrJobFlowSensor 2023-12-21T11:01:36.394019+00:00 2023-12-21T11:25:40.288257+00:00 0:24:03.894238 460155 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T11:01:34.276594+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T11:01:13.979112+00:00 2023-12-21T11:01:15.234081+00:00 0:00:01.254969 460153 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T11:01:12.260363+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T10:00:00+00:00 PythonOperator 2023-12-21T11:00:12.074016+00:00 2023-12-21T11:00:13.669115+00:00 0:00:01.595099 460150 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T11:00:10.280305+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T09:00:00+00:00 EmrJobFlowSensor 2023-12-21T10:02:15.041763+00:00 2023-12-21T10:27:18.852574+00:00 0:25:03.810811 460138 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T10:02:12.899338+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T10:01:54.609393+00:00 2023-12-21T10:01:55.623518+00:00 0:00:01.014125 460136 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T10:01:52.884064+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T09:00:00+00:00 PythonOperator 2023-12-21T10:01:33.271513+00:00 2023-12-21T10:01:34.844600+00:00 0:00:01.573087 460134 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T10:01:30.864262+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T08:00:00+00:00 EmrJobFlowSensor 2023-12-21T09:02:05.170797+00:00 2023-12-21T09:27:08.974494+00:00 0:25:03.803697 460119 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T09:02:03.126928+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T09:01:43.689327+00:00 2023-12-21T09:01:44.739261+00:00 0:00:01.049934 460117 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T09:01:41.107074+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T08:00:00+00:00 PythonOperator 2023-12-21T09:00:04.772256+00:00 2023-12-21T09:00:06.336007+00:00 0:00:01.563751 460113 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T09:00:02.578040+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T07:00:00+00:00 EmrJobFlowSensor 2023-12-21T08:01:50.419963+00:00 2023-12-21T08:27:54.373507+00:00 0:26:03.953544 460101 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T08:01:47.956866+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T08:01:28.478144+00:00 2023-12-21T08:01:29.422563+00:00 0:00:00.944419 460099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T08:01:25.936591+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T07:00:00+00:00 PythonOperator 2023-12-21T08:00:07.865636+00:00 2023-12-21T08:00:09.460791+00:00 0:00:01.595155 460095 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T08:00:05.948454+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T06:00:00+00:00 EmrJobFlowSensor 2023-12-21T07:02:05.364129+00:00 2023-12-21T07:28:09.542841+00:00 0:26:04.178712 460082 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T07:02:03.727741+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T07:01:45.438832+00:00 2023-12-21T07:01:46.525533+00:00 0:00:01.086701 460081 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T07:01:43.710678+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T06:00:00+00:00 PythonOperator 2023-12-21T07:00:14.268905+00:00 2023-12-21T07:00:15.846713+00:00 0:00:01.577808 460078 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T07:00:12.550175+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T05:00:00+00:00 EmrJobFlowSensor 2023-12-21T06:09:37.653104+00:00 2023-12-21T06:35:41.535145+00:00 0:26:03.882041 460070 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T06:09:35.964517+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T06:09:15.691037+00:00 2023-12-21T06:09:16.635646+00:00 0:00:00.944609 460069 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T06:09:13.961318+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T05:00:00+00:00 PythonOperator 2023-12-21T06:00:17.855346+00:00 2023-12-21T06:00:19.474065+00:00 0:00:01.618719 460061 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T06:00:16.136521+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T04:00:00+00:00 EmrJobFlowSensor 2023-12-21T05:00:51.696415+00:00 2023-12-21T06:09:01.611276+00:00 1:08:09.914861 460047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T05:00:49.592324+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T05:00:29.693868+00:00 2023-12-21T05:00:30.576772+00:00 0:00:00.882904 460045 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T05:00:27.507665+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T04:00:00+00:00 PythonOperator 2023-12-21T05:00:09.169767+00:00 2023-12-21T05:00:10.846197+00:00 0:00:01.676430 460043 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T05:00:07.490541+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T03:00:00+00:00 EmrJobFlowSensor 2023-12-21T04:00:48.976556+00:00 2023-12-21T04:47:56.151060+00:00 0:47:07.174504 460025 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T04:00:47.033253+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T04:00:29.570425+00:00 2023-12-21T04:00:30.541437+00:00 0:00:00.971012 460022 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T04:00:27.067556+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T03:00:00+00:00 PythonOperator 2023-12-21T04:00:07.175887+00:00 2023-12-21T04:00:08.730915+00:00 0:00:01.555028 460019 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T04:00:04.995337+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T02:00:00+00:00 EmrJobFlowSensor 2023-12-21T03:00:58.958868+00:00 2023-12-21T03:27:03.078248+00:00 0:26:04.119380 460006 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T03:00:57.271254+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T03:00:39.134733+00:00 2023-12-21T03:00:40.172340+00:00 0:00:01.037607 460004 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T03:00:37.211276+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T02:00:00+00:00 PythonOperator 2023-12-21T03:00:17.728186+00:00 2023-12-21T03:00:19.335530+00:00 0:00:01.607344 460002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T03:00:15.195723+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T01:00:00+00:00 EmrJobFlowSensor 2023-12-21T02:01:04.769748+00:00 2023-12-21T02:26:08.582224+00:00 0:25:03.812476 459989 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T02:01:02.733203+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T02:00:42.580088+00:00 2023-12-21T02:00:43.707760+00:00 0:00:01.127672 459986 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T02:00:40.766180+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T01:00:00+00:00 PythonOperator 2023-12-21T02:00:23.135269+00:00 2023-12-21T02:00:24.730922+00:00 0:00:01.595653 459985 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T02:00:20.696720+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T00:00:00+00:00 EmrJobFlowSensor 2023-12-21T01:01:02.751671+00:00 2023-12-21T01:26:06.815935+00:00 0:25:04.064264 459964 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T01:01:01.111410+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T01:00:40.955267+00:00 2023-12-21T01:00:42.009804+00:00 0:00:01.054537 459962 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T01:00:39.150203+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T00:00:00+00:00 PythonOperator 2023-12-21T01:00:21.332361+00:00 2023-12-21T01:00:22.905876+00:00 0:00:01.573515 459960 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T01:00:19.033452+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T23:00:00+00:00 EmrJobFlowSensor 2023-12-21T00:01:03.409867+00:00 2023-12-21T00:26:07.277082+00:00 0:25:03.867215 459948 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T00:01:01.226898+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T00:00:43.481838+00:00 2023-12-21T00:00:44.458362+00:00 0:00:00.976524 459946 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T00:00:41.273113+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T23:00:00+00:00 PythonOperator 2023-12-21T00:00:21.262525+00:00 2023-12-21T00:00:22.801399+00:00 0:00:01.538874 459944 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T00:00:19.219872+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T22:00:00+00:00 EmrJobFlowSensor 2023-12-20T23:00:58.157484+00:00 2023-12-20T23:26:02.098054+00:00 0:25:03.940570 459928 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T23:00:56.519102+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T23:00:36.580524+00:00 2023-12-20T23:00:37.550130+00:00 0:00:00.969606 459925 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T23:00:34.498315+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T22:00:00+00:00 PythonOperator 2023-12-20T23:00:15.678318+00:00 2023-12-20T23:00:17.316316+00:00 0:00:01.637998 459922 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T23:00:12.464759+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T21:00:00+00:00 EmrJobFlowSensor 2023-12-20T22:00:49.640971+00:00 2023-12-20T22:24:53.298455+00:00 0:24:03.657484 459907 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T22:00:47.320418+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T22:00:27.378434+00:00 2023-12-20T22:00:28.308668+00:00 0:00:00.930234 459905 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T22:00:25.352003+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T21:00:00+00:00 PythonOperator 2023-12-20T22:00:05.468812+00:00 2023-12-20T22:00:07.021639+00:00 0:00:01.552827 459903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T22:00:03.287643+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T20:00:00+00:00 EmrJobFlowSensor 2023-12-20T21:01:03.566887+00:00 2023-12-20T21:27:07.509688+00:00 0:26:03.942801 459889 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T21:01:01.909437+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T21:00:41.881392+00:00 2023-12-20T21:00:42.902857+00:00 0:00:01.021465 459887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T21:00:39.895828+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T20:00:00+00:00 PythonOperator 2023-12-20T21:00:20.106392+00:00 2023-12-20T21:00:21.647219+00:00 0:00:01.540827 459884 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T21:00:17.881890+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T19:00:00+00:00 EmrJobFlowSensor 2023-12-20T20:01:06.284681+00:00 2023-12-20T20:28:10.588545+00:00 0:27:04.303864 459871 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T20:01:04.262402+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T20:00:44.367886+00:00 2023-12-20T20:00:45.288358+00:00 0:00:00.920472 459869 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T20:00:42.238878+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T19:00:00+00:00 PythonOperator 2023-12-20T20:00:22.056653+00:00 2023-12-20T20:00:23.622755+00:00 0:00:01.566102 459867 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T20:00:20.271044+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T18:00:00+00:00 EmrJobFlowSensor 2023-12-20T19:00:47.856408+00:00 2023-12-20T19:27:51.836440+00:00 0:27:03.980032 459852 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T19:00:46.081301+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T19:00:26.306607+00:00 2023-12-20T19:00:27.299946+00:00 0:00:00.993339 459850 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T19:00:24.083379+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T18:00:00+00:00 PythonOperator 2023-12-20T19:00:05.775976+00:00 2023-12-20T19:00:07.397975+00:00 0:00:01.621999 459848 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T19:00:04.020511+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T17:00:00+00:00 EmrJobFlowSensor 2023-12-20T18:00:54.641733+00:00 2023-12-20T18:25:58.540341+00:00 0:25:03.898608 459834 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T18:00:52.943054+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T18:00:32.757964+00:00 2023-12-20T18:00:33.756688+00:00 0:00:00.998724 459832 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T18:00:30.971278+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T17:00:00+00:00 PythonOperator 2023-12-20T18:00:13.345919+00:00 2023-12-20T18:00:15.831244+00:00 0:00:02.485325 459830 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T18:00:10.963339+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T16:00:00+00:00 EmrJobFlowSensor 2023-12-20T17:01:21.060386+00:00 2023-12-20T17:24:24.877453+00:00 0:23:03.817067 459818 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T17:01:18.741977+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T17:01:00.814938+00:00 2023-12-20T17:01:01.862788+00:00 0:00:01.047850 459816 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T17:00:58.725864+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T16:00:00+00:00 PythonOperator 2023-12-20T17:00:13.403348+00:00 2023-12-20T17:00:15.014908+00:00 0:00:01.611560 459812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T17:00:11.193204+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T15:00:00+00:00 EmrJobFlowSensor 2023-12-20T16:00:55.769625+00:00 2023-12-20T16:26:59.776149+00:00 0:26:04.006524 459799 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T16:00:53.739410+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T16:00:35.955435+00:00 2023-12-20T16:00:36.831592+00:00 0:00:00.876157 459797 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T16:00:33.719340+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T15:00:00+00:00 PythonOperator 2023-12-20T16:00:14.082620+00:00 2023-12-20T16:00:15.682186+00:00 0:00:01.599566 459795 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T16:00:11.704078+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T14:00:00+00:00 EmrJobFlowSensor 2023-12-20T15:01:06.480575+00:00 2023-12-20T15:27:10.173017+00:00 0:26:03.692442 459782 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T15:01:04.258124+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T15:00:44.294642+00:00 2023-12-20T15:00:45.228806+00:00 0:00:00.934164 459780 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T15:00:42.188702+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T14:00:00+00:00 PythonOperator 2023-12-20T15:00:23.859530+00:00 2023-12-20T15:00:25.445819+00:00 0:00:01.586289 459778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T15:00:22.147592+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T13:00:00+00:00 EmrJobFlowSensor 2023-12-20T14:00:57.339460+00:00 2023-12-20T14:26:01.183295+00:00 0:25:03.843835 459766 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T14:00:55.305387+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T14:00:35.451754+00:00 2023-12-20T14:00:36.382421+00:00 0:00:00.930667 459764 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T14:00:33.284413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T13:00:00+00:00 PythonOperator 2023-12-20T14:00:15.097789+00:00 2023-12-20T14:00:16.751621+00:00 0:00:01.653832 459762 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T14:00:13.268831+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T12:00:00+00:00 EmrJobFlowSensor 2023-12-20T13:01:51.247899+00:00 2023-12-20T13:25:54.885195+00:00 0:24:03.637296 459748 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T13:01:48.602976+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T13:01:28.264054+00:00 2023-12-20T13:01:29.209735+00:00 0:00:00.945681 459746 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T13:01:26.567277+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T12:00:00+00:00 PythonOperator 2023-12-20T13:00:15.335896+00:00 2023-12-20T13:00:16.959986+00:00 0:00:01.624090 459743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T13:00:13.081379+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T11:00:00+00:00 EmrJobFlowSensor 2023-12-20T12:00:53.767537+00:00 2023-12-20T12:24:57.555458+00:00 0:24:03.787921 459732 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T12:00:51.882303+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T12:00:31.670399+00:00 2023-12-20T12:00:32.705715+00:00 0:00:01.035316 459730 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T12:00:29.883583+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T11:00:00+00:00 PythonOperator 2023-12-20T12:00:11.986176+00:00 2023-12-20T12:00:13.591652+00:00 0:00:01.605476 459728 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T12:00:09.876038+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T10:00:00+00:00 EmrJobFlowSensor 2023-12-20T11:00:57.977423+00:00 2023-12-20T11:27:02.086801+00:00 0:26:04.109378 459715 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T11:00:55.796033+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T11:00:37.935173+00:00 2023-12-20T11:00:39.128418+00:00 0:00:01.193245 459713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T11:00:35.780421+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T10:00:00+00:00 PythonOperator 2023-12-20T11:00:15.628330+00:00 2023-12-20T11:00:17.254906+00:00 0:00:01.626576 459711 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T11:00:13.749218+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T09:00:00+00:00 EmrJobFlowSensor 2023-12-20T10:04:18.939710+00:00 2023-12-20T10:30:23.060499+00:00 0:26:04.120789 459698 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T10:04:17.207728+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T10:03:58.865415+00:00 2023-12-20T10:03:59.858313+00:00 0:00:00.992898 459696 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T10:03:57.187208+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T09:00:00+00:00 PythonOperator 2023-12-20T10:03:37.357019+00:00 2023-12-20T10:03:38.854698+00:00 0:00:01.497679 459694 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T10:03:35.168874+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T08:00:00+00:00 EmrJobFlowSensor 2023-12-20T09:00:58.651919+00:00 2023-12-20T09:28:02.879987+00:00 0:27:04.228068 459682 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T09:00:56.354330+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T09:00:36.154969+00:00 2023-12-20T09:00:37.159423+00:00 0:00:01.004454 459680 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T09:00:34.325347+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T08:00:00+00:00 PythonOperator 2023-12-20T09:00:16.950911+00:00 2023-12-20T09:00:18.547027+00:00 0:00:01.596116 459678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T09:00:14.308000+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T07:00:00+00:00 EmrJobFlowSensor 2023-12-20T08:01:14.357756+00:00 2023-12-20T08:27:18.620704+00:00 0:26:04.262948 459663 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T08:01:12.311210+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T08:00:51.958646+00:00 2023-12-20T08:00:53.005181+00:00 0:00:01.046535 459661 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T08:00:50.291133+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T07:00:00+00:00 PythonOperator 2023-12-20T08:00:32.351654+00:00 2023-12-20T08:00:33.925460+00:00 0:00:01.573806 459659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T08:00:30.273187+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T06:00:00+00:00 EmrJobFlowSensor 2023-12-20T07:01:07.789389+00:00 2023-12-20T07:27:11.798369+00:00 0:26:04.008980 459645 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T07:01:06.052613+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T07:00:45.873225+00:00 2023-12-20T07:00:46.842774+00:00 0:00:00.969549 459643 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T07:00:44.032480+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T06:00:00+00:00 PythonOperator 2023-12-20T07:00:24.219285+00:00 2023-12-20T07:00:25.784690+00:00 0:00:01.565405 459641 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T07:00:22.013740+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T05:00:00+00:00 EmrJobFlowSensor 2023-12-20T06:00:50.673661+00:00 2023-12-20T06:26:54.582082+00:00 0:26:03.908421 459626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T06:00:48.472026+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T06:00:30.604150+00:00 2023-12-20T06:00:31.477066+00:00 0:00:00.872916 459624 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T06:00:28.454292+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T05:00:00+00:00 PythonOperator 2023-12-20T06:00:08.164108+00:00 2023-12-20T06:00:09.701332+00:00 0:00:01.537224 459622 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T06:00:06.386887+00:00 2 default_pool