Task Instances


  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_cluster_and_add_emr_steps 2023-12-10T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T06:00:55.371075+00:00 2023-12-10T06:00:56.362970+00:00 0:00:00.991895 454830 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T06:00:53.499100+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T05:00:00+00:00 PythonOperator 2023-12-10T06:00:35.912657+00:00 2023-12-10T06:00:37.601066+00:00 0:00:01.688409 454828 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T06:00:33.536933+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T04:00:00+00:00 EmrJobFlowSensor 2023-12-10T05:01:02.284467+00:00 2023-12-10T05:23:05.998197+00:00 0:22:03.713730 454811 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T05:01:00.618699+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T05:00:40.457917+00:00 2023-12-10T05:00:41.394530+00:00 0:00:00.936613 454809 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T05:00:38.597563+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T04:00:00+00:00 PythonOperator 2023-12-10T05:00:20.486489+00:00 2023-12-10T05:00:22.164525+00:00 0:00:01.678036 454807 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T05:00:18.579936+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T03:00:00+00:00 EmrJobFlowSensor 2023-12-10T04:00:59.150825+00:00 2023-12-10T04:23:02.609769+00:00 0:22:03.458944 454789 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T04:00:57.172191+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T04:00:39.220020+00:00 2023-12-10T04:00:40.085720+00:00 0:00:00.865700 454786 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T04:00:37.131287+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T03:00:00+00:00 PythonOperator 2023-12-10T04:00:17.544510+00:00 2023-12-10T04:00:19.225792+00:00 0:00:01.681282 454783 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T04:00:15.114108+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T02:00:00+00:00 EmrJobFlowSensor 2023-12-10T03:00:46.835245+00:00 2023-12-10T03:22:50.370436+00:00 0:22:03.535191 454763 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T03:00:44.782920+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T03:00:24.660426+00:00 2023-12-10T03:00:25.709688+00:00 0:00:01.049262 454761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T03:00:22.711777+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T02:00:00+00:00 PythonOperator 2023-12-10T03:00:04.813585+00:00 2023-12-10T03:00:06.537069+00:00 0:00:01.723484 454759 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T03:00:02.693790+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T01:00:00+00:00 EmrJobFlowSensor 2023-12-10T02:00:50.445966+00:00 2023-12-10T02:22:53.702449+00:00 0:22:03.256483 454741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T02:00:48.407260+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T02:00:28.800381+00:00 2023-12-10T02:00:29.887634+00:00 0:00:01.087253 454739 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T02:00:26.389271+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T01:00:00+00:00 PythonOperator 2023-12-10T02:00:08.622121+00:00 2023-12-10T02:00:10.319034+00:00 0:00:01.696913 454737 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T02:00:06.369624+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T00:00:00+00:00 EmrJobFlowSensor 2023-12-10T01:00:51.850829+00:00 2023-12-10T01:22:55.309505+00:00 0:22:03.458676 454712 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T01:00:50.061827+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T01:00:32.812412+00:00 2023-12-10T01:00:33.813106+00:00 0:00:01.000694 454711 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T01:00:29.971528+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T00:00:00+00:00 PythonOperator 2023-12-10T01:00:09.860736+00:00 2023-12-10T01:00:11.540499+00:00 0:00:01.679763 454708 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T01:00:07.946986+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T23:00:00+00:00 EmrJobFlowSensor 2023-12-10T00:01:06.064024+00:00 2023-12-10T00:24:09.430847+00:00 0:23:03.366823 454691 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T00:01:04.387066+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T00:00:44.293488+00:00 2023-12-10T00:00:45.133417+00:00 0:00:00.839929 454689 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T00:00:42.367102+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T23:00:00+00:00 PythonOperator 2023-12-10T00:00:24.061346+00:00 2023-12-10T00:00:25.787431+00:00 0:00:01.726085 454687 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T00:00:22.348237+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T22:00:00+00:00 EmrJobFlowSensor 2023-12-09T23:00:59.744657+00:00 2023-12-09T23:24:03.317563+00:00 0:23:03.572906 454667 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T23:00:57.973606+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T23:00:39.850894+00:00 2023-12-09T23:00:40.759652+00:00 0:00:00.908758 454664 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T23:00:37.891637+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T22:00:00+00:00 PythonOperator 2023-12-09T23:00:17.849863+00:00 2023-12-09T23:00:19.525755+00:00 0:00:01.675892 454661 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T23:00:15.861833+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T21:00:00+00:00 EmrJobFlowSensor 2023-12-09T22:00:51.448505+00:00 2023-12-09T22:22:54.732227+00:00 0:22:03.283722 454643 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T22:00:49.454435+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T22:00:29.054908+00:00 2023-12-09T22:00:30.049808+00:00 0:00:00.994900 454641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T22:00:27.381917+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T21:00:00+00:00 PythonOperator 2023-12-09T22:00:09.322667+00:00 2023-12-09T22:00:11.077386+00:00 0:00:01.754719 454639 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T22:00:07.356601+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T20:00:00+00:00 EmrJobFlowSensor 2023-12-09T21:00:48.241195+00:00 2023-12-09T21:26:52.062036+00:00 0:26:03.820841 454620 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T21:00:45.689853+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T21:00:25.782840+00:00 2023-12-09T21:00:26.959594+00:00 0:00:01.176754 454618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T21:00:23.635413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T20:00:00+00:00 PythonOperator 2023-12-09T21:00:05.516530+00:00 2023-12-09T21:00:07.227868+00:00 0:00:01.711338 454616 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T21:00:03.614941+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T19:00:00+00:00 EmrJobFlowSensor 2023-12-09T20:01:03.088969+00:00 2023-12-09T20:28:07.260474+00:00 0:27:04.171505 454599 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T20:01:01.063010+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T20:00:40.743894+00:00 2023-12-09T20:00:41.750552+00:00 0:00:01.006658 454597 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T20:00:38.983427+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T19:00:00+00:00 PythonOperator 2023-12-09T20:00:20.639101+00:00 2023-12-09T20:00:22.288783+00:00 0:00:01.649682 454595 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T20:00:18.971880+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T18:00:00+00:00 EmrJobFlowSensor 2023-12-09T19:01:01.693808+00:00 2023-12-09T19:29:06.106487+00:00 0:28:04.412679 454577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T19:00:59.671574+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T19:00:41.658215+00:00 2023-12-09T19:00:42.582477+00:00 0:00:00.924262 454575 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T19:00:39.654367+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T18:00:00+00:00 PythonOperator 2023-12-09T19:00:19.276709+00:00 2023-12-09T19:00:20.933452+00:00 0:00:01.656743 454573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T19:00:17.575839+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T17:00:00+00:00 EmrJobFlowSensor 2023-12-09T18:00:59.941412+00:00 2023-12-09T18:26:03.945091+00:00 0:25:04.003679 454554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T18:00:57.954679+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T18:00:39.953072+00:00 2023-12-09T18:00:40.922030+00:00 0:00:00.968958 454552 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T18:00:37.880749+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T17:00:00+00:00 PythonOperator 2023-12-09T18:00:17.651618+00:00 2023-12-09T18:00:19.327485+00:00 0:00:01.675867 454550 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T18:00:15.833394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T16:00:00+00:00 EmrJobFlowSensor 2023-12-09T17:01:04.571080+00:00 2023-12-09T17:24:09.155434+00:00 0:23:04.584354 454533 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T17:01:02.649956+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T17:00:42.302191+00:00 2023-12-09T17:00:43.334498+00:00 0:00:01.032307 454531 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T17:00:40.630802+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T16:00:00+00:00 PythonOperator 2023-12-09T17:00:22.259307+00:00 2023-12-09T17:00:23.949037+00:00 0:00:01.689730 454529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T17:00:20.613584+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T15:00:00+00:00 EmrJobFlowSensor 2023-12-09T16:01:03.840477+00:00 2023-12-09T16:23:07.243306+00:00 0:22:03.402829 454513 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T16:01:02.186307+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T16:00:42.085159+00:00 2023-12-09T16:00:42.979697+00:00 0:00:00.894538 454511 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T16:00:40.162816+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T15:00:00+00:00 PythonOperator 2023-12-09T16:00:21.935801+00:00 2023-12-09T16:00:23.592055+00:00 0:00:01.656254 454509 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T16:00:20.146700+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T14:00:00+00:00 EmrJobFlowSensor 2023-12-09T15:00:58.572263+00:00 2023-12-09T15:23:01.994562+00:00 0:22:03.422299 454499 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T15:00:56.814885+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T15:00:38.460137+00:00 2023-12-09T15:00:39.459301+00:00 0:00:00.999164 454497 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T15:00:36.797461+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T14:00:00+00:00 PythonOperator 2023-12-09T15:00:17.144343+00:00 2023-12-09T15:00:18.807409+00:00 0:00:01.663066 454495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T15:00:14.776505+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T13:00:00+00:00 EmrJobFlowSensor 2023-12-09T14:00:46.164164+00:00 2023-12-09T14:22:49.596275+00:00 0:22:03.432111 454481 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T14:00:44.456595+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T14:00:24.382518+00:00 2023-12-09T14:00:25.342426+00:00 0:00:00.959908 454479 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T14:00:22.428994+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T13:00:00+00:00 PythonOperator 2023-12-09T14:00:04.522914+00:00 2023-12-09T14:00:06.273639+00:00 0:00:01.750725 454477 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T14:00:02.411279+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T12:00:00+00:00 EmrJobFlowSensor 2023-12-09T13:00:47.538950+00:00 2023-12-09T13:22:50.913834+00:00 0:22:03.374884 454465 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T13:00:45.641426+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T13:00:28.108341+00:00 2023-12-09T13:00:29.125418+00:00 0:00:01.017077 454463 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T13:00:25.625840+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T12:00:00+00:00 PythonOperator 2023-12-09T13:00:06.480296+00:00 2023-12-09T13:00:08.228026+00:00 0:00:01.747730 454461 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T13:00:03.606092+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T11:00:00+00:00 EmrJobFlowSensor 2023-12-09T12:00:55.776129+00:00 2023-12-09T12:22:59.383001+00:00 0:22:03.606872 454449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T12:00:54.090996+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T12:00:33.747698+00:00 2023-12-09T12:00:34.763513+00:00 0:00:01.015815 454447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T12:00:32.070517+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T11:00:00+00:00 PythonOperator 2023-12-09T12:00:13.833003+00:00 2023-12-09T12:00:15.539195+00:00 0:00:01.706192 454445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T12:00:12.057491+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T10:00:00+00:00 EmrJobFlowSensor 2023-12-09T11:00:53.891220+00:00 2023-12-09T11:22:57.261673+00:00 0:22:03.370453 454433 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T11:00:51.805964+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T11:00:31.663628+00:00 2023-12-09T11:00:32.635492+00:00 0:00:00.971864 454431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T11:00:29.790832+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T10:00:00+00:00 PythonOperator 2023-12-09T11:00:11.841157+00:00 2023-12-09T11:00:13.571508+00:00 0:00:01.730351 454429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T11:00:09.746572+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T09:00:00+00:00 EmrJobFlowSensor 2023-12-09T10:00:49.183788+00:00 2023-12-09T10:22:52.725887+00:00 0:22:03.542099 454417 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T10:00:47.115581+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T10:00:26.983260+00:00 2023-12-09T10:00:28.007005+00:00 0:00:01.023745 454415 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T10:00:25.063076+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T09:00:00+00:00 PythonOperator 2023-12-09T10:00:07.053492+00:00 2023-12-09T10:00:08.723127+00:00 0:00:01.669635 454413 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T10:00:05.041262+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T08:00:00+00:00 EmrJobFlowSensor 2023-12-09T09:01:05.426258+00:00 2023-12-09T09:23:09.260919+00:00 0:22:03.834661 454401 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T09:01:03.658909+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T09:00:43.612268+00:00 2023-12-09T09:00:44.616584+00:00 0:00:01.004316 454400 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T09:00:41.639381+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T08:00:00+00:00 PythonOperator 2023-12-09T09:00:23.729195+00:00 2023-12-09T09:00:25.431180+00:00 0:00:01.701985 454398 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T09:00:21.623848+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T07:00:00+00:00 EmrJobFlowSensor 2023-12-09T08:00:55.805113+00:00 2023-12-09T08:23:59.202569+00:00 0:23:03.397456 454386 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T08:00:53.892833+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T08:00:33.851007+00:00 2023-12-09T08:00:34.878814+00:00 0:00:01.027807 454384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T08:00:31.870745+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T07:00:00+00:00 PythonOperator 2023-12-09T08:00:13.882096+00:00 2023-12-09T08:00:15.597670+00:00 0:00:01.715574 454382 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T08:00:11.857179+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T06:00:00+00:00 EmrJobFlowSensor 2023-12-09T07:01:06.313721+00:00 2023-12-09T07:23:09.660721+00:00 0:22:03.347000 454371 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T07:01:04.328356+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T07:00:44.166264+00:00 2023-12-09T07:00:45.129543+00:00 0:00:00.963279 454369 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T07:00:42.303517+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T06:00:00+00:00 PythonOperator 2023-12-09T07:00:23.967588+00:00 2023-12-09T07:00:25.630555+00:00 0:00:01.662967 454367 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T07:00:22.285421+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T05:00:00+00:00 EmrJobFlowSensor 2023-12-09T06:00:54.680316+00:00 2023-12-09T06:22:58.066180+00:00 0:22:03.385864 454353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T06:00:52.789969+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T06:00:32.720851+00:00 2023-12-09T06:00:33.609546+00:00 0:00:00.888695 454351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T06:00:30.768434+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T05:00:00+00:00 PythonOperator 2023-12-09T06:00:11.046851+00:00 2023-12-09T06:00:12.720159+00:00 0:00:01.673308 454349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T06:00:08.796496+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T04:00:00+00:00 EmrJobFlowSensor 2023-12-09T05:00:50.047747+00:00 2023-12-09T05:22:53.538688+00:00 0:22:03.490941 454335 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T05:00:48.368932+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T05:00:29.942546+00:00 2023-12-09T05:00:30.996455+00:00 0:00:01.053909 454333 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T05:00:28.318508+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T04:00:00+00:00 PythonOperator 2023-12-09T05:00:08.368118+00:00 2023-12-09T05:00:10.097757+00:00 0:00:01.729639 454331 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T05:00:06.296817+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T03:00:00+00:00 EmrJobFlowSensor 2023-12-09T04:00:51.185456+00:00 2023-12-09T04:22:54.525213+00:00 0:22:03.339757 454315 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T04:00:49.237037+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T04:00:29.154437+00:00 2023-12-09T04:00:30.065831+00:00 0:00:00.911394 454312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T04:00:27.217471+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T03:00:00+00:00 PythonOperator 2023-12-09T04:00:08.939118+00:00 2023-12-09T04:00:10.535744+00:00 0:00:01.596626 454309 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T04:00:07.198681+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T02:00:00+00:00 EmrJobFlowSensor 2023-12-09T03:00:47.144454+00:00 2023-12-09T03:22:50.755037+00:00 0:22:03.610583 454294 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T03:00:45.456781+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T03:00:25.479424+00:00 2023-12-09T03:00:26.330381+00:00 0:00:00.850957 454292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T03:00:23.438794+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T02:00:00+00:00 PythonOperator 2023-12-09T03:00:03.692879+00:00 2023-12-09T03:00:05.501557+00:00 0:00:01.808678 454290 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T03:00:01.478037+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T01:00:00+00:00 EmrJobFlowSensor 2023-12-09T02:00:50.159548+00:00 2023-12-09T02:22:53.516754+00:00 0:22:03.357206 454276 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T02:00:48.280201+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T02:00:28.205276+00:00 2023-12-09T02:00:29.074833+00:00 0:00:00.869557 454274 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T02:00:26.267663+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T01:00:00+00:00 PythonOperator 2023-12-09T02:00:07.140960+00:00 2023-12-09T02:00:08.861589+00:00 0:00:01.720629 454272 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T02:00:04.287904+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-09T00:00:00+00:00 EmrJobFlowSensor 2023-12-09T01:01:02.988311+00:00 2023-12-09T01:23:06.482953+00:00 0:22:03.494642 454254 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T01:01:01.273291+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-09T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T01:00:41.497001+00:00 2023-12-09T01:00:42.461867+00:00 0:00:00.964866 454252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T01:00:39.265002+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-09T00:00:00+00:00 PythonOperator 2023-12-09T01:00:20.132333+00:00 2023-12-09T01:00:21.904874+00:00 0:00:01.772541 454250 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T01:00:17.286366+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T23:00:00+00:00 EmrJobFlowSensor 2023-12-09T00:00:59.840363+00:00 2023-12-09T00:24:03.313746+00:00 0:23:03.473383 454234 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-09T00:00:57.933393+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-09T00:00:37.576667+00:00 2023-12-09T00:00:38.669880+00:00 0:00:01.093213 454232 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-09T00:00:35.915616+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T23:00:00+00:00 PythonOperator 2023-12-09T00:00:17.653541+00:00 2023-12-09T00:00:19.348843+00:00 0:00:01.695302 454230 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-09T00:00:15.891061+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T22:00:00+00:00 EmrJobFlowSensor 2023-12-08T23:00:48.375086+00:00 2023-12-08T23:24:52.182133+00:00 0:24:03.807047 454217 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T23:00:46.306875+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T23:00:26.253895+00:00 2023-12-08T23:00:27.396592+00:00 0:00:01.142697 454213 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T23:00:24.296749+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T22:00:00+00:00 PythonOperator 2023-12-08T23:00:06.117439+00:00 2023-12-08T23:00:07.866484+00:00 0:00:01.749045 454210 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T23:00:04.242166+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T21:00:00+00:00 EmrJobFlowSensor 2023-12-08T22:00:58.365045+00:00 2023-12-08T22:26:02.347443+00:00 0:25:03.982398 454194 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T22:00:56.648915+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T22:00:36.649597+00:00 2023-12-08T22:00:37.574379+00:00 0:00:00.924782 454192 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T22:00:34.648720+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-08T21:00:00+00:00 PythonOperator 2023-12-08T22:00:16.339476+00:00 2023-12-08T22:00:17.991278+00:00 0:00:01.651802 454190 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-08T22:00:14.617344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-08T20:00:00+00:00 EmrJobFlowSensor 2023-12-08T21:00:48.969615+00:00 2023-12-08T21:27:53.081270+00:00 0:27:04.111655 454171 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-08T21:00:47.061708+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-08T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-08T21:00:27.071846+00:00 2023-12-08T21:00:28.091046+00:00 0:00:01.019200 454169 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-08T21:00:25.046068+00:00 2 default_pool