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-11-03T07:00:00+00:00 EmrJobFlowSensor 2023-11-03T08:06:01.258127+00:00 2023-11-03T08:30:05.466623+00:00 0:24:04.208496 442056 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T08:05:59.324133+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T08:05:42.874183+00:00 2023-11-03T08:05:43.973918+00:00 0:00:01.099735 442055 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T08:05:39.306720+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T07:00:00+00:00 PythonOperator 2023-11-03T08:05:20.019196+00:00 2023-11-03T08:05:22.905113+00:00 0:00:02.885917 442051 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T08:05:17.288834+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T06:00:00+00:00 EmrJobFlowSensor 2023-11-03T07:01:03.189245+00:00 2023-11-03T07:26:07.091213+00:00 0:25:03.901968 442036 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T07:01:01.169328+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T07:00:41.161132+00:00 2023-11-03T07:00:42.393109+00:00 0:00:01.231977 442035 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T07:00:39.146524+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T06:00:00+00:00 PythonOperator 2023-11-03T07:00:19.618111+00:00 2023-11-03T07:00:21.690609+00:00 0:00:02.072498 442034 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T07:00:17.165464+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T05:00:00+00:00 EmrJobFlowSensor 2023-11-03T06:00:51.448783+00:00 2023-11-03T06:24:55.198943+00:00 0:24:03.750160 442013 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T06:00:49.448695+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T06:00:31.381064+00:00 2023-11-03T06:00:32.442098+00:00 0:00:01.061034 442012 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T06:00:29.379632+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T05:00:00+00:00 PythonOperator 2023-11-03T06:00:09.447545+00:00 2023-11-03T06:00:11.574119+00:00 0:00:02.126574 442009 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T06:00:07.354784+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T04:00:00+00:00 EmrJobFlowSensor 2023-11-03T05:01:05.341242+00:00 2023-11-03T05:25:09.007043+00:00 0:24:03.665801 441987 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T05:01:03.270156+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T05:00:43.377216+00:00 2023-11-03T05:00:44.385652+00:00 0:00:01.008436 441986 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T05:00:41.262370+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T04:00:00+00:00 PythonOperator 2023-11-03T05:00:23.618872+00:00 2023-11-03T05:00:25.716202+00:00 0:00:02.097330 441985 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T05:00:21.255941+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T03:00:00+00:00 EmrJobFlowSensor 2023-11-03T04:00:54.238668+00:00 2023-11-03T04:24:57.816436+00:00 0:24:03.577768 441971 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T04:00:52.238281+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T04:00:34.173348+00:00 2023-11-03T04:00:35.146849+00:00 0:00:00.973501 441970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T04:00:32.162466+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T03:00:00+00:00 PythonOperator 2023-11-03T04:00:12.224810+00:00 2023-11-03T04:00:14.324100+00:00 0:00:02.099290 441968 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T04:00:10.143731+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T02:00:00+00:00 EmrJobFlowSensor 2023-11-03T03:01:28.087782+00:00 2023-11-03T03:25:31.913398+00:00 0:24:03.825616 441954 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T03:01:26.064383+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T03:01:08.067755+00:00 2023-11-03T03:01:09.023943+00:00 0:00:00.956188 441953 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T03:01:06.033045+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T02:00:00+00:00 PythonOperator 2023-11-03T03:00:46.357125+00:00 2023-11-03T03:00:48.463912+00:00 0:00:02.106787 441952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T03:00:44.073922+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T01:00:00+00:00 EmrJobFlowSensor 2023-11-03T02:00:49.271882+00:00 2023-11-03T02:24:52.840572+00:00 0:24:03.568690 441936 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T02:00:47.263493+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T02:00:27.200032+00:00 2023-11-03T02:00:28.188106+00:00 0:00:00.988074 441935 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T02:00:25.243162+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T01:00:00+00:00 PythonOperator 2023-11-03T02:00:07.503921+00:00 2023-11-03T02:00:09.597132+00:00 0:00:02.093211 441933 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T02:00:05.227739+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T00:00:00+00:00 EmrJobFlowSensor 2023-11-03T01:10:51.463443+00:00 2023-11-03T01:34:55.352157+00:00 0:24:03.888714 441917 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T01:10:49.479322+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T01:10:29.449659+00:00 2023-11-03T01:10:30.476876+00:00 0:00:01.027217 441915 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T01:10:27.458193+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T00:00:00+00:00 PythonOperator 2023-11-03T01:10:10.062075+00:00 2023-11-03T01:10:15.186078+00:00 0:00:05.124003 441912 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T01:10:07.442907+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T23:00:00+00:00 EmrJobFlowSensor 2023-11-03T00:00:46.174018+00:00 2023-11-03T00:24:49.849215+00:00 0:24:03.675197 441897 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T00:00:44.144086+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T00:00:26.068587+00:00 2023-11-03T00:00:27.109063+00:00 0:00:01.040476 441896 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T00:00:24.086543+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T23:00:00+00:00 PythonOperator 2023-11-03T00:00:04.213862+00:00 2023-11-03T00:00:07.191306+00:00 0:00:02.977444 441894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T00:00:02.058310+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T22:00:00+00:00 EmrJobFlowSensor 2023-11-02T23:00:49.747289+00:00 2023-11-02T23:24:53.488242+00:00 0:24:03.740953 441876 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T23:00:47.830713+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T23:00:31.380764+00:00 2023-11-02T23:00:32.572739+00:00 0:00:01.191975 441875 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T23:00:27.815835+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T22:00:00+00:00 PythonOperator 2023-11-02T23:00:08.358055+00:00 2023-11-02T23:00:11.272469+00:00 0:00:02.914414 441871 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T23:00:05.797513+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T21:00:00+00:00 EmrJobFlowSensor 2023-11-02T22:02:21.928992+00:00 2023-11-02T22:21:24.786499+00:00 0:19:02.857507 441856 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T22:02:20.037838+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T22:01:59.957927+00:00 2023-11-02T22:02:00.985004+00:00 0:00:01.027077 441855 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T22:01:58.015291+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T21:00:00+00:00 PythonOperator 2023-11-02T22:01:40.268085+00:00 2023-11-02T22:01:42.343778+00:00 0:00:02.075693 441854 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T22:01:37.997656+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T20:00:00+00:00 EmrJobFlowSensor 2023-11-02T21:00:50.271663+00:00 2023-11-02T21:21:53.526412+00:00 0:21:03.254749 441839 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T21:00:48.361241+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T21:00:30.356865+00:00 2023-11-02T21:00:31.474181+00:00 0:00:01.117316 441837 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T21:00:28.342565+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T20:00:00+00:00 PythonOperator 2023-11-02T21:00:08.778155+00:00 2023-11-02T21:00:11.021263+00:00 0:00:02.243108 441835 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T21:00:06.365079+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T19:00:00+00:00 EmrJobFlowSensor 2023-11-02T20:00:58.789570+00:00 2023-11-02T20:24:02.372387+00:00 0:23:03.582817 441822 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T20:00:56.748400+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T20:00:38.657198+00:00 2023-11-02T20:00:39.639363+00:00 0:00:00.982165 441820 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T20:00:36.730679+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T19:00:00+00:00 PythonOperator 2023-11-02T20:00:16.754259+00:00 2023-11-02T20:00:18.901057+00:00 0:00:02.146798 441818 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T20:00:14.710250+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T18:00:00+00:00 EmrJobFlowSensor 2023-11-02T19:00:59.870029+00:00 2023-11-02T19:23:03.252435+00:00 0:22:03.382406 441803 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T19:00:57.755954+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T19:00:37.775651+00:00 2023-11-02T19:00:38.828420+00:00 0:00:01.052769 441802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T19:00:35.739886+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T18:00:00+00:00 PythonOperator 2023-11-02T19:00:17.744585+00:00 2023-11-02T19:00:19.810625+00:00 0:00:02.066040 441801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T19:00:15.664195+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T17:00:00+00:00 EmrJobFlowSensor 2023-11-02T18:00:57.745918+00:00 2023-11-02T18:23:01.208228+00:00 0:22:03.462310 441783 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T18:00:55.753066+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T18:00:37.668338+00:00 2023-11-02T18:00:38.662257+00:00 0:00:00.993919 441782 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T18:00:35.686402+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T17:00:00+00:00 PythonOperator 2023-11-02T18:00:15.867467+00:00 2023-11-02T18:00:17.968082+00:00 0:00:02.100615 441780 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T18:00:13.666619+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T16:00:00+00:00 EmrJobFlowSensor 2023-11-02T17:00:49.248320+00:00 2023-11-02T17:21:52.688251+00:00 0:21:03.439931 441765 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T17:00:47.162148+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T17:00:29.178329+00:00 2023-11-02T17:00:30.192259+00:00 0:00:01.013930 441764 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T17:00:27.163716+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T16:00:00+00:00 PythonOperator 2023-11-02T17:00:07.352948+00:00 2023-11-02T17:00:09.487797+00:00 0:00:02.134849 441763 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T17:00:05.097209+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T15:00:00+00:00 EmrJobFlowSensor 2023-11-02T16:00:48.492599+00:00 2023-11-02T16:20:51.763832+00:00 0:20:03.271233 441748 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T16:00:46.491276+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T16:00:26.577419+00:00 2023-11-02T16:00:27.549998+00:00 0:00:00.972579 441747 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T16:00:24.534708+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T15:00:00+00:00 PythonOperator 2023-11-02T16:00:06.484149+00:00 2023-11-02T16:00:08.725508+00:00 0:00:02.241359 441745 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T16:00:04.409638+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T14:00:00+00:00 EmrJobFlowSensor 2023-11-02T15:08:49.831761+00:00 2023-11-02T15:19:51.745014+00:00 0:11:01.913253 441732 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T15:08:47.148782+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T15:00:35.537740+00:00 2023-11-02T15:00:36.528301+00:00 0:00:00.990561 441729 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T15:00:33.639002+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T14:00:00+00:00 PythonOperator 2023-11-02T15:00:13.763488+00:00 2023-11-02T15:00:15.961711+00:00 0:00:02.198223 441728 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T15:00:11.664442+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T13:00:00+00:00 EmrJobFlowSensor 2023-11-02T14:04:26.346709+00:00 2023-11-02T14:28:29.897065+00:00 0:24:03.550356 441713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T14:04:24.361491+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T14:04:06.406981+00:00 2023-11-02T14:04:07.437508+00:00 0:00:01.030527 441712 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T14:04:04.342256+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T13:00:00+00:00 PythonOperator 2023-11-02T14:03:44.386745+00:00 2023-11-02T14:03:46.482207+00:00 0:00:02.095462 441710 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T14:03:42.325809+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T12:00:00+00:00 EmrJobFlowSensor 2023-11-02T13:24:05.285662+00:00 2023-11-02T13:49:09.025746+00:00 0:25:03.740084 441706 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T13:24:03.298077+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T13:23:45.567787+00:00 2023-11-02T13:23:46.613583+00:00 0:00:01.045796 441705 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T13:23:43.283799+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T12:00:00+00:00 PythonOperator 2023-11-02T13:00:18.661553+00:00 2023-11-02T13:00:20.800700+00:00 0:00:02.139147 441694 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T13:00:16.442265+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T11:00:00+00:00 EmrJobFlowSensor 2023-11-02T12:57:28.403365+00:00 2023-11-02T13:22:32.147336+00:00 0:25:03.743971 441692 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T12:57:26.265500+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T12:57:08.596765+00:00 2023-11-02T12:57:09.795369+00:00 0:00:01.198604 441691 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T12:57:06.330675+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T10:00:00+00:00 EmrJobFlowSensor 2023-11-02T12:32:40.195686+00:00 2023-11-02T12:56:43.771891+00:00 0:24:03.576205 441686 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T12:32:36.345041+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T11:00:00+00:00 PythonOperator 2023-11-02T12:32:40.148714+00:00 2023-11-02T12:32:42.401260+00:00 0:00:02.252546 441685 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T12:32:36.345071+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T12:32:16.271284+00:00 2023-11-02T12:32:17.355679+00:00 0:00:01.084395 441684 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T12:32:14.260673+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T10:00:00+00:00 PythonOperator 2023-11-02T12:06:54.359100+00:00 2023-11-02T12:06:57.393391+00:00 0:00:03.034291 441676 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T12:06:50.745245+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T09:00:00+00:00 EmrJobFlowSensor 2023-11-02T12:06:54.326163+00:00 2023-11-02T12:31:58.388626+00:00 0:25:04.062463 441675 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T12:06:50.745213+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T12:06:34.793645+00:00 2023-11-02T12:06:36.338584+00:00 0:00:01.544939 441673 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T12:06:30.790461+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T08:00:00+00:00 EmrJobFlowSensor 2023-11-02T11:41:14.553171+00:00 2023-11-02T12:06:18.354068+00:00 0:25:03.800897 441668 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T11:41:10.844060+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T09:00:00+00:00 PythonOperator 2023-11-02T11:41:14.490228+00:00 2023-11-02T11:41:16.734183+00:00 0:00:02.243955 441667 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T11:41:10.844092+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T11:40:52.877144+00:00 2023-11-02T11:40:53.924172+00:00 0:00:01.047028 441666 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T11:40:50.772495+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T08:00:00+00:00 PythonOperator 2023-11-02T11:23:27.450244+00:00 2023-11-02T11:23:29.955021+00:00 0:00:02.504777 441662 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T11:23:23.733681+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T07:00:00+00:00 EmrJobFlowSensor 2023-11-02T11:23:27.428516+00:00 2023-11-02T11:40:30.541866+00:00 0:17:03.113350 441661 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T11:23:23.733653+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T11:16:48.691028+00:00 2023-11-02T11:16:49.584383+00:00 0:00:00.893355 441658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T11:16:46.677024+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T06:00:00+00:00 EmrJobFlowSensor 2023-11-02T10:51:24.980426+00:00 2023-11-02T11:16:28.804014+00:00 0:25:03.823588 441648 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T10:51:21.477119+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T07:00:00+00:00 PythonOperator 2023-11-02T10:51:24.976152+00:00 2023-11-02T10:51:27.237673+00:00 0:00:02.261521 441647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T10:51:21.477150+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T10:51:01.582339+00:00 2023-11-02T10:51:02.648090+00:00 0:00:01.065751 441645 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T10:50:59.457748+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T05:00:00+00:00 EmrJobFlowSensor 2023-11-02T10:22:55.982523+00:00 2023-11-02T10:46:59.708333+00:00 0:24:03.725810 441639 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T10:22:52.199035+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T06:00:00+00:00 PythonOperator 2023-11-02T10:22:55.964178+00:00 2023-11-02T10:22:58.344502+00:00 0:00:02.380324 441638 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T10:22:52.199071+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T10:22:34.554068+00:00 2023-11-02T10:22:35.667461+00:00 0:00:01.113393 441636 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T10:22:32.182271+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T05:00:00+00:00 PythonOperator 2023-11-02T09:39:35.684772+00:00 2023-11-02T09:39:38.054766+00:00 0:00:02.369994 441630 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T09:39:32.031836+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T04:00:00+00:00 EmrJobFlowSensor 2023-11-02T09:39:35.685635+00:00 2023-11-02T10:03:39.331506+00:00 0:24:03.645871 441629 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T09:39:32.031807+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T09:39:12.273147+00:00 2023-11-02T09:39:13.244043+00:00 0:00:00.970896 441628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T09:39:10.080234+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T03:00:00+00:00 EmrJobFlowSensor 2023-11-02T09:14:52.475450+00:00 2023-11-02T09:38:55.963433+00:00 0:24:03.487983 441622 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T09:14:48.929325+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T04:00:00+00:00 PythonOperator 2023-11-02T09:14:52.449731+00:00 2023-11-02T09:14:54.704052+00:00 0:00:02.254321 441621 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T09:14:48.929355+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T09:14:30.951099+00:00 2023-11-02T09:14:31.988857+00:00 0:00:01.037758 441620 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T09:14:28.912099+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T02:00:00+00:00 EmrJobFlowSensor 2023-11-02T08:49:12.495437+00:00 2023-11-02T09:13:16.389853+00:00 0:24:03.894416 441609 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T08:49:08.564943+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T03:00:00+00:00 PythonOperator 2023-11-02T08:49:12.463838+00:00 2023-11-02T08:49:14.667148+00:00 0:00:02.203310 441608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T08:49:08.564971+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T08:48:48.637384+00:00 2023-11-02T08:48:49.837010+00:00 0:00:01.199626 441607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T08:48:46.492642+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T01:00:00+00:00 EmrJobFlowSensor 2023-11-02T08:23:33.085427+00:00 2023-11-02T08:48:36.935415+00:00 0:25:03.849988 441602 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T08:23:29.416261+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T02:00:00+00:00 PythonOperator 2023-11-02T08:23:33.068792+00:00 2023-11-02T08:23:35.280994+00:00 0:00:02.212202 441601 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T08:23:29.416291+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T08:23:11.232164+00:00 2023-11-02T08:23:12.561500+00:00 0:00:01.329336 441600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T08:23:07.396828+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-02T00:00:00+00:00 EmrJobFlowSensor 2023-11-02T07:55:12.695048+00:00 2023-11-02T08:19:16.380998+00:00 0:24:03.685950 441590 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T07:55:09.085489+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T01:00:00+00:00 PythonOperator 2023-11-02T07:55:12.666151+00:00 2023-11-02T07:55:14.896743+00:00 0:00:02.230592 441589 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T07:55:09.085520+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-02T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T07:54:49.291666+00:00 2023-11-02T07:54:50.367449+00:00 0:00:01.075783 441588 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T07:54:47.064510+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-02T00:00:00+00:00 PythonOperator 2023-11-02T06:55:30.754816+00:00 2023-11-02T06:55:32.906719+00:00 0:00:02.151903 441575 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T06:55:27.089500+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-01T23:00:00+00:00 EmrJobFlowSensor 2023-11-02T06:55:30.722951+00:00 2023-11-02T07:54:38.835158+00:00 0:59:08.112207 441574 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-02T06:55:27.089469+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-02T06:55:09.133873+00:00 2023-11-02T06:55:10.244529+00:00 0:00:01.110656 441573 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-02T06:55:07.135184+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-01T23:00:00+00:00 PythonOperator 2023-11-02T06:54:47.179233+00:00 2023-11-02T06:54:49.300451+00:00 0:00:02.121218 441572 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-02T06:54:45.047291+00:00 2 default_pool