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 check_cluster_status 2023-12-15T22:00:00+00:00 EmrJobFlowSensor 2023-12-15T23:00:58.570250+00:00 2023-12-15T23:27:02.939117+00:00 0:26:04.368867 457772 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T23:00:56.551753+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T23:00:38.462150+00:00 2023-12-15T23:00:39.836480+00:00 0:00:01.374330 457769 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T23:00:36.533027+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T22:00:00+00:00 PythonOperator 2023-12-15T23:00:17.271073+00:00 2023-12-15T23:00:18.803452+00:00 0:00:01.532379 457766 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T23:00:14.571502+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T21:00:00+00:00 EmrJobFlowSensor 2023-12-15T22:00:47.165339+00:00 2023-12-15T22:23:50.630394+00:00 0:23:03.465055 457751 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T22:00:45.114943+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T22:00:27.173619+00:00 2023-12-15T22:00:28.055492+00:00 0:00:00.881873 457749 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T22:00:25.096659+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T21:00:00+00:00 PythonOperator 2023-12-15T22:00:05.226203+00:00 2023-12-15T22:00:06.900346+00:00 0:00:01.674143 457747 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T22:00:03.080314+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T20:00:00+00:00 EmrJobFlowSensor 2023-12-15T21:00:48.165950+00:00 2023-12-15T21:26:52.090940+00:00 0:26:03.924990 457733 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T21:00:46.088869+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T21:00:28.178580+00:00 2023-12-15T21:00:29.189742+00:00 0:00:01.011162 457731 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T21:00:26.065728+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T20:00:00+00:00 PythonOperator 2023-12-15T21:00:06.570901+00:00 2023-12-15T21:00:08.161122+00:00 0:00:01.590221 457729 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T21:00:04.084520+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T19:00:00+00:00 EmrJobFlowSensor 2023-12-15T20:00:58.555512+00:00 2023-12-15T20:29:02.768533+00:00 0:28:04.213021 457716 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T20:00:56.895553+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T20:00:36.984154+00:00 2023-12-15T20:00:37.995861+00:00 0:00:01.011707 457714 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T20:00:34.874185+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T19:00:00+00:00 PythonOperator 2023-12-15T20:00:16.576492+00:00 2023-12-15T20:00:18.143307+00:00 0:00:01.566815 457712 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T20:00:14.856596+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T18:00:00+00:00 EmrJobFlowSensor 2023-12-15T19:01:00.356868+00:00 2023-12-15T19:28:04.551383+00:00 0:27:04.194515 457698 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T19:00:58.261499+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T19:00:38.056224+00:00 2023-12-15T19:00:39.132812+00:00 0:00:01.076588 457696 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T19:00:36.285784+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T18:00:00+00:00 PythonOperator 2023-12-15T19:00:18.338339+00:00 2023-12-15T19:00:19.917520+00:00 0:00:01.579181 457694 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T19:00:16.263560+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T17:00:00+00:00 EmrJobFlowSensor 2023-12-15T18:00:50.092396+00:00 2023-12-15T18:26:53.987967+00:00 0:26:03.895571 457679 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T18:00:48.048192+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T18:00:28.313595+00:00 2023-12-15T18:00:29.564988+00:00 0:00:01.251393 457677 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T18:00:26.081532+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T17:00:00+00:00 PythonOperator 2023-12-15T18:00:06.123860+00:00 2023-12-15T18:00:07.750124+00:00 0:00:01.626264 457675 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T18:00:04.064270+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T16:00:00+00:00 EmrJobFlowSensor 2023-12-15T17:01:53.688597+00:00 2023-12-15T17:26:57.520986+00:00 0:25:03.832389 457663 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T17:01:51.583676+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T17:01:31.283656+00:00 2023-12-15T17:01:32.750503+00:00 0:00:01.466847 457660 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T17:01:29.563838+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T16:00:00+00:00 PythonOperator 2023-12-15T17:01:11.359252+00:00 2023-12-15T17:01:12.943066+00:00 0:00:01.583814 457658 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T17:01:09.546260+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T15:00:00+00:00 EmrJobFlowSensor 2023-12-15T16:01:13.248894+00:00 2023-12-15T16:26:17.013266+00:00 0:25:03.764372 457645 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T16:01:11.593173+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T16:00:53.694900+00:00 2023-12-15T16:00:54.760288+00:00 0:00:01.065388 457643 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T16:00:51.573420+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T15:00:00+00:00 PythonOperator 2023-12-15T16:00:31.664404+00:00 2023-12-15T16:00:33.218110+00:00 0:00:01.553706 457641 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T16:00:29.553044+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T14:00:00+00:00 EmrJobFlowSensor 2023-12-15T15:00:50.455514+00:00 2023-12-15T15:25:54.089702+00:00 0:25:03.634188 457628 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T15:00:48.762636+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T15:00:28.757313+00:00 2023-12-15T15:00:29.954213+00:00 0:00:01.196900 457626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T15:00:26.739744+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T14:00:00+00:00 PythonOperator 2023-12-15T15:00:06.996804+00:00 2023-12-15T15:00:08.536257+00:00 0:00:01.539453 457624 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T15:00:04.720933+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T13:00:00+00:00 EmrJobFlowSensor 2023-12-15T14:00:58.992117+00:00 2023-12-15T14:26:02.852119+00:00 0:25:03.860002 457612 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T14:00:56.939732+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T14:00:37.156721+00:00 2023-12-15T14:00:38.065218+00:00 0:00:00.908497 457610 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T14:00:34.978366+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T13:00:00+00:00 PythonOperator 2023-12-15T14:00:14.965385+00:00 2023-12-15T14:00:16.601528+00:00 0:00:01.636143 457608 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T14:00:12.954510+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T12:00:00+00:00 EmrJobFlowSensor 2023-12-15T13:06:08.946072+00:00 2023-12-15T13:31:12.730834+00:00 0:25:03.784762 457599 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T13:06:07.277394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T13:05:46.960324+00:00 2023-12-15T13:05:48.016915+00:00 0:00:01.056591 457595 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T13:05:45.247182+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T12:00:00+00:00 PythonOperator 2023-12-15T13:05:27.254272+00:00 2023-12-15T13:05:28.765017+00:00 0:00:01.510745 457593 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T13:05:25.228306+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T11:00:00+00:00 EmrJobFlowSensor 2023-12-15T12:01:46.586917+00:00 2023-12-15T12:25:50.184794+00:00 0:24:03.597877 457579 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T12:01:44.543896+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T12:00:33.845146+00:00 2023-12-15T12:00:34.803940+00:00 0:00:00.958794 457576 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T12:00:31.823955+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T11:00:00+00:00 PythonOperator 2023-12-15T12:00:13.809792+00:00 2023-12-15T12:00:15.334895+00:00 0:00:01.525103 457574 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T12:00:11.805998+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T10:00:00+00:00 EmrJobFlowSensor 2023-12-15T11:01:50.196627+00:00 2023-12-15T11:24:54.059306+00:00 0:23:03.862679 457560 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T11:01:48.041352+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T11:00:27.874285+00:00 2023-12-15T11:00:28.847312+00:00 0:00:00.973027 457557 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T11:00:26.157565+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T10:00:00+00:00 PythonOperator 2023-12-15T11:00:08.581402+00:00 2023-12-15T11:00:10.126634+00:00 0:00:01.545232 457555 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T11:00:06.143468+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T09:00:00+00:00 EmrJobFlowSensor 2023-12-15T10:01:28.243740+00:00 2023-12-15T10:27:31.953955+00:00 0:26:03.710215 457542 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T10:01:26.156934+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T10:00:46.110076+00:00 2023-12-15T10:00:47.081455+00:00 0:00:00.971379 457540 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T10:00:43.987137+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T09:00:00+00:00 PythonOperator 2023-12-15T10:00:24.043408+00:00 2023-12-15T10:00:26.526340+00:00 0:00:02.482932 457538 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T10:00:21.971304+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T08:00:00+00:00 EmrJobFlowSensor 2023-12-15T09:12:13.059528+00:00 2023-12-15T09:26:15.607581+00:00 0:14:02.548053 457530 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T09:12:11.203125+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T09:00:30.081762+00:00 2023-12-15T09:00:31.104465+00:00 0:00:01.022703 457520 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T09:00:28.003121+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T08:00:00+00:00 PythonOperator 2023-12-15T09:00:08.391824+00:00 2023-12-15T09:00:09.861898+00:00 0:00:01.470074 457518 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T09:00:05.988562+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T07:00:00+00:00 EmrJobFlowSensor 2023-12-15T08:02:18.662701+00:00 2023-12-15T08:28:22.530415+00:00 0:26:03.867714 457506 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T08:02:16.204209+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T08:00:43.084119+00:00 2023-12-15T08:00:43.989127+00:00 0:00:00.905008 457502 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T08:00:40.973516+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T07:00:00+00:00 PythonOperator 2023-12-15T08:00:21.273287+00:00 2023-12-15T08:00:22.838510+00:00 0:00:01.565223 457500 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T08:00:18.949196+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T06:00:00+00:00 EmrJobFlowSensor 2023-12-15T07:01:21.137560+00:00 2023-12-15T07:28:25.258741+00:00 0:27:04.121181 457488 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T07:01:19.128916+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T07:00:46.578542+00:00 2023-12-15T07:00:47.514168+00:00 0:00:00.935626 457485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T07:00:44.470814+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T06:00:00+00:00 PythonOperator 2023-12-15T07:00:24.745534+00:00 2023-12-15T07:00:26.349588+00:00 0:00:01.604054 457483 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T07:00:22.445899+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T05:00:00+00:00 EmrJobFlowSensor 2023-12-15T06:00:47.322252+00:00 2023-12-15T06:25:51.206675+00:00 0:25:03.884423 457470 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T06:00:45.269970+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T06:00:25.352850+00:00 2023-12-15T06:00:26.221106+00:00 0:00:00.868256 457468 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T06:00:23.259240+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T05:00:00+00:00 PythonOperator 2023-12-15T06:00:04.962851+00:00 2023-12-15T06:00:06.642482+00:00 0:00:01.679631 457466 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T06:00:03.175424+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T04:00:00+00:00 EmrJobFlowSensor 2023-12-15T05:00:47.936342+00:00 2023-12-15T05:24:51.658713+00:00 0:24:03.722371 457453 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T05:00:46.236039+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T05:00:25.853344+00:00 2023-12-15T05:00:26.731386+00:00 0:00:00.878042 457450 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T05:00:24.216255+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T04:00:00+00:00 PythonOperator 2023-12-15T05:00:04.463615+00:00 2023-12-15T05:00:06.057055+00:00 0:00:01.593440 457448 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T05:00:02.252356+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T03:00:00+00:00 EmrJobFlowSensor 2023-12-15T04:01:00.062426+00:00 2023-12-15T04:26:04.244867+00:00 0:25:04.182441 457433 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T04:00:58.364618+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T04:00:40.107541+00:00 2023-12-15T04:00:41.056645+00:00 0:00:00.949104 457430 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T04:00:38.347423+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T03:00:00+00:00 PythonOperator 2023-12-15T04:00:19.337549+00:00 2023-12-15T04:00:21.855387+00:00 0:00:02.517838 457428 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T04:00:16.379301+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T02:00:00+00:00 EmrJobFlowSensor 2023-12-15T03:12:22.659148+00:00 2023-12-15T03:26:25.004330+00:00 0:14:02.345182 457419 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T03:12:20.997921+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T03:00:44.269282+00:00 2023-12-15T03:00:45.313185+00:00 0:00:01.043903 457411 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T03:00:42.343252+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T02:00:00+00:00 PythonOperator 2023-12-15T03:00:22.740936+00:00 2023-12-15T03:00:24.245892+00:00 0:00:01.504956 457409 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T03:00:20.325367+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T01:00:00+00:00 EmrJobFlowSensor 2023-12-15T02:01:02.157276+00:00 2023-12-15T02:27:06.234018+00:00 0:26:04.076742 457393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T02:01:00.481714+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T02:00:42.686618+00:00 2023-12-15T02:00:43.565033+00:00 0:00:00.878415 457391 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T02:00:40.463111+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T01:00:00+00:00 PythonOperator 2023-12-15T02:00:21.119939+00:00 2023-12-15T02:00:22.713821+00:00 0:00:01.593882 457389 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T02:00:18.552507+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-15T00:00:00+00:00 EmrJobFlowSensor 2023-12-15T01:01:04.434782+00:00 2023-12-15T01:27:08.491871+00:00 0:26:04.057089 457370 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T01:01:02.698048+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-15T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T01:00:42.367404+00:00 2023-12-15T01:00:43.366727+00:00 0:00:00.999323 457368 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T01:00:40.676864+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-15T00:00:00+00:00 PythonOperator 2023-12-15T01:00:22.345204+00:00 2023-12-15T01:00:23.881363+00:00 0:00:01.536159 457366 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T01:00:20.655008+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T23:00:00+00:00 EmrJobFlowSensor 2023-12-15T00:06:51.652790+00:00 2023-12-15T00:32:55.600242+00:00 0:26:03.947452 457356 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-15T00:06:50.032435+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-15T00:06:30.106334+00:00 2023-12-15T00:06:31.031251+00:00 0:00:00.924917 457353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-15T00:06:28.012991+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T23:00:00+00:00 PythonOperator 2023-12-15T00:06:09.645080+00:00 2023-12-15T00:06:11.284424+00:00 0:00:01.639344 457350 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-15T00:06:07.995835+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T22:00:00+00:00 EmrJobFlowSensor 2023-12-14T23:01:08.965000+00:00 2023-12-14T23:29:13.110357+00:00 0:28:04.145357 457330 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T23:01:06.796622+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T23:00:48.469531+00:00 2023-12-14T23:00:49.438921+00:00 0:00:00.969390 457327 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T23:00:46.779375+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T22:00:00+00:00 PythonOperator 2023-12-14T23:00:26.943828+00:00 2023-12-14T23:00:29.794356+00:00 0:00:02.850528 457324 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T23:00:24.757003+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T21:00:00+00:00 EmrJobFlowSensor 2023-12-14T22:00:55.458611+00:00 2023-12-14T22:27:59.468089+00:00 0:27:04.009478 457311 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T22:00:53.751421+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T22:00:33.337631+00:00 2023-12-14T22:00:34.352574+00:00 0:00:01.014943 457308 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T22:00:31.714642+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T21:00:00+00:00 PythonOperator 2023-12-14T22:00:13.378788+00:00 2023-12-14T22:00:14.890748+00:00 0:00:01.511960 457307 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T22:00:11.700781+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T20:00:00+00:00 EmrJobFlowSensor 2023-12-14T21:01:07.336153+00:00 2023-12-14T21:28:11.406674+00:00 0:27:04.070521 457293 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T21:01:05.674765+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T21:00:47.377179+00:00 2023-12-14T21:00:48.620772+00:00 0:00:01.243593 457291 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T21:00:45.652098+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T20:00:00+00:00 PythonOperator 2023-12-14T21:00:25.267885+00:00 2023-12-14T21:00:26.800103+00:00 0:00:01.532218 457289 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T21:00:23.632686+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T19:00:00+00:00 EmrJobFlowSensor 2023-12-14T20:00:54.944033+00:00 2023-12-14T20:28:59.272722+00:00 0:28:04.328689 457274 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T20:00:52.486701+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T20:00:32.147704+00:00 2023-12-14T20:00:33.299825+00:00 0:00:01.152121 457271 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T20:00:30.460216+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T19:00:00+00:00 PythonOperator 2023-12-14T20:00:12.210602+00:00 2023-12-14T20:00:13.756335+00:00 0:00:01.545733 457270 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T20:00:10.444205+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T18:00:00+00:00 EmrJobFlowSensor 2023-12-14T19:00:50.660463+00:00 2023-12-14T19:27:55.000059+00:00 0:27:04.339596 457255 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T19:00:48.625404+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T19:00:30.277573+00:00 2023-12-14T19:00:31.206490+00:00 0:00:00.928917 457253 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T19:00:28.613720+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T18:00:00+00:00 PythonOperator 2023-12-14T19:00:09.164457+00:00 2023-12-14T19:00:10.645398+00:00 0:00:01.480941 457251 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T19:00:06.594522+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T17:00:00+00:00 EmrJobFlowSensor 2023-12-14T18:01:15.261996+00:00 2023-12-14T18:27:19.026809+00:00 0:26:03.764813 457238 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T18:01:13.568410+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T18:00:54.172911+00:00 2023-12-14T18:00:55.175488+00:00 0:00:01.002577 457236 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T18:00:51.549287+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T17:00:00+00:00 PythonOperator 2023-12-14T18:00:33.248534+00:00 2023-12-14T18:00:34.911975+00:00 0:00:01.663441 457234 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T18:00:31.529905+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T16:00:00+00:00 EmrJobFlowSensor 2023-12-14T17:01:05.462417+00:00 2023-12-14T17:26:09.325933+00:00 0:25:03.863516 457220 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T17:01:02.964614+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T17:00:42.567327+00:00 2023-12-14T17:00:43.522243+00:00 0:00:00.954916 457218 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T17:00:40.913945+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T16:00:00+00:00 PythonOperator 2023-12-14T17:00:22.964949+00:00 2023-12-14T17:00:24.471494+00:00 0:00:01.506545 457216 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T17:00:20.896862+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T15:00:00+00:00 EmrJobFlowSensor 2023-12-14T16:01:07.938977+00:00 2023-12-14T16:26:11.905302+00:00 0:25:03.966325 457201 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T16:01:05.864589+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T16:00:47.545200+00:00 2023-12-14T16:00:48.576804+00:00 0:00:01.031604 457199 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T16:00:45.833907+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T15:00:00+00:00 PythonOperator 2023-12-14T16:00:26.071289+00:00 2023-12-14T16:00:27.584537+00:00 0:00:01.513248 457197 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T16:00:23.816863+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T14:00:00+00:00 EmrJobFlowSensor 2023-12-14T15:01:01.948084+00:00 2023-12-14T15:26:05.990017+00:00 0:25:04.041933 457183 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T15:01:00.017794+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T15:00:41.645936+00:00 2023-12-14T15:00:42.658195+00:00 0:00:01.012259 457181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T15:00:39.993572+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T14:00:00+00:00 PythonOperator 2023-12-14T15:00:20.461146+00:00 2023-12-14T15:00:22.042963+00:00 0:00:01.581817 457179 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T15:00:17.986723+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T13:00:00+00:00 EmrJobFlowSensor 2023-12-14T14:04:09.286734+00:00 2023-12-14T14:30:13.131330+00:00 0:26:03.844596 457166 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T14:04:07.509399+00:00 2 default_pool