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_cluster_and_add_emr_steps 2023-12-14T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T12:01:30.207661+00:00 2023-12-14T12:01:31.106571+00:00 0:00:00.898910 457130 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T12:01:28.029801+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T11:00:00+00:00 PythonOperator 2023-12-14T12:01:10.450840+00:00 2023-12-14T12:01:11.947697+00:00 0:00:01.496857 457128 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T12:01:08.015251+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T10:00:00+00:00 EmrJobFlowSensor 2023-12-14T11:01:20.955062+00:00 2023-12-14T11:26:24.777755+00:00 0:25:03.822693 457106 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T11:01:19.316730+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T11:01:00.972920+00:00 2023-12-14T11:01:02.501710+00:00 0:00:01.528790 457104 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T11:00:59.287923+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T10:00:00+00:00 PythonOperator 2023-12-14T11:00:39.775557+00:00 2023-12-14T11:00:41.296486+00:00 0:00:01.520929 457102 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T11:00:37.272568+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T09:00:00+00:00 EmrJobFlowSensor 2023-12-14T10:01:39.957985+00:00 2023-12-14T10:27:44.034555+00:00 0:26:04.076570 457085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T10:01:37.906893+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T10:01:20.342673+00:00 2023-12-14T10:01:21.353108+00:00 0:00:01.010435 457083 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T10:01:17.891766+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T09:00:00+00:00 PythonOperator 2023-12-14T10:00:57.573211+00:00 2023-12-14T10:00:59.093807+00:00 0:00:01.520596 457081 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T10:00:55.869179+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T08:00:00+00:00 EmrJobFlowSensor 2023-12-14T09:01:55.255371+00:00 2023-12-14T09:27:59.156185+00:00 0:26:03.900814 457062 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T09:01:53.562104+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T09:01:33.203636+00:00 2023-12-14T09:01:34.191629+00:00 0:00:00.987993 457060 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T09:01:31.538732+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T08:00:00+00:00 PythonOperator 2023-12-14T09:01:13.760460+00:00 2023-12-14T09:01:15.323989+00:00 0:00:01.563529 457058 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T09:01:11.423918+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T07:00:00+00:00 EmrJobFlowSensor 2023-12-14T08:01:09.591826+00:00 2023-12-14T08:28:13.733552+00:00 0:27:04.141726 457041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T08:01:07.521142+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T08:00:49.594701+00:00 2023-12-14T08:00:50.488041+00:00 0:00:00.893340 457039 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T08:00:47.501266+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T07:00:00+00:00 PythonOperator 2023-12-14T08:00:27.569640+00:00 2023-12-14T08:00:29.076627+00:00 0:00:01.506987 457037 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T08:00:25.484907+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T06:00:00+00:00 EmrJobFlowSensor 2023-12-14T07:02:37.291057+00:00 2023-12-14T07:30:41.790812+00:00 0:28:04.499755 457019 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T07:02:35.251512+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T07:02:14.882156+00:00 2023-12-14T07:02:15.952861+00:00 0:00:01.070705 457017 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T07:02:13.230011+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T06:00:00+00:00 PythonOperator 2023-12-14T07:01:55.392669+00:00 2023-12-14T07:01:56.925931+00:00 0:00:01.533262 457015 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T07:01:53.210597+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T05:00:00+00:00 EmrJobFlowSensor 2023-12-14T06:01:47.985770+00:00 2023-12-14T06:27:51.904360+00:00 0:26:03.918590 456997 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T06:01:45.684090+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T06:01:25.346183+00:00 2023-12-14T06:01:26.384271+00:00 0:00:01.038088 456995 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T06:01:23.657268+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T05:00:00+00:00 PythonOperator 2023-12-14T06:01:05.748018+00:00 2023-12-14T06:01:07.277873+00:00 0:00:01.529855 456993 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T06:01:03.638282+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T04:00:00+00:00 EmrJobFlowSensor 2023-12-14T05:01:30.564859+00:00 2023-12-14T05:26:34.495609+00:00 0:25:03.930750 456974 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T05:01:28.887182+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T05:01:09.526839+00:00 2023-12-14T05:01:10.502242+00:00 0:00:00.975403 456972 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T05:01:06.861680+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T04:00:00+00:00 PythonOperator 2023-12-14T05:00:48.555069+00:00 2023-12-14T05:00:50.105394+00:00 0:00:01.550325 456970 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T05:00:46.846107+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T03:00:00+00:00 EmrJobFlowSensor 2023-12-14T04:00:58.908175+00:00 2023-12-14T04:27:03.243539+00:00 0:26:04.335364 456949 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T04:00:57.234741+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T04:00:37.247128+00:00 2023-12-14T04:00:38.256643+00:00 0:00:01.009515 456946 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T04:00:35.214961+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T03:00:00+00:00 PythonOperator 2023-12-14T04:00:17.271033+00:00 2023-12-14T04:00:18.775303+00:00 0:00:01.504270 456943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T04:00:15.199423+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T02:00:00+00:00 EmrJobFlowSensor 2023-12-14T03:01:11.365650+00:00 2023-12-14T03:27:15.238731+00:00 0:26:03.873081 456925 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T03:01:09.663618+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T03:00:51.897258+00:00 2023-12-14T03:00:52.829582+00:00 0:00:00.932324 456924 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T03:00:49.647125+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T02:00:00+00:00 PythonOperator 2023-12-14T03:00:30.393508+00:00 2023-12-14T03:00:32.901288+00:00 0:00:02.507780 456921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T03:00:27.628229+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T01:00:00+00:00 EmrJobFlowSensor 2023-12-14T02:01:02.400277+00:00 2023-12-14T02:27:06.539476+00:00 0:26:04.139199 456903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T02:01:00.260041+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T02:00:39.858257+00:00 2023-12-14T02:00:40.834827+00:00 0:00:00.976570 456901 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T02:00:38.201551+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T01:00:00+00:00 PythonOperator 2023-12-14T02:00:20.683223+00:00 2023-12-14T02:00:22.196977+00:00 0:00:01.513754 456899 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T02:00:18.184325+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-14T00:00:00+00:00 EmrJobFlowSensor 2023-12-14T01:00:55.589125+00:00 2023-12-14T01:27:59.787355+00:00 0:27:04.198230 456875 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T01:00:53.876231+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-14T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T01:00:35.968713+00:00 2023-12-14T01:00:37.271117+00:00 0:00:01.302404 456873 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T01:00:33.826945+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-14T00:00:00+00:00 PythonOperator 2023-12-14T01:00:13.998280+00:00 2023-12-14T01:00:16.532965+00:00 0:00:02.534685 456871 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T01:00:11.811447+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T23:00:00+00:00 EmrJobFlowSensor 2023-12-14T00:00:57.381618+00:00 2023-12-14T00:30:01.615461+00:00 0:29:04.233843 456854 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-14T00:00:55.369189+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-14T00:00:35.351339+00:00 2023-12-14T00:00:36.353837+00:00 0:00:01.002498 456852 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-14T00:00:33.309387+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T23:00:00+00:00 PythonOperator 2023-12-14T00:00:15.364683+00:00 2023-12-14T00:00:16.892455+00:00 0:00:01.527772 456850 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-14T00:00:13.290251+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T22:00:00+00:00 EmrJobFlowSensor 2023-12-13T23:00:56.598155+00:00 2023-12-13T23:30:00.883083+00:00 0:29:04.284928 456830 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T23:00:54.885454+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T23:00:36.902187+00:00 2023-12-13T23:00:38.204070+00:00 0:00:01.301883 456827 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T23:00:34.840892+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T22:00:00+00:00 PythonOperator 2023-12-13T23:00:14.580953+00:00 2023-12-13T23:00:16.136953+00:00 0:00:01.556000 456824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T23:00:12.820346+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T21:00:00+00:00 EmrJobFlowSensor 2023-12-13T22:01:03.445272+00:00 2023-12-13T22:26:07.201674+00:00 0:25:03.756402 456807 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T22:01:01.735755+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T22:00:41.786882+00:00 2023-12-13T22:00:42.780462+00:00 0:00:00.993580 456805 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T22:00:39.718691+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T21:00:00+00:00 PythonOperator 2023-12-13T22:00:21.445690+00:00 2023-12-13T22:00:23.002055+00:00 0:00:01.556365 456803 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T22:00:19.700441+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T20:00:00+00:00 EmrJobFlowSensor 2023-12-13T21:00:51.138054+00:00 2023-12-13T21:29:55.754775+00:00 0:29:04.616721 456784 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T21:00:49.075550+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T21:00:31.214850+00:00 2023-12-13T21:00:32.210905+00:00 0:00:00.996055 456782 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T21:00:29.055264+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T20:00:00+00:00 PythonOperator 2023-12-13T21:00:09.063227+00:00 2023-12-13T21:00:10.580510+00:00 0:00:01.517283 456780 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T21:00:07.086133+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T19:00:00+00:00 EmrJobFlowSensor 2023-12-13T20:01:04.159815+00:00 2023-12-13T20:30:08.834912+00:00 0:29:04.675097 456762 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T20:01:02.473909+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T20:00:44.583940+00:00 2023-12-13T20:00:45.529393+00:00 0:00:00.945453 456761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T20:00:42.457100+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T19:00:00+00:00 PythonOperator 2023-12-13T20:00:22.756504+00:00 2023-12-13T20:00:24.270159+00:00 0:00:01.513655 456758 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T20:00:20.438489+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T18:00:00+00:00 EmrJobFlowSensor 2023-12-13T19:00:53.053865+00:00 2023-12-13T19:30:57.676906+00:00 0:30:04.623041 456740 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T19:00:51.383375+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T19:00:33.048406+00:00 2023-12-13T19:00:34.131086+00:00 0:00:01.082680 456738 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T19:00:31.352853+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T18:00:00+00:00 PythonOperator 2023-12-13T19:00:11.268309+00:00 2023-12-13T19:00:12.792912+00:00 0:00:01.524603 456736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T19:00:09.382682+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T17:00:00+00:00 EmrJobFlowSensor 2023-12-13T18:00:55.590876+00:00 2023-12-13T18:28:59.773951+00:00 0:28:04.183075 456718 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T18:00:53.089555+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T18:00:34.731021+00:00 2023-12-13T18:00:35.902852+00:00 0:00:01.171831 456716 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T18:00:33.045708+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T17:00:00+00:00 PythonOperator 2023-12-13T18:00:12.793834+00:00 2023-12-13T18:00:14.347571+00:00 0:00:01.553737 456714 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T18:00:11.034227+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T16:00:00+00:00 EmrJobFlowSensor 2023-12-13T17:01:27.074354+00:00 2023-12-13T17:27:30.990436+00:00 0:26:03.916082 456696 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T17:01:24.552949+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T17:01:07.000457+00:00 2023-12-13T17:01:07.919936+00:00 0:00:00.919479 456694 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T17:01:04.534048+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T16:00:00+00:00 PythonOperator 2023-12-13T17:00:44.234930+00:00 2023-12-13T17:00:45.765322+00:00 0:00:01.530392 456692 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T17:00:42.513009+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T15:00:00+00:00 EmrJobFlowSensor 2023-12-13T16:02:15.206597+00:00 2023-12-13T16:27:19.239691+00:00 0:25:04.033094 456675 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T16:02:13.088383+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T16:00:42.660608+00:00 2023-12-13T16:00:43.663327+00:00 0:00:01.002719 456672 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T16:00:40.972805+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T15:00:00+00:00 PythonOperator 2023-12-13T16:00:23.069877+00:00 2023-12-13T16:00:24.549243+00:00 0:00:01.479366 456670 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T16:00:20.951054+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T14:00:00+00:00 EmrJobFlowSensor 2023-12-13T15:00:58.948627+00:00 2023-12-13T15:28:03.208325+00:00 0:27:04.259698 456654 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T15:00:56.752165+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T15:00:36.847312+00:00 2023-12-13T15:00:37.804019+00:00 0:00:00.956707 456651 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T15:00:34.676058+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T14:00:00+00:00 PythonOperator 2023-12-13T15:00:17.149778+00:00 2023-12-13T15:00:18.669046+00:00 0:00:01.519268 456650 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T15:00:14.666759+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T13:00:00+00:00 EmrJobFlowSensor 2023-12-13T14:01:06.380830+00:00 2023-12-13T14:28:10.583234+00:00 0:27:04.202404 456632 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T14:01:04.311314+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T14:00:44.393422+00:00 2023-12-13T14:00:45.318306+00:00 0:00:00.924884 456630 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T14:00:42.353438+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T13:00:00+00:00 PythonOperator 2023-12-13T14:00:24.478655+00:00 2023-12-13T14:00:26.027244+00:00 0:00:01.548589 456628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T14:00:22.284413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T12:00:00+00:00 EmrJobFlowSensor 2023-12-13T13:00:51.653481+00:00 2023-12-13T13:26:55.739040+00:00 0:26:04.085559 456609 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T13:00:50.027665+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T13:00:30.207063+00:00 2023-12-13T13:00:31.396169+00:00 0:00:01.189106 456607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T13:00:28.008595+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T12:00:00+00:00 PythonOperator 2023-12-13T13:00:08.191125+00:00 2023-12-13T13:00:09.698286+00:00 0:00:01.507161 456605 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T13:00:05.989533+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T11:00:00+00:00 EmrJobFlowSensor 2023-12-13T12:06:44.656581+00:00 2023-12-13T12:32:49.065052+00:00 0:26:04.408471 456591 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T12:06:42.596879+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T12:06:24.657490+00:00 2023-12-13T12:06:25.629419+00:00 0:00:00.971929 456588 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T12:06:22.577882+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T11:00:00+00:00 PythonOperator 2023-12-13T12:06:02.609394+00:00 2023-12-13T12:06:04.195079+00:00 0:00:01.585685 456585 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T12:06:00.562081+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T10:00:00+00:00 EmrJobFlowSensor 2023-12-13T11:14:44.471707+00:00 2023-12-13T11:40:48.628090+00:00 0:26:04.156383 456575 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T11:14:42.427040+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T11:14:24.348364+00:00 2023-12-13T11:14:25.281283+00:00 0:00:00.932919 456574 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T11:14:22.462264+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T10:00:00+00:00 PythonOperator 2023-12-13T11:00:19.157026+00:00 2023-12-13T11:00:20.725617+00:00 0:00:01.568591 456563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T11:00:17.180070+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T09:00:00+00:00 EmrJobFlowSensor 2023-12-13T10:48:03.475158+00:00 2023-12-13T11:14:07.443530+00:00 0:26:03.968372 456560 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T10:48:01.285200+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T10:47:43.687290+00:00 2023-12-13T10:47:44.567536+00:00 0:00:00.880246 456559 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T10:47:41.270805+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T08:00:00+00:00 EmrJobFlowSensor 2023-12-13T10:21:15.976659+00:00 2023-12-13T10:47:20.056546+00:00 0:26:04.079887 456554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T10:21:13.872667+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T09:00:00+00:00 PythonOperator 2023-12-13T10:21:15.575092+00:00 2023-12-13T10:21:17.124528+00:00 0:00:01.549436 456553 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T10:21:13.872696+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T10:20:55.842775+00:00 2023-12-13T10:20:56.830870+00:00 0:00:00.988095 456552 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T10:20:53.806631+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T08:00:00+00:00 PythonOperator 2023-12-13T09:52:38.590134+00:00 2023-12-13T09:52:40.077229+00:00 0:00:01.487095 456537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T09:52:36.533818+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T07:00:00+00:00 EmrJobFlowSensor 2023-12-13T09:52:38.199759+00:00 2023-12-13T10:20:42.266662+00:00 0:28:04.066903 456536 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T09:52:36.533789+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T09:52:16.661274+00:00 2023-12-13T09:52:17.872851+00:00 0:00:01.211577 456535 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T09:52:14.515974+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T07:00:00+00:00 PythonOperator 2023-12-13T09:27:08.622546+00:00 2023-12-13T09:27:10.085981+00:00 0:00:01.463435 456530 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T09:27:06.385366+00:00 3 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T06:00:00+00:00 EmrJobFlowSensor 2023-12-13T09:27:08.170303+00:00 2023-12-13T09:52:11.821916+00:00 0:25:03.651613 456529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T09:27:06.385337+00:00 12 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T09:26:46.647683+00:00 2023-12-13T09:26:47.594388+00:00 0:00:00.946705 456528 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T09:26:44.459027+00:00 4 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T06:00:00+00:00 PythonOperator 2023-12-13T09:26:26.474445+00:00 2023-12-13T09:26:27.926944+00:00 0:00:01.452499 456527 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T09:26:24.298214+00:00 4 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T05:00:00+00:00 EmrJobFlowSensor 2023-12-13T06:01:06.865062+00:00 2023-12-13T06:28:10.866642+00:00 0:27:04.001580 456443 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T06:01:04.251706+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T06:00:45.499366+00:00 2023-12-13T06:00:46.506425+00:00 0:00:01.007059 456441 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T06:00:43.819279+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T05:00:00+00:00 PythonOperator 2023-12-13T06:00:26.073821+00:00 2023-12-13T06:00:27.739244+00:00 0:00:01.665423 456439 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T06:00:23.799566+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T04:00:00+00:00 EmrJobFlowSensor 2023-12-13T05:01:49.150260+00:00 2023-12-13T05:27:52.945180+00:00 0:26:03.794920 456421 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T05:01:47.126177+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T05:00:32.356470+00:00 2023-12-13T05:00:33.516206+00:00 0:00:01.159736 456418 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T05:00:30.669669+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T04:00:00+00:00 PythonOperator 2023-12-13T05:00:12.510016+00:00 2023-12-13T05:00:14.158002+00:00 0:00:01.647986 456416 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T05:00:10.652307+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T03:00:00+00:00 EmrJobFlowSensor 2023-12-13T04:01:28.459591+00:00 2023-12-13T04:26:32.306368+00:00 0:25:03.846777 456400 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T04:01:26.350126+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T04:00:35.349208+00:00 2023-12-13T04:00:36.333483+00:00 0:00:00.984275 456394 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T04:00:33.271178+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T03:00:00+00:00 PythonOperator 2023-12-13T04:00:15.152991+00:00 2023-12-13T04:00:16.831872+00:00 0:00:01.678881 456391 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T04:00:13.253137+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T02:00:00+00:00 EmrJobFlowSensor 2023-12-13T03:02:06.493748+00:00 2023-12-13T03:31:11.183792+00:00 0:29:04.690044 456374 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T03:02:04.426614+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T03:00:38.903492+00:00 2023-12-13T03:00:39.815731+00:00 0:00:00.912239 456372 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T03:00:36.342475+00:00 2 default_pool