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-30T02:00:00+00:00 PythonOperator 2023-12-30T03:04:29.754004+00:00 2023-12-30T03:04:31.426218+00:00 0:00:01.672214 463890 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-30T03:04:27.219657+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-30T01:00:00+00:00 EmrJobFlowSensor 2023-12-30T02:00:48.969947+00:00 2023-12-30T02:25:53.109980+00:00 0:25:04.140033 463877 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-30T02:00:46.780413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-30T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-30T02:00:26.969357+00:00 2023-12-30T02:00:27.950759+00:00 0:00:00.981402 463875 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-30T02:00:24.765370+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-30T01:00:00+00:00 PythonOperator 2023-12-30T02:00:07.137132+00:00 2023-12-30T02:00:08.793695+00:00 0:00:01.656563 463873 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-30T02:00:04.767903+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-30T00:00:00+00:00 EmrJobFlowSensor 2023-12-30T01:00:51.185472+00:00 2023-12-30T01:25:55.051078+00:00 0:25:03.865606 463853 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-30T01:00:49.360803+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-30T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-30T01:00:29.377655+00:00 2023-12-30T01:00:30.291855+00:00 0:00:00.914200 463851 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-30T01:00:27.279886+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-30T00:00:00+00:00 PythonOperator 2023-12-30T01:00:09.074284+00:00 2023-12-30T01:00:10.748163+00:00 0:00:01.673879 463849 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-30T01:00:07.214571+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T23:00:00+00:00 EmrJobFlowSensor 2023-12-30T00:00:56.420845+00:00 2023-12-30T00:26:00.026229+00:00 0:25:03.605384 463836 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-30T00:00:54.152276+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-30T00:00:36.628326+00:00 2023-12-30T00:00:37.528866+00:00 0:00:00.900540 463834 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-30T00:00:34.065165+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T23:00:00+00:00 PythonOperator 2023-12-30T00:00:13.862006+00:00 2023-12-30T00:00:15.515800+00:00 0:00:01.653794 463832 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-30T00:00:12.083436+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T22:00:00+00:00 EmrJobFlowSensor 2023-12-29T23:00:49.968889+00:00 2023-12-29T23:26:53.840635+00:00 0:26:03.871746 463816 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T23:00:48.286759+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T23:00:28.267139+00:00 2023-12-29T23:00:29.179793+00:00 0:00:00.912654 463813 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T23:00:26.230654+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T22:00:00+00:00 PythonOperator 2023-12-29T23:00:08.357350+00:00 2023-12-29T23:00:09.951931+00:00 0:00:01.594581 463810 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T23:00:06.213236+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T21:00:00+00:00 EmrJobFlowSensor 2023-12-29T22:00:50.385626+00:00 2023-12-29T22:23:53.952284+00:00 0:23:03.566658 463796 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T22:00:48.719398+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T22:00:28.580922+00:00 2023-12-29T22:00:29.838309+00:00 0:00:01.257387 463794 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T22:00:26.754998+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T21:00:00+00:00 PythonOperator 2023-12-29T22:00:09.159016+00:00 2023-12-29T22:00:10.798615+00:00 0:00:01.639599 463792 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T22:00:06.686592+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T20:00:00+00:00 EmrJobFlowSensor 2023-12-29T21:00:48.284707+00:00 2023-12-29T21:24:52.004370+00:00 0:24:03.719663 463778 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T21:00:46.064681+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T21:00:25.877810+00:00 2023-12-29T21:00:26.852536+00:00 0:00:00.974726 463776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T21:00:24.054954+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T20:00:00+00:00 PythonOperator 2023-12-29T21:00:06.079275+00:00 2023-12-29T21:00:08.298565+00:00 0:00:02.219290 463774 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T21:00:03.985026+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T19:00:00+00:00 EmrJobFlowSensor 2023-12-29T20:00:51.169942+00:00 2023-12-29T20:26:54.892847+00:00 0:26:03.722905 463760 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T20:00:49.372561+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T20:00:31.184379+00:00 2023-12-29T20:00:32.114792+00:00 0:00:00.930413 463758 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T20:00:29.288798+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T19:00:00+00:00 PythonOperator 2023-12-29T20:00:09.502772+00:00 2023-12-29T20:00:11.151636+00:00 0:00:01.648864 463756 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T20:00:07.287037+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T18:00:00+00:00 EmrJobFlowSensor 2023-12-29T19:00:48.144616+00:00 2023-12-29T19:26:52.010958+00:00 0:26:03.866342 463741 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T19:00:46.357073+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T19:00:28.476838+00:00 2023-12-29T19:00:29.396353+00:00 0:00:00.919515 463739 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T19:00:26.284120+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T18:00:00+00:00 PythonOperator 2023-12-29T19:00:06.411432+00:00 2023-12-29T19:00:07.978772+00:00 0:00:01.567340 463737 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T19:00:04.285907+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T17:00:00+00:00 EmrJobFlowSensor 2023-12-29T18:00:59.249559+00:00 2023-12-29T18:26:03.053810+00:00 0:25:03.804251 463724 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T18:00:57.449688+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T18:00:38.164890+00:00 2023-12-29T18:00:39.036024+00:00 0:00:00.871134 463722 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T18:00:35.379812+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T17:00:00+00:00 PythonOperator 2023-12-29T18:00:16.966646+00:00 2023-12-29T18:00:18.555496+00:00 0:00:01.588850 463720 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T18:00:15.320390+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T16:00:00+00:00 EmrJobFlowSensor 2023-12-29T17:23:12.264033+00:00 2023-12-29T17:48:15.975623+00:00 0:25:03.711590 463711 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T17:23:10.555260+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T17:22:52.154678+00:00 2023-12-29T17:22:53.100728+00:00 0:00:00.946050 463708 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T17:22:50.498842+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T16:00:00+00:00 PythonOperator 2023-12-29T17:22:30.173892+00:00 2023-12-29T17:22:32.396627+00:00 0:00:02.222735 463705 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T17:22:28.466754+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T15:00:00+00:00 EmrJobFlowSensor 2023-12-29T16:13:05.147175+00:00 2023-12-29T16:38:09.059518+00:00 0:25:03.912343 463696 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T16:13:03.389280+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T16:12:43.252271+00:00 2023-12-29T16:12:44.324655+00:00 0:00:01.072384 463693 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T16:12:41.319720+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T15:00:00+00:00 PythonOperator 2023-12-29T16:12:22.953085+00:00 2023-12-29T16:12:24.554452+00:00 0:00:01.601367 463690 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T16:12:21.304849+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T14:00:00+00:00 EmrJobFlowSensor 2023-12-29T15:00:59.658417+00:00 2023-12-29T15:26:03.634368+00:00 0:25:03.975951 463676 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T15:00:57.864562+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T15:00:39.659555+00:00 2023-12-29T15:00:40.649186+00:00 0:00:00.989631 463674 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T15:00:37.858586+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T14:00:00+00:00 PythonOperator 2023-12-29T15:00:17.661328+00:00 2023-12-29T15:00:19.901643+00:00 0:00:02.240315 463672 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T15:00:15.785821+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T13:00:00+00:00 EmrJobFlowSensor 2023-12-29T14:00:51.080235+00:00 2023-12-29T14:25:55.173661+00:00 0:25:04.093426 463661 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T14:00:49.340887+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T14:00:28.956504+00:00 2023-12-29T14:00:29.849107+00:00 0:00:00.892603 463659 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T14:00:27.321021+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T13:00:00+00:00 PythonOperator 2023-12-29T14:00:07.784208+00:00 2023-12-29T14:00:09.326918+00:00 0:00:01.542710 463658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T14:00:05.303933+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T12:00:00+00:00 EmrJobFlowSensor 2023-12-29T13:01:42.281535+00:00 2023-12-29T13:26:46.331501+00:00 0:25:04.049966 463646 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T13:01:40.223975+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T13:01:21.853017+00:00 2023-12-29T13:01:22.988812+00:00 0:00:01.135795 463644 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T13:01:20.207628+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T12:00:00+00:00 PythonOperator 2023-12-29T13:01:00.625154+00:00 2023-12-29T13:01:02.271080+00:00 0:00:01.645926 463642 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T13:00:58.243983+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T11:00:00+00:00 EmrJobFlowSensor 2023-12-29T12:01:07.215750+00:00 2023-12-29T12:26:10.939427+00:00 0:25:03.723677 463629 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T12:01:05.534481+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T12:00:45.250418+00:00 2023-12-29T12:00:46.232188+00:00 0:00:00.981770 463627 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T12:00:43.514196+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T11:00:00+00:00 PythonOperator 2023-12-29T12:00:23.164677+00:00 2023-12-29T12:00:24.735450+00:00 0:00:01.570773 463625 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T12:00:21.495545+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T10:00:00+00:00 EmrJobFlowSensor 2023-12-29T11:00:59.948046+00:00 2023-12-29T11:25:03.792458+00:00 0:24:03.844412 463612 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T11:00:58.255280+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T11:00:38.490982+00:00 2023-12-29T11:00:39.518493+00:00 0:00:01.027511 463610 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T11:00:36.283376+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T10:00:00+00:00 PythonOperator 2023-12-29T11:00:18.078561+00:00 2023-12-29T11:00:19.702228+00:00 0:00:01.623667 463608 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T11:00:16.267450+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T09:00:00+00:00 EmrJobFlowSensor 2023-12-29T10:08:35.374906+00:00 2023-12-29T10:33:39.278241+00:00 0:25:03.903335 463600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T10:08:33.188287+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T10:08:14.860745+00:00 2023-12-29T10:08:15.976903+00:00 0:00:01.116158 463597 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T10:08:13.159193+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T09:00:00+00:00 PythonOperator 2023-12-29T10:07:52.824687+00:00 2023-12-29T10:07:54.375807+00:00 0:00:01.551120 463594 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T10:07:51.141429+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T08:00:00+00:00 EmrJobFlowSensor 2023-12-29T09:00:52.344203+00:00 2023-12-29T09:25:56.409588+00:00 0:25:04.065385 463578 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T09:00:50.681547+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T09:00:30.354452+00:00 2023-12-29T09:00:31.364609+00:00 0:00:01.010157 463576 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T09:00:28.658746+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T08:00:00+00:00 PythonOperator 2023-12-29T09:00:08.497349+00:00 2023-12-29T09:00:10.097318+00:00 0:00:01.599969 463574 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T09:00:06.687663+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T07:00:00+00:00 EmrJobFlowSensor 2023-12-29T08:00:51.692795+00:00 2023-12-29T08:26:55.625239+00:00 0:26:03.932444 463559 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T08:00:49.639645+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T08:00:29.681191+00:00 2023-12-29T08:00:30.667233+00:00 0:00:00.986042 463557 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T08:00:27.623165+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T07:00:00+00:00 PythonOperator 2023-12-29T08:00:09.869027+00:00 2023-12-29T08:00:11.533132+00:00 0:00:01.664105 463555 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T08:00:07.604061+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T06:00:00+00:00 EmrJobFlowSensor 2023-12-29T07:00:58.851702+00:00 2023-12-29T07:27:02.897174+00:00 0:26:04.045472 463544 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T07:00:57.159284+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T07:00:38.870178+00:00 2023-12-29T07:00:39.784407+00:00 0:00:00.914229 463542 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T07:00:37.084291+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T06:00:00+00:00 PythonOperator 2023-12-29T07:00:17.280822+00:00 2023-12-29T07:00:18.883999+00:00 0:00:01.603177 463540 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T07:00:15.094379+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T05:00:00+00:00 EmrJobFlowSensor 2023-12-29T06:08:07.595305+00:00 2023-12-29T06:33:11.585478+00:00 0:25:03.990173 463529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T06:08:05.935777+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T06:07:48.017957+00:00 2023-12-29T06:07:48.904553+00:00 0:00:00.886596 463526 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T06:07:45.917511+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T05:00:00+00:00 PythonOperator 2023-12-29T06:00:10.694047+00:00 2023-12-29T06:00:12.354858+00:00 0:00:01.660811 463521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T06:00:08.512140+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T04:00:00+00:00 EmrJobFlowSensor 2023-12-29T05:01:20.679045+00:00 2023-12-29T05:25:24.555811+00:00 0:24:03.876766 463508 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T05:01:19.033693+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T05:01:00.901229+00:00 2023-12-29T05:01:02.179835+00:00 0:00:01.278606 463506 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T05:00:59.015655+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T04:00:00+00:00 PythonOperator 2023-12-29T05:00:16.959499+00:00 2023-12-29T05:00:18.504282+00:00 0:00:01.544783 463504 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T05:00:14.393335+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T03:00:00+00:00 EmrJobFlowSensor 2023-12-29T04:01:34.963849+00:00 2023-12-29T04:25:38.697027+00:00 0:24:03.733178 463489 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T04:01:33.303140+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T04:01:15.338763+00:00 2023-12-29T04:01:16.423624+00:00 0:00:01.084861 463486 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T04:01:13.285675+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T03:00:00+00:00 PythonOperator 2023-12-29T04:00:11.232860+00:00 2023-12-29T04:00:14.093924+00:00 0:00:02.861064 463482 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T04:00:08.966398+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T02:00:00+00:00 EmrJobFlowSensor 2023-12-29T03:02:02.766820+00:00 2023-12-29T03:27:06.381464+00:00 0:25:03.614644 463469 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T03:02:01.058269+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T03:01:41.179736+00:00 2023-12-29T03:01:42.181401+00:00 0:00:01.001665 463467 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T03:01:39.038545+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T02:00:00+00:00 PythonOperator 2023-12-29T03:00:12.304381+00:00 2023-12-29T03:00:13.925297+00:00 0:00:01.620916 463464 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T03:00:10.071418+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T01:00:00+00:00 EmrJobFlowSensor 2023-12-29T02:01:42.150685+00:00 2023-12-29T02:25:45.742464+00:00 0:24:03.591779 463451 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T02:01:40.496861+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T02:01:22.274103+00:00 2023-12-29T02:01:23.272393+00:00 0:00:00.998290 463449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T02:01:20.486301+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T01:00:00+00:00 PythonOperator 2023-12-29T02:00:13.444420+00:00 2023-12-29T02:00:15.180354+00:00 0:00:01.735934 463447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T02:00:11.460200+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-29T00:00:00+00:00 EmrJobFlowSensor 2023-12-29T01:01:14.422894+00:00 2023-12-29T01:26:18.416580+00:00 0:25:03.993686 463427 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T01:01:12.303540+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-29T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T01:00:52.376634+00:00 2023-12-29T01:00:53.317241+00:00 0:00:00.940607 463425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T01:00:50.286433+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-29T00:00:00+00:00 PythonOperator 2023-12-29T01:00:32.789307+00:00 2023-12-29T01:00:34.448416+00:00 0:00:01.659109 463423 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T01:00:30.327608+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-28T23:00:00+00:00 EmrJobFlowSensor 2023-12-29T00:01:39.450860+00:00 2023-12-29T00:26:43.199399+00:00 0:25:03.748539 463408 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-29T00:01:37.781764+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-29T00:01:19.908419+00:00 2023-12-29T00:01:20.824301+00:00 0:00:00.915882 463406 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-29T00:01:17.741608+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-28T23:00:00+00:00 PythonOperator 2023-12-29T00:00:57.982380+00:00 2023-12-29T00:00:59.587450+00:00 0:00:01.605070 463404 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-29T00:00:55.722196+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-28T22:00:00+00:00 EmrJobFlowSensor 2023-12-28T23:01:20.733370+00:00 2023-12-28T23:27:24.840352+00:00 0:26:04.106982 463389 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-28T23:01:18.686908+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-28T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-28T23:00:58.263889+00:00 2023-12-28T23:00:59.262650+00:00 0:00:00.998761 463386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-28T23:00:56.615083+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-28T22:00:00+00:00 PythonOperator 2023-12-28T23:00:38.480241+00:00 2023-12-28T23:00:40.038510+00:00 0:00:01.558269 463383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-28T23:00:36.600379+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-28T21:00:00+00:00 EmrJobFlowSensor 2023-12-28T22:00:56.622088+00:00 2023-12-28T22:24:00.826276+00:00 0:23:04.204188 463367 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-28T22:00:54.510098+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-28T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-28T22:00:36.612710+00:00 2023-12-28T22:00:37.909636+00:00 0:00:01.296926 463365 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-28T22:00:34.491594+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-28T21:00:00+00:00 PythonOperator 2023-12-28T22:00:14.284830+00:00 2023-12-28T22:00:15.846132+00:00 0:00:01.561302 463363 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-28T22:00:12.475817+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-28T20:00:00+00:00 EmrJobFlowSensor 2023-12-28T21:01:07.062782+00:00 2023-12-28T21:26:10.859400+00:00 0:25:03.796618 463350 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-28T21:01:04.977411+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-28T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-28T21:00:45.145598+00:00 2023-12-28T21:00:46.351924+00:00 0:00:01.206326 463347 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-28T21:00:42.909746+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-28T20:00:00+00:00 PythonOperator 2023-12-28T21:00:25.282144+00:00 2023-12-28T21:00:26.917147+00:00 0:00:01.635003 463346 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-28T21:00:22.893212+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-28T19:00:00+00:00 EmrJobFlowSensor 2023-12-28T20:01:10.479890+00:00 2023-12-28T20:28:14.864748+00:00 0:27:04.384858 463331 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-28T20:01:08.028551+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-28T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-28T20:00:50.112571+00:00 2023-12-28T20:00:50.959426+00:00 0:00:00.846855 463329 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-28T20:00:48.002702+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-28T19:00:00+00:00 PythonOperator 2023-12-28T20:00:28.054971+00:00 2023-12-28T20:00:29.562063+00:00 0:00:01.507092 463327 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-28T20:00:25.989143+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-28T18:00:00+00:00 EmrJobFlowSensor 2023-12-28T19:01:12.668264+00:00 2023-12-28T19:27:16.593208+00:00 0:26:03.924944 463312 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-28T19:01:10.985635+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-28T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-28T19:00:53.002333+00:00 2023-12-28T19:00:54.083855+00:00 0:00:01.081522 463311 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-28T19:00:50.937593+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-28T18:00:00+00:00 PythonOperator 2023-12-28T19:00:31.283310+00:00 2023-12-28T19:00:32.898447+00:00 0:00:01.615137 463309 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-28T19:00:28.916802+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-28T17:00:00+00:00 EmrJobFlowSensor 2023-12-28T18:01:52.071427+00:00 2023-12-28T18:26:55.659401+00:00 0:25:03.587974 463294 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-28T18:01:50.441069+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-28T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-28T18:01:32.491149+00:00 2023-12-28T18:01:33.470220+00:00 0:00:00.979071 463292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-28T18:01:30.424059+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-28T17:00:00+00:00 PythonOperator 2023-12-28T18:01:10.990380+00:00 2023-12-28T18:01:12.657575+00:00 0:00:01.667195 463290 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-28T18:01:08.407645+00:00 2 default_pool