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-11-10T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T18:00:28.275361+00:00 2023-11-10T18:00:29.282327+00:00 0:00:01.006966 445178 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T18:00:26.185706+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T17:00:00+00:00 PythonOperator 2023-11-10T18:00:08.196714+00:00 2023-11-10T18:00:10.311682+00:00 0:00:02.114968 445177 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T18:00:06.124051+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T16:00:00+00:00 EmrJobFlowSensor 2023-11-10T17:03:48.461188+00:00 2023-11-10T17:27:52.045737+00:00 0:24:03.584549 445166 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T17:03:46.454090+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T17:03:28.470561+00:00 2023-11-10T17:03:29.463646+00:00 0:00:00.993085 445165 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T17:03:26.433878+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T16:00:00+00:00 PythonOperator 2023-11-10T17:00:16.350733+00:00 2023-11-10T17:00:18.684849+00:00 0:00:02.334116 445164 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T17:00:14.187728+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T15:00:00+00:00 EmrJobFlowSensor 2023-11-10T16:37:07.960007+00:00 2023-11-10T17:03:11.778042+00:00 0:26:03.818035 445161 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T16:37:05.978306+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T16:36:46.310053+00:00 2023-11-10T16:36:47.323997+00:00 0:00:01.013944 445160 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T16:36:43.906921+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T14:00:00+00:00 EmrJobFlowSensor 2023-11-10T16:11:37.107771+00:00 2023-11-10T16:36:41.088498+00:00 0:25:03.980727 445155 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T16:11:33.233696+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T15:00:00+00:00 PythonOperator 2023-11-10T16:11:37.081291+00:00 2023-11-10T16:11:39.453191+00:00 0:00:02.371900 445154 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T16:11:33.233743+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T16:11:13.168837+00:00 2023-11-10T16:11:14.191351+00:00 0:00:01.022514 445152 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T16:11:11.213607+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T14:00:00+00:00 PythonOperator 2023-11-10T15:41:54.019053+00:00 2023-11-10T15:41:56.295430+00:00 0:00:02.276377 445147 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T15:41:50.417853+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T13:00:00+00:00 EmrJobFlowSensor 2023-11-10T15:41:54.016026+00:00 2023-11-10T16:06:57.908148+00:00 0:25:03.892122 445146 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T15:41:50.417827+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T15:41:32.450063+00:00 2023-11-10T15:41:33.518536+00:00 0:00:01.068473 445145 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T15:41:30.400604+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T13:00:00+00:00 PythonOperator 2023-11-10T15:17:05.388491+00:00 2023-11-10T15:17:07.646347+00:00 0:00:02.257856 445142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T15:17:01.790782+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T12:00:00+00:00 EmrJobFlowSensor 2023-11-10T15:17:05.367965+00:00 2023-11-10T15:41:08.980074+00:00 0:24:03.612109 445141 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T15:17:01.790755+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T15:16:41.761062+00:00 2023-11-10T15:16:42.784618+00:00 0:00:01.023556 445140 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T15:16:39.767943+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T12:00:00+00:00 PythonOperator 2023-11-10T14:25:59.825549+00:00 2023-11-10T14:26:01.986957+00:00 0:00:02.161408 445130 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T14:25:57.827698+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T14:25:39.760192+00:00 2023-11-10T14:25:40.835174+00:00 0:00:01.074982 445129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T14:25:37.808097+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T11:00:00+00:00 PythonOperator 2023-11-10T14:25:18.164337+00:00 2023-11-10T14:25:20.375466+00:00 0:00:02.211129 445128 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T14:25:15.782014+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-09T21:00:00+00:00 PythonOperator 2023-11-10T14:05:09.965044+00:00 2023-11-10T14:05:12.079802+00:00 0:00:02.114758 445123 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T14:05:07.522401+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-09T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T14:04:47.496098+00:00 2023-11-10T14:04:48.517201+00:00 0:00:01.021103 445121 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T14:04:45.499829+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-09T20:00:00+00:00 PythonOperator 2023-11-10T14:04:27.754361+00:00 2023-11-10T14:04:29.897404+00:00 0:00:02.143043 445120 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T14:04:25.481545+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-09T05:00:00+00:00 PythonOperator 2023-11-10T13:48:38.905306+00:00 2023-11-10T13:48:41.059164+00:00 0:00:02.153858 445117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T13:48:36.777171+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-09T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T13:48:18.789139+00:00 2023-11-10T13:48:20.016479+00:00 0:00:01.227340 445116 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T13:48:16.771027+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-09T04:00:00+00:00 PythonOperator 2023-11-10T13:47:56.852051+00:00 2023-11-10T13:47:58.985808+00:00 0:00:02.133757 445115 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T13:47:54.699113+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T14:00:00+00:00 PythonOperator 2023-11-10T09:29:03.534743+00:00 2023-11-10T09:29:05.748386+00:00 0:00:02.213643 445068 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T09:28:59.853831+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T13:00:00+00:00 EmrJobFlowSensor 2023-11-10T09:29:03.482592+00:00 2023-11-10T09:54:07.289912+00:00 0:25:03.807320 445067 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T09:28:59.853802+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T09:28:40.047175+00:00 2023-11-10T09:28:41.098713+00:00 0:00:01.051538 445066 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T09:28:37.834900+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T12:00:00+00:00 EmrJobFlowSensor 2023-11-10T09:02:17.738227+00:00 2023-11-10T09:28:21.840123+00:00 0:26:04.101896 445059 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T09:02:13.925404+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T13:00:00+00:00 PythonOperator 2023-11-10T09:02:17.526961+00:00 2023-11-10T09:02:19.977259+00:00 0:00:02.450298 445058 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T09:02:13.925432+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T09:01:54.403132+00:00 2023-11-10T09:01:55.406906+00:00 0:00:01.003774 445057 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T09:01:51.905405+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T12:00:00+00:00 PythonOperator 2023-11-10T08:35:43.102721+00:00 2023-11-10T08:35:45.413791+00:00 0:00:02.311070 445053 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T08:35:39.488729+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T11:00:00+00:00 EmrJobFlowSensor 2023-11-10T08:35:43.075595+00:00 2023-11-10T09:01:47.217543+00:00 0:26:04.141948 445052 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T08:35:39.488702+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T08:35:19.651246+00:00 2023-11-10T08:35:20.531551+00:00 0:00:00.880305 445051 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T08:35:17.477362+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T10:00:00+00:00 EmrJobFlowSensor 2023-11-10T08:12:01.975034+00:00 2023-11-10T08:35:05.516328+00:00 0:23:03.541294 445048 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T08:12:00.047616+00:00 12 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T08:11:38.083913+00:00 2023-11-10T08:11:39.114138+00:00 0:00:01.030225 445047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T08:11:36.082719+00:00 4 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T10:00:00+00:00 PythonOperator 2023-11-10T08:11:16.067657+00:00 2023-11-10T08:11:18.295077+00:00 0:00:02.227420 445046 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T08:11:14.062104+00:00 4 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T11:00:00+00:00 PythonOperator 2023-11-08T12:00:19.652939+00:00 2023-11-08T12:00:21.933239+00:00 0:00:02.280300 444481 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T12:00:17.680149+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T09:00:00+00:00 EmrJobFlowSensor 2023-11-08T10:00:55.850369+00:00 2023-11-08T10:25:59.504702+00:00 0:25:03.654333 444447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T10:00:53.885820+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T10:00:33.772325+00:00 2023-11-08T10:00:34.796735+00:00 0:00:01.024410 444446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T10:00:31.828227+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T09:00:00+00:00 PythonOperator 2023-11-08T10:00:13.865661+00:00 2023-11-08T10:00:15.984132+00:00 0:00:02.118471 444444 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T10:00:11.809651+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T08:00:00+00:00 EmrJobFlowSensor 2023-11-08T09:11:34.216926+00:00 2023-11-08T09:36:37.776826+00:00 0:25:03.559900 444432 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T09:11:32.130855+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T09:11:14.066109+00:00 2023-11-08T09:11:15.230477+00:00 0:00:01.164368 444430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T09:11:12.110368+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T08:00:00+00:00 PythonOperator 2023-11-08T09:10:53.929474+00:00 2023-11-08T09:10:57.315716+00:00 0:00:03.386242 444427 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T09:10:50.138804+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T07:00:00+00:00 EmrJobFlowSensor 2023-11-08T08:04:46.216935+00:00 2023-11-08T08:31:50.192421+00:00 0:27:03.975486 444412 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T08:04:44.191230+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T08:04:24.177657+00:00 2023-11-08T08:04:25.194924+00:00 0:00:01.017267 444411 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T08:04:22.170627+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T07:00:00+00:00 PythonOperator 2023-11-08T08:04:04.376846+00:00 2023-11-08T08:04:06.698682+00:00 0:00:02.321836 444409 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T08:04:02.157325+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T06:00:00+00:00 EmrJobFlowSensor 2023-11-08T07:00:55.180412+00:00 2023-11-08T07:27:59.196756+00:00 0:27:04.016344 444394 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T07:00:53.221012+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T07:00:33.173385+00:00 2023-11-08T07:00:34.295789+00:00 0:00:01.122404 444393 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T07:00:31.198440+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T06:00:00+00:00 PythonOperator 2023-11-08T07:00:13.118670+00:00 2023-11-08T07:00:15.321555+00:00 0:00:02.202885 444392 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T07:00:11.138920+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T05:00:00+00:00 EmrJobFlowSensor 2023-11-08T06:00:51.796637+00:00 2023-11-08T06:25:55.773120+00:00 0:25:03.976483 444376 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T06:00:49.844373+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T06:00:29.783692+00:00 2023-11-08T06:00:30.894372+00:00 0:00:01.110680 444375 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T06:00:27.822099+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T05:00:00+00:00 PythonOperator 2023-11-08T06:00:07.848456+00:00 2023-11-08T06:00:10.103882+00:00 0:00:02.255426 444374 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T06:00:05.801158+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T04:00:00+00:00 EmrJobFlowSensor 2023-11-08T05:00:48.840714+00:00 2023-11-08T05:25:52.899724+00:00 0:25:04.059010 444359 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T05:00:46.830273+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T05:00:26.757648+00:00 2023-11-08T05:00:27.747714+00:00 0:00:00.990066 444358 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T05:00:24.809472+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T04:00:00+00:00 PythonOperator 2023-11-08T05:00:08.676570+00:00 2023-11-08T05:00:10.938625+00:00 0:00:02.262055 444357 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T05:00:04.795666+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T03:00:00+00:00 EmrJobFlowSensor 2023-11-08T04:14:14.351781+00:00 2023-11-08T04:26:16.337676+00:00 0:12:01.985895 444342 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T04:14:12.371902+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T04:00:38.338518+00:00 2023-11-08T04:00:39.372130+00:00 0:00:01.033612 444330 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T04:00:35.989210+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T03:00:00+00:00 PythonOperator 2023-11-08T04:00:17.894916+00:00 2023-11-08T04:00:20.249172+00:00 0:00:02.354256 444328 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T04:00:15.971747+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T02:00:00+00:00 EmrJobFlowSensor 2023-11-08T03:01:00.726873+00:00 2023-11-08T03:25:04.498357+00:00 0:24:03.771484 444310 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T03:00:58.677406+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T03:00:40.574113+00:00 2023-11-08T03:00:41.650957+00:00 0:00:01.076844 444309 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T03:00:38.604784+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T02:00:00+00:00 PythonOperator 2023-11-08T03:00:18.652135+00:00 2023-11-08T03:00:20.807234+00:00 0:00:02.155099 444308 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T03:00:16.585077+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T01:00:00+00:00 EmrJobFlowSensor 2023-11-08T02:01:35.996115+00:00 2023-11-08T02:26:39.912831+00:00 0:25:03.916716 444291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T02:01:33.982758+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T02:01:15.951897+00:00 2023-11-08T02:01:16.985452+00:00 0:00:01.033555 444290 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T02:01:13.967527+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T01:00:00+00:00 PythonOperator 2023-11-08T02:00:54.354613+00:00 2023-11-08T02:00:56.616157+00:00 0:00:02.261544 444288 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T02:00:51.950388+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-08T00:00:00+00:00 EmrJobFlowSensor 2023-11-08T01:00:52.841442+00:00 2023-11-08T01:24:56.670340+00:00 0:24:03.828898 444265 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T01:00:50.862785+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-08T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T01:00:30.800357+00:00 2023-11-08T01:00:31.835024+00:00 0:00:01.034667 444264 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T01:00:28.785424+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-08T00:00:00+00:00 PythonOperator 2023-11-08T01:00:10.866614+00:00 2023-11-08T01:00:14.017234+00:00 0:00:03.150620 444262 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T01:00:08.768164+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T23:00:00+00:00 EmrJobFlowSensor 2023-11-08T00:01:03.214087+00:00 2023-11-08T00:27:07.111946+00:00 0:26:03.897859 444246 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-08T00:01:01.181647+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-08T00:00:41.201984+00:00 2023-11-08T00:00:42.362351+00:00 0:00:01.160367 444245 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-08T00:00:39.168993+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T23:00:00+00:00 PythonOperator 2023-11-08T00:00:21.125738+00:00 2023-11-08T00:00:23.351439+00:00 0:00:02.225701 444244 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-08T00:00:19.087732+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T22:00:00+00:00 EmrJobFlowSensor 2023-11-07T23:00:59.055914+00:00 2023-11-07T23:27:03.081294+00:00 0:26:04.025380 444226 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T23:00:56.980842+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T23:00:36.958413+00:00 2023-11-07T23:00:38.093272+00:00 0:00:01.134859 444224 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T23:00:34.916850+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T22:00:00+00:00 PythonOperator 2023-11-07T23:00:16.985767+00:00 2023-11-07T23:00:20.882580+00:00 0:00:03.896813 444221 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T23:00:14.897487+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T21:00:00+00:00 EmrJobFlowSensor 2023-11-07T22:00:59.754027+00:00 2023-11-07T22:25:03.593363+00:00 0:24:03.839336 444205 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T22:00:57.801543+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T22:00:37.882345+00:00 2023-11-07T22:00:38.852260+00:00 0:00:00.969915 444204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T22:00:35.784196+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T21:00:00+00:00 PythonOperator 2023-11-07T22:00:18.099810+00:00 2023-11-07T22:00:20.295061+00:00 0:00:02.195251 444203 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T22:00:15.766221+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T20:00:00+00:00 EmrJobFlowSensor 2023-11-07T21:00:59.542166+00:00 2023-11-07T21:25:03.425229+00:00 0:24:03.883063 444188 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T21:00:57.657851+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T21:00:37.663672+00:00 2023-11-07T21:00:38.750923+00:00 0:00:01.087251 444186 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T21:00:35.654073+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T20:00:00+00:00 PythonOperator 2023-11-07T21:00:17.834164+00:00 2023-11-07T21:00:20.215183+00:00 0:00:02.381019 444184 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T21:00:15.557546+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T19:00:00+00:00 EmrJobFlowSensor 2023-11-07T20:00:58.451546+00:00 2023-11-07T20:27:02.552229+00:00 0:26:04.100683 444170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T20:00:56.405373+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T20:00:36.362735+00:00 2023-11-07T20:00:37.525644+00:00 0:00:01.162909 444168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T20:00:34.377356+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T19:00:00+00:00 PythonOperator 2023-11-07T20:00:16.338774+00:00 2023-11-07T20:00:18.512140+00:00 0:00:02.173366 444166 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T20:00:14.360983+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T18:00:00+00:00 EmrJobFlowSensor 2023-11-07T19:28:39.149402+00:00 2023-11-07T19:54:43.063441+00:00 0:26:03.914039 444160 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T19:28:37.169670+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T19:28:17.232080+00:00 2023-11-07T19:28:18.341052+00:00 0:00:01.108972 444159 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T19:28:15.151461+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T18:00:00+00:00 PythonOperator 2023-11-07T19:03:05.197995+00:00 2023-11-07T19:03:07.432261+00:00 0:00:02.234266 444146 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T19:03:01.658491+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T17:00:00+00:00 EmrJobFlowSensor 2023-11-07T19:03:05.147233+00:00 2023-11-07T19:28:08.993403+00:00 0:25:03.846170 444145 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T19:03:01.658465+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T19:02:44.003224+00:00 2023-11-07T19:02:45.276673+00:00 0:00:01.273449 444144 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T19:02:41.644233+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T17:00:00+00:00 PythonOperator 2023-11-07T18:36:09.720901+00:00 2023-11-07T18:36:12.036459+00:00 0:00:02.315558 444136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T18:36:06.164002+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T16:00:00+00:00 EmrJobFlowSensor 2023-11-07T18:36:09.714136+00:00 2023-11-07T19:02:13.510781+00:00 0:26:03.796645 444135 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T18:36:06.163976+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T18:35:46.223853+00:00 2023-11-07T18:35:47.285172+00:00 0:00:01.061319 444134 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T18:35:44.144031+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T15:00:00+00:00 EmrJobFlowSensor 2023-11-07T18:07:35.865872+00:00 2023-11-07T18:35:39.991701+00:00 0:28:04.125829 444124 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T18:07:32.344151+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T16:00:00+00:00 PythonOperator 2023-11-07T18:07:35.822332+00:00 2023-11-07T18:07:38.003432+00:00 0:00:02.181100 444123 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T18:07:32.344182+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T18:07:14.576417+00:00 2023-11-07T18:07:15.603015+00:00 0:00:01.026598 444122 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T18:07:12.324125+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T15:00:00+00:00 PythonOperator 2023-11-07T17:41:03.693386+00:00 2023-11-07T17:41:06.429829+00:00 0:00:02.736443 444113 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T17:41:00.023544+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T14:00:00+00:00 EmrJobFlowSensor 2023-11-07T17:41:03.694611+00:00 2023-11-07T18:07:07.633070+00:00 0:26:03.938459 444112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T17:41:00.023519+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T17:39:26.652880+00:00 2023-11-07T17:39:27.621298+00:00 0:00:00.968418 444110 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T17:39:24.580063+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-07T13:00:00+00:00 EmrJobFlowSensor 2023-11-07T17:12:10.061737+00:00 2023-11-07T17:39:14.147475+00:00 0:27:04.085738 444104 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-07T17:12:08.080431+00:00 12 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-07T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-07T17:11:48.223579+00:00 2023-11-07T17:11:49.248957+00:00 0:00:01.025378 444103 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-07T17:11:46.087159+00:00 4 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-07T13:00:00+00:00 PythonOperator 2023-11-07T17:11:26.057660+00:00 2023-11-07T17:11:28.244293+00:00 0:00:02.186633 444102 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-07T17:11:24.068530+00:00 4 default_pool