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-22T00:00:00+00:00 PythonOperator 2023-11-22T01:00:07.254114+00:00 2023-11-22T01:00:09.566742+00:00 0:00:02.312628 448923 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-22T01:00:04.969994+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T23:00:00+00:00 EmrJobFlowSensor 2023-11-22T00:00:46.346583+00:00 2023-11-22T00:26:50.264742+00:00 0:26:03.918159 448911 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-22T00:00:44.736808+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-22T00:00:26.758996+00:00 2023-11-22T00:00:28.001778+00:00 0:00:01.242782 448910 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-22T00:00:24.721140+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T23:00:00+00:00 PythonOperator 2023-11-22T00:00:04.579310+00:00 2023-11-22T00:00:06.593308+00:00 0:00:02.013998 448909 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-22T00:00:02.701558+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T22:00:00+00:00 EmrJobFlowSensor 2023-11-21T23:00:48.368525+00:00 2023-11-21T23:26:52.436639+00:00 0:26:04.068114 448896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T23:00:46.730690+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T23:00:26.350823+00:00 2023-11-21T23:00:27.402692+00:00 0:00:01.051869 448894 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T23:00:24.714961+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T22:00:00+00:00 PythonOperator 2023-11-21T23:00:06.812800+00:00 2023-11-21T23:00:08.995487+00:00 0:00:02.182687 448892 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T23:00:04.697286+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T21:00:00+00:00 EmrJobFlowSensor 2023-11-21T22:00:57.060006+00:00 2023-11-21T22:24:00.936281+00:00 0:23:03.876275 448880 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T22:00:55.294349+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T22:00:34.968767+00:00 2023-11-21T22:00:35.988248+00:00 0:00:01.019481 448879 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T22:00:33.285398+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T21:00:00+00:00 PythonOperator 2023-11-21T22:00:15.302339+00:00 2023-11-21T22:00:17.530514+00:00 0:00:02.228175 448878 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T22:00:13.222258+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T20:00:00+00:00 EmrJobFlowSensor 2023-11-21T21:00:53.551947+00:00 2023-11-21T21:25:57.342331+00:00 0:25:03.790384 448866 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T21:00:51.860352+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T21:00:31.926929+00:00 2023-11-21T21:00:33.146150+00:00 0:00:01.219221 448865 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T21:00:29.804797+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T20:00:00+00:00 PythonOperator 2023-11-21T21:00:11.564516+00:00 2023-11-21T21:00:13.473054+00:00 0:00:01.908538 448864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T21:00:09.785740+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T19:00:00+00:00 EmrJobFlowSensor 2023-11-21T20:00:45.305527+00:00 2023-11-21T20:27:49.376252+00:00 0:27:04.070725 448852 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T20:00:43.294472+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T20:00:25.169257+00:00 2023-11-21T20:00:26.095027+00:00 0:00:00.925770 448851 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T20:00:23.216319+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T19:00:00+00:00 PythonOperator 2023-11-21T20:00:03.298444+00:00 2023-11-21T20:00:05.661260+00:00 0:00:02.362816 448850 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T20:00:01.199767+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T18:00:00+00:00 EmrJobFlowSensor 2023-11-21T19:01:03.961377+00:00 2023-11-21T19:27:07.899156+00:00 0:26:03.937779 448838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T19:01:02.334476+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T19:00:42.341247+00:00 2023-11-21T19:00:43.395141+00:00 0:00:01.053894 448837 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T19:00:40.313186+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T18:00:00+00:00 PythonOperator 2023-11-21T19:00:22.068931+00:00 2023-11-21T19:00:24.014437+00:00 0:00:01.945506 448836 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T19:00:20.293514+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T17:00:00+00:00 EmrJobFlowSensor 2023-11-21T18:01:02.771292+00:00 2023-11-21T18:27:06.669010+00:00 0:26:03.897718 448824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T18:01:01.131613+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T18:00:41.173521+00:00 2023-11-21T18:00:42.327725+00:00 0:00:01.154204 448823 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T18:00:39.164025+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T17:00:00+00:00 PythonOperator 2023-11-21T18:00:21.222430+00:00 2023-11-21T18:00:23.494634+00:00 0:00:02.272204 448822 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T18:00:19.093850+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T16:00:00+00:00 EmrJobFlowSensor 2023-11-21T17:00:52.683069+00:00 2023-11-21T17:24:56.415187+00:00 0:24:03.732118 448810 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T17:00:50.986243+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T17:00:30.906777+00:00 2023-11-21T17:00:31.944823+00:00 0:00:01.038046 448809 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T17:00:28.962702+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T16:00:00+00:00 PythonOperator 2023-11-21T17:00:11.188715+00:00 2023-11-21T17:00:13.414716+00:00 0:00:02.226001 448808 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T17:00:08.942402+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T15:00:00+00:00 EmrJobFlowSensor 2023-11-21T16:01:07.100349+00:00 2023-11-21T16:27:11.150684+00:00 0:26:04.050335 448796 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T16:01:05.116208+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T16:00:44.848802+00:00 2023-11-21T16:00:45.915156+00:00 0:00:01.066354 448795 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T16:00:43.154154+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T15:00:00+00:00 PythonOperator 2023-11-21T16:00:25.020813+00:00 2023-11-21T16:00:26.998829+00:00 0:00:01.978016 448794 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T16:00:23.083555+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T14:00:00+00:00 EmrJobFlowSensor 2023-11-21T15:01:02.902745+00:00 2023-11-21T15:26:06.783339+00:00 0:25:03.880594 448785 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T15:01:01.067607+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T15:00:40.654457+00:00 2023-11-21T15:00:41.571199+00:00 0:00:00.916742 448784 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T15:00:38.990228+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T14:00:00+00:00 PythonOperator 2023-11-21T15:00:20.778112+00:00 2023-11-21T15:00:22.772902+00:00 0:00:01.994790 448783 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T15:00:18.986737+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T13:00:00+00:00 EmrJobFlowSensor 2023-11-21T14:00:49.169468+00:00 2023-11-21T14:25:52.975504+00:00 0:25:03.806036 448773 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T14:00:47.530640+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T14:00:27.573621+00:00 2023-11-21T14:00:28.518442+00:00 0:00:00.944821 448772 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T14:00:25.563188+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T13:00:00+00:00 PythonOperator 2023-11-21T14:00:07.584962+00:00 2023-11-21T14:00:09.764123+00:00 0:00:02.179161 448771 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T14:00:05.490495+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T12:00:00+00:00 EmrJobFlowSensor 2023-11-21T13:00:52.742077+00:00 2023-11-21T13:25:56.800098+00:00 0:25:04.058021 448760 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T13:00:50.709196+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T13:00:32.451819+00:00 2023-11-21T13:00:33.465552+00:00 0:00:01.013733 448759 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T13:00:30.691668+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T12:00:00+00:00 PythonOperator 2023-11-21T13:00:10.699186+00:00 2023-11-21T13:00:12.921613+00:00 0:00:02.222427 448758 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T13:00:08.639826+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T11:00:00+00:00 EmrJobFlowSensor 2023-11-21T12:00:55.090417+00:00 2023-11-21T12:25:59.019783+00:00 0:25:03.929366 448746 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T12:00:53.073967+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T12:00:33.104409+00:00 2023-11-21T12:00:34.080413+00:00 0:00:00.976004 448745 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T12:00:31.090826+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T11:00:00+00:00 PythonOperator 2023-11-21T12:00:13.176632+00:00 2023-11-21T12:00:15.396467+00:00 0:00:02.219835 448744 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T12:00:11.031763+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T10:00:00+00:00 EmrJobFlowSensor 2023-11-21T11:01:02.102542+00:00 2023-11-21T11:26:05.888128+00:00 0:25:03.785586 448732 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T11:01:00.358129+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T11:00:40.261285+00:00 2023-11-21T11:00:41.228171+00:00 0:00:00.966886 448731 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T11:00:38.291267+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T10:00:00+00:00 PythonOperator 2023-11-21T11:00:20.382754+00:00 2023-11-21T11:00:22.639017+00:00 0:00:02.256263 448730 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T11:00:18.273922+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T09:00:00+00:00 EmrJobFlowSensor 2023-11-21T10:00:51.147113+00:00 2023-11-21T10:25:55.051862+00:00 0:25:03.904749 448719 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T10:00:49.090110+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T10:00:30.745766+00:00 2023-11-21T10:00:31.777522+00:00 0:00:01.031756 448718 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T10:00:29.072284+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T09:00:00+00:00 PythonOperator 2023-11-21T10:00:08.965897+00:00 2023-11-21T10:00:10.913194+00:00 0:00:01.947297 448717 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T10:00:07.095705+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T08:00:00+00:00 EmrJobFlowSensor 2023-11-21T09:01:43.493175+00:00 2023-11-21T09:26:47.235712+00:00 0:25:03.742537 448705 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T09:01:41.509910+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T09:01:23.151131+00:00 2023-11-21T09:01:24.088844+00:00 0:00:00.937713 448704 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T09:01:21.490258+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T08:00:00+00:00 PythonOperator 2023-11-21T09:01:01.267658+00:00 2023-11-21T09:01:03.242551+00:00 0:00:01.974893 448703 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T09:00:59.468237+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T07:00:00+00:00 EmrJobFlowSensor 2023-11-21T08:01:04.950425+00:00 2023-11-21T08:27:08.996082+00:00 0:26:04.045657 448691 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T08:01:02.959854+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T08:00:44.553373+00:00 2023-11-21T08:00:45.610666+00:00 0:00:01.057293 448690 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T08:00:42.847518+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T07:00:00+00:00 PythonOperator 2023-11-21T08:00:22.890969+00:00 2023-11-21T08:00:25.123570+00:00 0:00:02.232601 448689 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T08:00:20.826345+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T06:00:00+00:00 EmrJobFlowSensor 2023-11-21T07:00:55.688833+00:00 2023-11-21T07:26:59.649340+00:00 0:26:03.960507 448679 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T07:00:54.017085+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T07:00:33.661985+00:00 2023-11-21T07:00:34.695464+00:00 0:00:01.033479 448678 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T07:00:31.996949+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T06:00:00+00:00 PythonOperator 2023-11-21T07:00:14.033475+00:00 2023-11-21T07:00:16.304423+00:00 0:00:02.270948 448677 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T07:00:11.932071+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T05:00:00+00:00 EmrJobFlowSensor 2023-11-21T06:00:47.859054+00:00 2023-11-21T06:25:51.746315+00:00 0:25:03.887261 448665 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T06:00:45.922995+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T06:00:27.823125+00:00 2023-11-21T06:00:29.101769+00:00 0:00:01.278644 448664 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T06:00:25.905340+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T05:00:00+00:00 PythonOperator 2023-11-21T06:00:06.270141+00:00 2023-11-21T06:00:08.498635+00:00 0:00:02.228494 448663 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T06:00:03.885756+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T04:00:00+00:00 EmrJobFlowSensor 2023-11-21T05:00:50.358483+00:00 2023-11-21T05:25:54.444800+00:00 0:25:04.086317 448651 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T05:00:48.380690+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T05:00:30.091006+00:00 2023-11-21T05:00:31.140877+00:00 0:00:01.049871 448650 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T05:00:28.362302+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T04:00:00+00:00 PythonOperator 2023-11-21T05:00:08.571308+00:00 2023-11-21T05:00:10.862578+00:00 0:00:02.291270 448649 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T05:00:06.342133+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T03:00:00+00:00 EmrJobFlowSensor 2023-11-21T04:01:01.698492+00:00 2023-11-21T04:26:05.763696+00:00 0:25:04.065204 448637 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T04:00:59.690644+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T04:00:41.297850+00:00 2023-11-21T04:00:42.351675+00:00 0:00:01.053825 448635 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T04:00:39.638754+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T03:00:00+00:00 PythonOperator 2023-11-21T04:00:19.579484+00:00 2023-11-21T04:00:21.826185+00:00 0:00:02.246701 448633 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T04:00:17.612330+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T02:00:00+00:00 EmrJobFlowSensor 2023-11-21T03:26:00.579956+00:00 2023-11-21T03:51:04.542848+00:00 0:25:03.962892 448626 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T03:25:58.920373+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T03:25:38.648991+00:00 2023-11-21T03:25:39.647055+00:00 0:00:00.998064 448625 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T03:25:36.902488+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T02:00:00+00:00 PythonOperator 2023-11-21T03:01:32.572293+00:00 2023-11-21T03:01:34.811962+00:00 0:00:02.239669 448618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T03:01:30.643531+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T01:00:00+00:00 EmrJobFlowSensor 2023-11-21T03:01:32.239140+00:00 2023-11-21T03:25:35.823564+00:00 0:24:03.584424 448617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T03:01:30.643503+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T03:01:12.893955+00:00 2023-11-21T03:01:13.899126+00:00 0:00:01.005171 448616 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T03:01:10.682362+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T01:00:00+00:00 PythonOperator 2023-11-21T02:35:51.500999+00:00 2023-11-21T02:35:53.735736+00:00 0:00:02.234737 448612 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T02:35:49.521259+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-21T00:00:00+00:00 EmrJobFlowSensor 2023-11-21T02:35:51.173230+00:00 2023-11-21T03:00:54.923905+00:00 0:25:03.750675 448611 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T02:35:49.521233+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-21T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T02:35:29.661526+00:00 2023-11-21T02:35:30.954600+00:00 0:00:01.293074 448610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T02:35:27.504038+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-21T00:00:00+00:00 PythonOperator 2023-11-21T02:10:03.773591+00:00 2023-11-21T02:10:06.204612+00:00 0:00:02.431021 448605 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T02:10:01.750529+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T23:00:00+00:00 EmrJobFlowSensor 2023-11-21T02:10:03.437945+00:00 2023-11-21T02:35:07.219413+00:00 0:25:03.781468 448604 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T02:10:01.750501+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T02:09:41.773625+00:00 2023-11-21T02:09:42.831068+00:00 0:00:01.057443 448603 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T02:09:39.757972+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T22:00:00+00:00 EmrJobFlowSensor 2023-11-21T01:45:21.972331+00:00 2023-11-21T02:09:25.584848+00:00 0:24:03.612517 448596 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T01:45:19.981711+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T23:00:00+00:00 PythonOperator 2023-11-21T01:45:21.652194+00:00 2023-11-21T01:45:23.599459+00:00 0:00:01.947265 448595 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T01:45:19.981758+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T01:45:00.450943+00:00 2023-11-21T01:45:01.458591+00:00 0:00:01.007648 448594 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T01:44:57.976686+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T22:00:00+00:00 PythonOperator 2023-11-21T01:21:45.608298+00:00 2023-11-21T01:21:47.830278+00:00 0:00:02.221980 448584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T01:21:43.627449+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T21:00:00+00:00 EmrJobFlowSensor 2023-11-21T01:21:45.335450+00:00 2023-11-21T01:44:48.932305+00:00 0:23:03.596855 448583 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T01:21:43.627423+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T01:21:25.543418+00:00 2023-11-21T01:21:26.530358+00:00 0:00:00.986940 448582 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T01:21:23.656251+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T20:00:00+00:00 EmrJobFlowSensor 2023-11-21T00:58:38.451609+00:00 2023-11-21T01:20:41.926283+00:00 0:22:03.474674 448575 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T00:58:36.502297+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T21:00:00+00:00 PythonOperator 2023-11-21T00:58:38.156074+00:00 2023-11-21T00:58:40.074872+00:00 0:00:01.918798 448574 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T00:58:36.502324+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T00:58:18.584362+00:00 2023-11-21T00:58:19.775749+00:00 0:00:01.191387 448573 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T00:58:16.483050+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T19:00:00+00:00 EmrJobFlowSensor 2023-11-21T00:34:58.027124+00:00 2023-11-21T00:58:01.709488+00:00 0:23:03.682364 448568 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T00:34:56.024199+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T20:00:00+00:00 PythonOperator 2023-11-21T00:34:57.716086+00:00 2023-11-21T00:34:59.728340+00:00 0:00:02.012254 448567 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T00:34:56.024231+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T00:34:35.789515+00:00 2023-11-21T00:34:36.869124+00:00 0:00:01.079609 448566 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T00:34:34.001499+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T19:00:00+00:00 PythonOperator 2023-11-21T00:12:24.870081+00:00 2023-11-21T00:12:27.117036+00:00 0:00:02.246955 448562 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-21T00:12:22.769303+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T18:00:00+00:00 EmrJobFlowSensor 2023-11-21T00:12:24.540257+00:00 2023-11-21T00:34:27.963330+00:00 0:22:03.423073 448561 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-21T00:12:22.769265+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-21T00:12:04.761849+00:00 2023-11-21T00:12:05.797583+00:00 0:00:01.035734 448560 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-21T00:12:02.759908+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T17:00:00+00:00 EmrJobFlowSensor 2023-11-20T23:49:44.837218+00:00 2023-11-21T00:11:48.376654+00:00 0:22:03.539436 448553 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T23:49:42.842019+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T18:00:00+00:00 PythonOperator 2023-11-20T23:49:44.541211+00:00 2023-11-20T23:49:46.482950+00:00 0:00:01.941739 448552 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T23:49:42.842047+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T23:49:24.794989+00:00 2023-11-20T23:49:25.742625+00:00 0:00:00.947636 448551 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T23:49:22.825360+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T16:00:00+00:00 EmrJobFlowSensor 2023-11-20T23:26:11.677186+00:00 2023-11-20T23:49:15.223960+00:00 0:23:03.546774 448547 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T23:26:09.654134+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T17:00:00+00:00 PythonOperator 2023-11-20T23:26:11.359524+00:00 2023-11-20T23:26:13.267531+00:00 0:00:01.908007 448546 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T23:26:09.654169+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T23:25:51.732935+00:00 2023-11-20T23:25:52.730404+00:00 0:00:00.997469 448545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T23:25:49.592194+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T16:00:00+00:00 PythonOperator 2023-11-20T23:00:38.985195+00:00 2023-11-20T23:00:41.192386+00:00 0:00:02.207191 448537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T23:00:37.015444+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T15:00:00+00:00 EmrJobFlowSensor 2023-11-20T23:00:38.948125+00:00 2023-11-20T23:25:42.902269+00:00 0:25:03.954144 448536 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T23:00:37.015413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T23:00:16.677476+00:00 2023-11-20T23:00:17.731208+00:00 0:00:01.053732 448534 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T23:00:14.996354+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T15:00:00+00:00 PythonOperator 2023-11-20T22:34:55.357684+00:00 2023-11-20T22:34:57.559014+00:00 0:00:02.201330 448528 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T22:34:53.415590+00:00 2 default_pool