Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T14:00:00+00:00 PythonOperator 2023-11-07T15:15:37.795632+00:00 2023-11-07T15:15:39.993026+00:00 0:00:02.197394 444066 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T15:15:34.154324+00:00 3 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T12:00:00+00:00 EmrJobFlowSensor 2023-11-07T13:04:13.444908+00:00 2023-11-07T13:28:16.941333+00:00 0:24:03.496425 444008 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T13:04:11.522969+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T13:03:53.448194+00:00 2023-11-07T13:03:54.481304+00:00 0:00:01.033110 444007 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T13:03:51.503426+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T12:00:00+00:00 PythonOperator 2023-11-07T13:03:31.870477+00:00 2023-11-07T13:03:33.996136+00:00 0:00:02.125659 444005 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T13:03:29.489939+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T11:00:00+00:00 EmrJobFlowSensor 2023-11-07T12:00:55.555768+00:00 2023-11-07T12:25:59.086705+00:00 0:25:03.530937 443990 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T12:00:53.584297+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T12:00:33.545539+00:00 2023-11-07T12:00:34.527335+00:00 0:00:00.981796 443989 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T12:00:31.538229+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T11:00:00+00:00 PythonOperator 2023-11-07T12:00:13.991931+00:00 2023-11-07T12:00:16.105344+00:00 0:00:02.113413 443987 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T12:00:11.558440+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T10:00:00+00:00 EmrJobFlowSensor 2023-11-07T11:07:17.808996+00:00 2023-11-07T11:32:21.422415+00:00 0:25:03.613419 443975 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T11:07:15.673926+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T11:06:55.549362+00:00 2023-11-07T11:06:56.579346+00:00 0:00:01.029984 443973 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T11:06:53.646011+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T10:00:00+00:00 PythonOperator 2023-11-07T11:06:35.545057+00:00 2023-11-07T11:06:38.606369+00:00 0:00:03.061312 443970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T11:06:33.625783+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T09:00:00+00:00 EmrJobFlowSensor 2023-11-07T10:01:40.345829+00:00 2023-11-07T10:27:44.206060+00:00 0:26:03.860231 443953 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T10:01:38.381142+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T10:01:20.256395+00:00 2023-11-07T10:01:21.315390+00:00 0:00:01.058995 443952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T10:01:18.356553+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T09:00:00+00:00 PythonOperator 2023-11-07T10:00:58.721269+00:00 2023-11-07T10:01:00.905275+00:00 0:00:02.184006 443950 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T10:00:56.396523+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T08:00:00+00:00 EmrJobFlowSensor 2023-11-07T09:01:41.707863+00:00 2023-11-07T09:26:45.469338+00:00 0:25:03.761475 443934 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T09:01:39.669547+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T09:01:19.574435+00:00 2023-11-07T09:01:20.643084+00:00 0:00:01.068649 443933 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T09:01:17.655590+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T08:00:00+00:00 PythonOperator 2023-11-07T09:00:59.573706+00:00 2023-11-07T09:01:01.699928+00:00 0:00:02.126222 443932 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T09:00:57.623317+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T07:00:00+00:00 EmrJobFlowSensor 2023-11-07T08:00:57.985787+00:00 2023-11-07T08:27:01.920741+00:00 0:26:03.934954 443915 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T08:00:55.971038+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T08:00:36.006679+00:00 2023-11-07T08:00:37.071912+00:00 0:00:01.065233 443914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T08:00:33.949608+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T07:00:00+00:00 PythonOperator 2023-11-07T08:00:15.966961+00:00 2023-11-07T08:00:19.041480+00:00 0:00:03.074519 443912 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T08:00:13.887744+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T06:00:00+00:00 EmrJobFlowSensor 2023-11-07T07:01:05.931701+00:00 2023-11-07T07:26:09.472803+00:00 0:25:03.541102 443896 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T07:01:03.930155+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T07:00:43.846760+00:00 2023-11-07T07:00:45.096959+00:00 0:00:01.250199 443895 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T07:00:41.908420+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T06:00:00+00:00 PythonOperator 2023-11-07T07:00:23.859558+00:00 2023-11-07T07:00:26.084949+00:00 0:00:02.225391 443894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T07:00:21.895772+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T05:00:00+00:00 EmrJobFlowSensor 2023-11-07T06:00:53.649764+00:00 2023-11-07T06:24:57.233793+00:00 0:24:03.584029 443877 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T06:00:51.651232+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T06:00:33.550753+00:00 2023-11-07T06:00:34.616547+00:00 0:00:01.065794 443876 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T06:00:31.631568+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T05:00:00+00:00 PythonOperator 2023-11-07T06:00:11.573887+00:00 2023-11-07T06:00:13.722575+00:00 0:00:02.148688 443875 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T06:00:09.613845+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T04:00:00+00:00 EmrJobFlowSensor 2023-11-07T05:00:50.626705+00:00 2023-11-07T05:24:54.198982+00:00 0:24:03.572277 443859 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T05:00:48.728616+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T05:00:28.645932+00:00 2023-11-07T05:00:29.798708+00:00 0:00:01.152776 443858 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T05:00:26.711923+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T04:00:00+00:00 PythonOperator 2023-11-07T05:00:08.801772+00:00 2023-11-07T05:00:10.908340+00:00 0:00:02.106568 443856 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T05:00:06.692157+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T03:00:00+00:00 EmrJobFlowSensor 2023-11-07T04:01:05.446101+00:00 2023-11-07T04:26:09.261048+00:00 0:25:03.814947 443839 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T04:01:03.432472+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T04:00:45.305851+00:00 2023-11-07T04:00:47.000643+00:00 0:00:01.694792 443837 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T04:00:43.343617+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T03:00:00+00:00 PythonOperator 2023-11-07T04:00:23.339903+00:00 2023-11-07T04:00:25.518110+00:00 0:00:02.178207 443835 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T04:00:21.323344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T02:00:00+00:00 EmrJobFlowSensor 2023-11-07T03:01:03.284633+00:00 2023-11-07T03:25:06.913369+00:00 0:24:03.628736 443817 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T03:01:01.242290+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T03:00:41.159334+00:00 2023-11-07T03:00:42.530907+00:00 0:00:01.371573 443816 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T03:00:39.175317+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T02:00:00+00:00 PythonOperator 2023-11-07T03:00:21.168365+00:00 2023-11-07T03:00:23.288918+00:00 0:00:02.120553 443815 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T03:00:19.157379+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T01:00:00+00:00 EmrJobFlowSensor 2023-11-07T02:00:54.050201+00:00 2023-11-07T02:24:57.693171+00:00 0:24:03.642970 443798 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T02:00:52.078017+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T02:00:32.122481+00:00 2023-11-07T02:00:33.075838+00:00 0:00:00.953357 443797 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T02:00:30.042215+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T01:00:00+00:00 PythonOperator 2023-11-07T02:00:11.970715+00:00 2023-11-07T02:00:14.099074+00:00 0:00:02.128359 443796 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T02:00:10.019420+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T00:00:00+00:00 EmrJobFlowSensor 2023-11-07T01:00:51.189882+00:00 2023-11-07T01:24:54.582919+00:00 0:24:03.393037 443774 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T01:00:49.060933+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T01:00:31.247933+00:00 2023-11-07T01:00:32.369554+00:00 0:00:01.121621 443773 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T01:00:29.044527+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T00:00:00+00:00 PythonOperator 2023-11-07T01:00:09.224867+00:00 2023-11-07T01:00:11.462634+00:00 0:00:02.237767 443771 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T01:00:07.027525+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T23:00:00+00:00 EmrJobFlowSensor 2023-11-07T00:00:46.802754+00:00 2023-11-07T00:25:50.465690+00:00 0:25:03.662936 443755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T00:00:44.731204+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T00:00:26.624008+00:00 2023-11-07T00:00:27.629958+00:00 0:00:01.005950 443754 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T00:00:24.636911+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T23:00:00+00:00 PythonOperator 2023-11-07T00:00:04.689268+00:00 2023-11-07T00:00:06.778825+00:00 0:00:02.089557 443752 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T00:00:02.620485+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T22:00:00+00:00 EmrJobFlowSensor 2023-11-06T23:01:01.891243+00:00 2023-11-06T23:26:05.989832+00:00 0:25:04.098589 443736 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T23:00:59.912056+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T23:00:40.092829+00:00 2023-11-06T23:00:41.105740+00:00 0:00:01.012911 443734 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T23:00:37.949273+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T22:00:00+00:00 PythonOperator 2023-11-06T23:00:17.981490+00:00 2023-11-06T23:00:20.353799+00:00 0:00:02.372309 443732 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T23:00:15.930328+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T21:00:00+00:00 EmrJobFlowSensor 2023-11-06T22:00:50.350380+00:00 2023-11-06T22:20:53.371304+00:00 0:20:03.020924 443714 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T22:00:48.253741+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T22:00:28.268982+00:00 2023-11-06T22:00:29.322753+00:00 0:00:01.053771 443713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T22:00:26.229107+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T21:00:00+00:00 PythonOperator 2023-11-06T22:00:08.504261+00:00 2023-11-06T22:00:10.629507+00:00 0:00:02.125246 443712 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T22:00:06.164701+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T20:00:00+00:00 EmrJobFlowSensor 2023-11-06T21:00:52.841142+00:00 2023-11-06T21:21:55.984365+00:00 0:21:03.143223 443698 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T21:00:50.755216+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T21:00:33.057962+00:00 2023-11-06T21:00:34.004902+00:00 0:00:00.946940 443696 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T21:00:30.684479+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T20:00:00+00:00 PythonOperator 2023-11-06T21:00:10.581996+00:00 2023-11-06T21:00:12.905204+00:00 0:00:02.323208 443694 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T21:00:08.639162+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T19:00:00+00:00 EmrJobFlowSensor 2023-11-06T20:00:52.538468+00:00 2023-11-06T20:22:55.594876+00:00 0:22:03.056408 443679 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T20:00:50.459087+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T20:00:32.455234+00:00 2023-11-06T20:00:33.469405+00:00 0:00:01.014171 443677 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T20:00:30.440946+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T19:00:00+00:00 PythonOperator 2023-11-06T20:00:10.480945+00:00 2023-11-06T20:00:12.570057+00:00 0:00:02.089112 443675 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T20:00:08.371768+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T18:00:00+00:00 EmrJobFlowSensor 2023-11-06T19:00:58.272132+00:00 2023-11-06T19:23:01.498696+00:00 0:22:03.226564 443659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T19:00:56.148252+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T19:00:36.162912+00:00 2023-11-06T19:00:37.178273+00:00 0:00:01.015361 443658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T19:00:34.132020+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T18:00:00+00:00 PythonOperator 2023-11-06T19:00:17.859457+00:00 2023-11-06T19:00:20.124721+00:00 0:00:02.265264 443657 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T19:00:14.064896+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-01T15:00:00+00:00 EmrJobFlowSensor 2023-11-06T18:49:43.818161+00:00 2023-11-06T19:14:47.606802+00:00 0:25:03.788641 443654 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-01T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T18:49:35.122797+00:00 2023-11-06T18:49:36.260022+00:00 0:00:01.137225 443653 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-01T15:00:00+00:00 PythonOperator 2023-11-06T18:49:25.275702+00:00 2023-11-06T18:49:27.358473+00:00 0:00:02.082771 443651 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T17:00:00+00:00 EmrJobFlowSensor 2023-11-06T18:00:56.367405+00:00 2023-11-06T18:23:59.829369+00:00 0:23:03.461964 443637 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T18:00:54.327326+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T18:00:34.174451+00:00 2023-11-06T18:00:35.162005+00:00 0:00:00.987554 443636 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T18:00:32.248888+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T17:00:00+00:00 PythonOperator 2023-11-06T18:00:14.194270+00:00 2023-11-06T18:00:16.503252+00:00 0:00:02.308982 443635 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T18:00:12.220889+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T16:00:00+00:00 EmrJobFlowSensor 2023-11-06T17:01:04.142253+00:00 2023-11-06T17:22:07.409121+00:00 0:21:03.266868 443618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T17:01:02.111015+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T17:00:42.108607+00:00 2023-11-06T17:00:43.295343+00:00 0:00:01.186736 443617 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T17:00:40.092797+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T16:00:00+00:00 PythonOperator 2023-11-06T17:00:21.786375+00:00 2023-11-06T17:00:24.070560+00:00 0:00:02.284185 443616 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T17:00:18.080390+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T15:00:00+00:00 EmrJobFlowSensor 2023-11-06T16:00:55.065450+00:00 2023-11-06T16:24:58.688404+00:00 0:24:03.622954 443599 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T16:00:53.042360+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T16:00:33.068946+00:00 2023-11-06T16:00:34.115603+00:00 0:00:01.046657 443598 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T16:00:31.027159+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T15:00:00+00:00 PythonOperator 2023-11-06T16:00:13.090744+00:00 2023-11-06T16:00:16.292423+00:00 0:00:03.201679 443596 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T16:00:10.951315+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T14:00:00+00:00 EmrJobFlowSensor 2023-11-06T15:00:48.851629+00:00 2023-11-06T15:24:52.246141+00:00 0:24:03.394512 443580 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T15:00:46.863283+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T15:00:28.769791+00:00 2023-11-06T15:00:29.758616+00:00 0:00:00.988825 443579 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T15:00:26.843217+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T14:00:00+00:00 PythonOperator 2023-11-06T15:00:06.990051+00:00 2023-11-06T15:00:09.114114+00:00 0:00:02.124063 443577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T15:00:04.848012+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T13:00:00+00:00 EmrJobFlowSensor 2023-11-06T14:01:06.201266+00:00 2023-11-06T14:24:09.661692+00:00 0:23:03.460426 443550 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T14:01:04.144762+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T14:00:46.234556+00:00 2023-11-06T14:00:47.208841+00:00 0:00:00.974285 443549 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T14:00:44.082395+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T13:00:00+00:00 PythonOperator 2023-11-06T14:00:24.116190+00:00 2023-11-06T14:00:26.232071+00:00 0:00:02.115881 443547 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T14:00:22.050497+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T12:00:00+00:00 EmrJobFlowSensor 2023-11-06T13:04:12.499253+00:00 2023-11-06T13:27:16.003742+00:00 0:23:03.504489 443524 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T13:04:10.463071+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T13:03:50.405279+00:00 2023-11-06T13:03:51.375698+00:00 0:00:00.970419 443523 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T13:03:48.445828+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T12:00:00+00:00 PythonOperator 2023-11-06T13:03:30.874367+00:00 2023-11-06T13:03:33.019525+00:00 0:00:02.145158 443521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T13:03:28.427859+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T11:00:00+00:00 EmrJobFlowSensor 2023-11-06T12:01:00.213296+00:00 2023-11-06T12:25:03.941046+00:00 0:24:03.727750 443505 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T12:00:58.239166+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T12:00:40.164287+00:00 2023-11-06T12:00:41.170115+00:00 0:00:01.005828 443504 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T12:00:38.219617+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T11:00:00+00:00 PythonOperator 2023-11-06T12:00:20.136243+00:00 2023-11-06T12:00:22.381210+00:00 0:00:02.244967 443503 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T12:00:16.202230+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T10:00:00+00:00 EmrJobFlowSensor 2023-11-06T11:01:03.862208+00:00 2023-11-06T11:25:07.442650+00:00 0:24:03.580442 443487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T11:01:01.841151+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T11:00:41.852736+00:00 2023-11-06T11:00:42.732579+00:00 0:00:00.879843 443486 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T11:00:39.766340+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T10:00:00+00:00 PythonOperator 2023-11-06T11:00:21.659605+00:00 2023-11-06T11:00:23.750063+00:00 0:00:02.090458 443485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T11:00:19.720875+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T09:00:00+00:00 EmrJobFlowSensor 2023-11-06T10:01:02.655391+00:00 2023-11-06T10:25:06.398045+00:00 0:24:03.742654 443468 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T10:01:00.557624+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T10:00:40.646189+00:00 2023-11-06T10:00:41.668062+00:00 0:00:01.021873 443467 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T10:00:38.553786+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T09:00:00+00:00 PythonOperator 2023-11-06T10:00:22.278455+00:00 2023-11-06T10:00:24.495074+00:00 0:00:02.216619 443466 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T10:00:18.478509+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T08:00:00+00:00 EmrJobFlowSensor 2023-11-06T09:00:46.238195+00:00 2023-11-06T09:25:49.702987+00:00 0:25:03.464792 443450 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T09:00:44.185044+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T09:00:24.165432+00:00 2023-11-06T09:00:25.268791+00:00 0:00:01.103359 443449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T09:00:22.132344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T08:00:00+00:00 PythonOperator 2023-11-06T09:00:04.597625+00:00 2023-11-06T09:00:06.768563+00:00 0:00:02.170938 443447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T09:00:02.156589+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T07:00:00+00:00 EmrJobFlowSensor 2023-11-06T08:00:48.740165+00:00 2023-11-06T08:27:52.630773+00:00 0:27:03.890608 443429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T08:00:46.742447+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T08:00:26.565213+00:00 2023-11-06T08:00:28.164101+00:00 0:00:01.598888 443427 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T08:00:24.627172+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T07:00:00+00:00 PythonOperator 2023-11-06T08:00:06.582881+00:00 2023-11-06T08:00:08.717542+00:00 0:00:02.134661 443425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T08:00:04.608059+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T06:00:00+00:00 EmrJobFlowSensor 2023-11-06T07:00:59.649796+00:00 2023-11-06T07:26:03.283284+00:00 0:25:03.633488 443401 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T07:00:57.728336+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T07:00:37.784687+00:00 2023-11-06T07:00:38.742548+00:00 0:00:00.957861 443400 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T07:00:35.708046+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T06:00:00+00:00 PythonOperator 2023-11-06T07:00:17.903943+00:00 2023-11-06T07:00:21.012289+00:00 0:00:03.108346 443398 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T07:00:15.691546+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-06T05:00:00+00:00 EmrJobFlowSensor 2023-11-06T06:01:06.453083+00:00 2023-11-06T06:25:10.039266+00:00 0:24:03.586183 443382 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-06T06:01:04.457852+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-06T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-06T06:00:46.375924+00:00 2023-11-06T06:00:47.458944+00:00 0:00:01.083020 443381 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-06T06:00:44.383127+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-06T05:00:00+00:00 PythonOperator 2023-11-06T06:00:24.334193+00:00 2023-11-06T06:00:26.431115+00:00 0:00:02.096922 443380 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-06T06:00:22.364065+00:00 2 default_pool