Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T04:00:00+00:00 EmrJobFlowSensor 2023-12-20T05:00:46.574545+00:00 2023-12-20T05:24:50.369542+00:00 0:24:03.794997 459608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T05:00:44.386744+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T05:00:26.258739+00:00 2023-12-20T05:00:27.231411+00:00 0:00:00.972672 459606 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T05:00:24.356675+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T04:00:00+00:00 PythonOperator 2023-12-20T05:00:04.428992+00:00 2023-12-20T05:00:06.027713+00:00 0:00:01.598721 459604 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T05:00:02.382426+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T03:00:00+00:00 EmrJobFlowSensor 2023-12-20T04:00:54.082213+00:00 2023-12-20T04:25:58.078440+00:00 0:25:03.996227 459587 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T04:00:52.404737+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T04:00:32.203600+00:00 2023-12-20T04:00:33.152139+00:00 0:00:00.948539 459584 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T04:00:30.387377+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T03:00:00+00:00 PythonOperator 2023-12-20T04:00:10.448566+00:00 2023-12-20T04:00:12.016987+00:00 0:00:01.568421 459581 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T04:00:08.383450+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T02:00:00+00:00 EmrJobFlowSensor 2023-12-20T03:01:01.408638+00:00 2023-12-20T03:26:05.283569+00:00 0:25:03.874931 459568 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T03:00:59.471202+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T03:00:39.654207+00:00 2023-12-20T03:00:40.565410+00:00 0:00:00.911203 459566 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T03:00:37.483895+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T02:00:00+00:00 PythonOperator 2023-12-20T03:00:19.657328+00:00 2023-12-20T03:00:21.230702+00:00 0:00:01.573374 459564 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T03:00:17.478915+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T01:00:00+00:00 EmrJobFlowSensor 2023-12-20T02:00:50.296487+00:00 2023-12-20T02:26:54.542376+00:00 0:26:04.245889 459549 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T02:00:48.150918+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T02:00:27.986228+00:00 2023-12-20T02:00:28.910732+00:00 0:00:00.924504 459547 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T02:00:26.183426+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T01:00:00+00:00 PythonOperator 2023-12-20T02:00:08.324789+00:00 2023-12-20T02:00:10.027025+00:00 0:00:01.702236 459545 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T02:00:06.115706+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-20T00:00:00+00:00 EmrJobFlowSensor 2023-12-20T01:00:59.406864+00:00 2023-12-20T01:26:03.434830+00:00 0:25:04.027966 459525 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T01:00:57.331313+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-20T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T01:00:38.995886+00:00 2023-12-20T01:00:40.016368+00:00 0:00:01.020482 459523 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T01:00:37.313030+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-20T00:00:00+00:00 PythonOperator 2023-12-20T01:00:17.840147+00:00 2023-12-20T01:00:19.404929+00:00 0:00:01.564782 459521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T01:00:15.352556+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T23:00:00+00:00 EmrJobFlowSensor 2023-12-20T00:01:03.502157+00:00 2023-12-20T00:26:07.468526+00:00 0:25:03.966369 459508 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-20T00:01:01.419781+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-20T00:00:41.109967+00:00 2023-12-20T00:00:42.124488+00:00 0:00:01.014521 459506 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-20T00:00:39.396026+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T23:00:00+00:00 PythonOperator 2023-12-20T00:00:19.077823+00:00 2023-12-20T00:00:20.753177+00:00 0:00:01.675354 459504 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-20T00:00:17.378420+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T22:00:00+00:00 EmrJobFlowSensor 2023-12-19T23:00:56.624732+00:00 2023-12-19T23:26:00.371762+00:00 0:25:03.747030 459488 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T23:00:54.467627+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T23:00:34.553589+00:00 2023-12-19T23:00:35.449480+00:00 0:00:00.895891 459485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T23:00:32.447599+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T22:00:00+00:00 PythonOperator 2023-12-19T23:00:14.176017+00:00 2023-12-19T23:00:15.756985+00:00 0:00:01.580968 459482 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T23:00:12.430224+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T21:00:00+00:00 EmrJobFlowSensor 2023-12-19T22:01:05.746038+00:00 2023-12-19T22:24:09.181833+00:00 0:23:03.435795 459468 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T22:01:04.049822+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T22:00:44.155117+00:00 2023-12-19T22:00:45.135667+00:00 0:00:00.980550 459466 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T22:00:42.031213+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T21:00:00+00:00 PythonOperator 2023-12-19T22:00:23.759004+00:00 2023-12-19T22:00:25.342430+00:00 0:00:01.583426 459464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T22:00:22.011776+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T20:00:00+00:00 EmrJobFlowSensor 2023-12-19T21:00:47.744124+00:00 2023-12-19T21:26:51.736093+00:00 0:26:03.991969 459449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T21:00:46.027629+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T21:00:27.670925+00:00 2023-12-19T21:00:28.655161+00:00 0:00:00.984236 459447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T21:00:26.010758+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T20:00:00+00:00 PythonOperator 2023-12-19T21:00:06.399449+00:00 2023-12-19T21:00:07.964429+00:00 0:00:01.564980 459445 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T21:00:03.994871+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T19:00:00+00:00 EmrJobFlowSensor 2023-12-19T20:00:54.455081+00:00 2023-12-19T20:27:58.715334+00:00 0:27:04.260253 459432 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T20:00:52.065430+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T20:00:34.680500+00:00 2023-12-19T20:00:35.674352+00:00 0:00:00.993852 459430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T20:00:32.049170+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T19:00:00+00:00 PythonOperator 2023-12-19T20:00:12.188731+00:00 2023-12-19T20:00:13.752302+00:00 0:00:01.563571 459428 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T20:00:10.069417+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T18:00:00+00:00 EmrJobFlowSensor 2023-12-19T19:00:56.862098+00:00 2023-12-19T19:27:01.076224+00:00 0:26:04.214126 459414 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T19:00:55.130405+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T19:00:35.278875+00:00 2023-12-19T19:00:36.170040+00:00 0:00:00.891165 459412 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T19:00:33.163545+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T18:00:00+00:00 PythonOperator 2023-12-19T19:00:14.988859+00:00 2023-12-19T19:00:16.616643+00:00 0:00:01.627784 459410 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T19:00:13.165358+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T17:00:00+00:00 EmrJobFlowSensor 2023-12-19T18:01:02.273009+00:00 2023-12-19T18:27:06.455100+00:00 0:26:04.182091 459395 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T18:01:00.177520+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T18:00:42.863212+00:00 2023-12-19T18:00:44.203249+00:00 0:00:01.340037 459393 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T18:00:40.151121+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T17:00:00+00:00 PythonOperator 2023-12-19T18:00:20.396804+00:00 2023-12-19T18:00:21.964347+00:00 0:00:01.567543 459391 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T18:00:18.249601+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T16:00:00+00:00 EmrJobFlowSensor 2023-12-19T17:00:46.859010+00:00 2023-12-19T17:23:50.399424+00:00 0:23:03.540414 459377 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T17:00:44.769035+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T17:00:24.774568+00:00 2023-12-19T17:00:25.739391+00:00 0:00:00.964823 459375 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T17:00:22.699504+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T16:00:00+00:00 PythonOperator 2023-12-19T17:00:02.780492+00:00 2023-12-19T17:00:04.372095+00:00 0:00:01.591603 459373 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T17:00:00.685340+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T15:00:00+00:00 EmrJobFlowSensor 2023-12-19T16:00:47.355776+00:00 2023-12-19T16:25:51.555397+00:00 0:25:04.199621 459359 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T16:00:45.252322+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T16:00:24.957020+00:00 2023-12-19T16:00:25.891426+00:00 0:00:00.934406 459357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T16:00:23.183364+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T15:00:00+00:00 PythonOperator 2023-12-19T16:00:05.054099+00:00 2023-12-19T16:00:06.597848+00:00 0:00:01.543749 459355 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T16:00:03.183724+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T14:00:00+00:00 EmrJobFlowSensor 2023-12-19T15:00:50.468660+00:00 2023-12-19T15:25:54.489779+00:00 0:25:04.021119 459341 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T15:00:48.758985+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T15:00:28.974372+00:00 2023-12-19T15:00:30.060526+00:00 0:00:01.086154 459339 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T15:00:26.783307+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T14:00:00+00:00 PythonOperator 2023-12-19T15:00:06.761603+00:00 2023-12-19T15:00:08.334965+00:00 0:00:01.573362 459337 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T15:00:04.775676+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T13:00:00+00:00 EmrJobFlowSensor 2023-12-19T14:00:53.962795+00:00 2023-12-19T14:25:57.740047+00:00 0:25:03.777252 459324 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T14:00:51.757346+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T14:00:31.850356+00:00 2023-12-19T14:00:32.745139+00:00 0:00:00.894783 459322 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T14:00:29.680955+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T13:00:00+00:00 PythonOperator 2023-12-19T14:00:11.760979+00:00 2023-12-19T14:00:13.294723+00:00 0:00:01.533744 459320 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T14:00:09.669477+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T12:00:00+00:00 EmrJobFlowSensor 2023-12-19T13:00:53.558056+00:00 2023-12-19T13:26:57.344194+00:00 0:26:03.786138 459307 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T13:00:51.842791+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T13:00:31.580498+00:00 2023-12-19T13:00:32.605028+00:00 0:00:01.024530 459305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T13:00:29.823517+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T12:00:00+00:00 PythonOperator 2023-12-19T13:00:09.846170+00:00 2023-12-19T13:00:11.413176+00:00 0:00:01.567006 459303 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T13:00:07.854455+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T11:00:00+00:00 EmrJobFlowSensor 2023-12-19T12:00:57.673414+00:00 2023-12-19T12:26:01.687384+00:00 0:25:04.013970 459292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T12:00:55.599709+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T12:00:37.259419+00:00 2023-12-19T12:00:38.222135+00:00 0:00:00.962716 459290 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T12:00:35.582464+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T11:00:00+00:00 PythonOperator 2023-12-19T12:00:16.071086+00:00 2023-12-19T12:00:17.541627+00:00 0:00:01.470541 459288 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T12:00:13.565101+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T10:00:00+00:00 EmrJobFlowSensor 2023-12-19T11:01:03.792192+00:00 2023-12-19T11:27:07.881190+00:00 0:26:04.088998 459277 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T11:01:01.584734+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T11:00:43.372382+00:00 2023-12-19T11:00:44.351752+00:00 0:00:00.979370 459275 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T11:00:41.572415+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T10:00:00+00:00 PythonOperator 2023-12-19T11:00:21.697654+00:00 2023-12-19T11:00:23.268461+00:00 0:00:01.570807 459273 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T11:00:19.554926+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T09:00:00+00:00 EmrJobFlowSensor 2023-12-19T10:01:03.189994+00:00 2023-12-19T10:26:07.350718+00:00 0:25:04.160724 459258 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T10:01:01.109320+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T10:00:41.255110+00:00 2023-12-19T10:00:42.443245+00:00 0:00:01.188135 459256 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T10:00:39.086810+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T09:00:00+00:00 PythonOperator 2023-12-19T10:00:21.078175+00:00 2023-12-19T10:00:22.668444+00:00 0:00:01.590269 459254 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T10:00:19.065165+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T08:00:00+00:00 EmrJobFlowSensor 2023-12-19T09:00:54.188314+00:00 2023-12-19T09:26:58.119835+00:00 0:26:03.931521 459243 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T09:00:52.036852+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T09:00:32.071842+00:00 2023-12-19T09:00:32.944758+00:00 0:00:00.872916 459241 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T09:00:30.017042+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T08:00:00+00:00 PythonOperator 2023-12-19T09:00:09.761109+00:00 2023-12-19T09:00:11.344001+00:00 0:00:01.582892 459239 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T09:00:08.052118+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T07:00:00+00:00 EmrJobFlowSensor 2023-12-19T08:01:06.857303+00:00 2023-12-19T08:26:10.948509+00:00 0:25:04.091206 459225 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T08:01:05.224550+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T08:00:45.456696+00:00 2023-12-19T08:00:46.411016+00:00 0:00:00.954320 459223 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T08:00:43.258240+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T07:00:00+00:00 PythonOperator 2023-12-19T08:00:22.860823+00:00 2023-12-19T08:00:24.515769+00:00 0:00:01.654946 459221 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T08:00:21.186759+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T06:00:00+00:00 EmrJobFlowSensor 2023-12-19T07:01:07.450269+00:00 2023-12-19T07:27:11.823908+00:00 0:26:04.373639 459209 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T07:01:05.269263+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T07:00:45.063076+00:00 2023-12-19T07:00:46.067545+00:00 0:00:01.004469 459207 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T07:00:43.261566+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T06:00:00+00:00 PythonOperator 2023-12-19T07:00:25.259360+00:00 2023-12-19T07:00:26.876078+00:00 0:00:01.616718 459205 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T07:00:23.184580+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T05:00:00+00:00 EmrJobFlowSensor 2023-12-19T06:00:55.292143+00:00 2023-12-19T06:25:59.136479+00:00 0:25:03.844336 459193 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T06:00:53.242290+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T06:00:32.920770+00:00 2023-12-19T06:00:33.898315+00:00 0:00:00.977545 459191 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T06:00:31.223698+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T05:00:00+00:00 PythonOperator 2023-12-19T06:00:12.864296+00:00 2023-12-19T06:00:14.395858+00:00 0:00:01.531562 459189 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T06:00:11.206270+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T04:00:00+00:00 EmrJobFlowSensor 2023-12-19T05:01:00.777450+00:00 2023-12-19T05:27:05.235993+00:00 0:26:04.458543 459177 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T05:00:58.565431+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T05:00:40.668611+00:00 2023-12-19T05:00:41.533218+00:00 0:00:00.864607 459175 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T05:00:38.561567+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T04:00:00+00:00 PythonOperator 2023-12-19T05:00:18.614628+00:00 2023-12-19T05:00:20.143683+00:00 0:00:01.529055 459173 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T05:00:16.481377+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T03:00:00+00:00 EmrJobFlowSensor 2023-12-19T04:00:52.778332+00:00 2023-12-19T04:24:56.499922+00:00 0:24:03.721590 459159 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T04:00:50.694526+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T04:00:30.807045+00:00 2023-12-19T04:00:32.093979+00:00 0:00:01.286934 459155 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T04:00:28.682092+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T03:00:00+00:00 PythonOperator 2023-12-19T04:00:10.870163+00:00 2023-12-19T04:00:12.440960+00:00 0:00:01.570797 459153 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T04:00:08.650570+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T02:00:00+00:00 EmrJobFlowSensor 2023-12-19T03:00:54.743734+00:00 2023-12-19T03:25:58.711920+00:00 0:25:03.968186 459141 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T03:00:52.531168+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T03:00:32.255956+00:00 2023-12-19T03:00:33.275681+00:00 0:00:01.019725 459138 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T03:00:30.560445+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T02:00:00+00:00 PythonOperator 2023-12-19T03:00:13.327984+00:00 2023-12-19T03:00:14.946668+00:00 0:00:01.618684 459137 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T03:00:10.565609+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T01:00:00+00:00 EmrJobFlowSensor 2023-12-19T02:02:01.180789+00:00 2023-12-19T02:28:05.205553+00:00 0:26:04.024764 459125 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T02:01:59.077083+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T02:01:41.156293+00:00 2023-12-19T02:01:42.012084+00:00 0:00:00.855791 459123 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T02:01:39.056510+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T01:00:00+00:00 PythonOperator 2023-12-19T02:01:18.740263+00:00 2023-12-19T02:01:20.304515+00:00 0:00:01.564252 459121 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T02:01:17.036150+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-19T00:00:00+00:00 EmrJobFlowSensor 2023-12-19T01:01:03.870971+00:00 2023-12-19T01:26:07.727294+00:00 0:25:03.856323 459098 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T01:01:02.076492+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-19T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T01:00:42.133298+00:00 2023-12-19T01:00:43.080066+00:00 0:00:00.946768 459096 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T01:00:40.009979+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-19T00:00:00+00:00 PythonOperator 2023-12-19T01:00:22.072966+00:00 2023-12-19T01:00:23.650543+00:00 0:00:01.577577 459094 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T01:00:19.985330+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T23:00:00+00:00 EmrJobFlowSensor 2023-12-19T00:00:47.061177+00:00 2023-12-19T00:25:50.851616+00:00 0:25:03.790439 459079 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-19T00:00:45.121437+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-19T00:00:27.178282+00:00 2023-12-19T00:00:28.113613+00:00 0:00:00.935331 459077 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-19T00:00:25.093398+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T23:00:00+00:00 PythonOperator 2023-12-19T00:00:05.249124+00:00 2023-12-19T00:00:06.858097+00:00 0:00:01.608973 459075 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-19T00:00:03.067236+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T22:00:00+00:00 EmrJobFlowSensor 2023-12-18T23:00:58.973157+00:00 2023-12-18T23:27:02.957690+00:00 0:26:03.984533 459061 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T23:00:57.307792+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T23:00:37.691039+00:00 2023-12-18T23:00:38.595131+00:00 0:00:00.904092 459058 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T23:00:35.293630+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T22:00:00+00:00 PythonOperator 2023-12-18T23:00:16.956009+00:00 2023-12-18T23:00:18.560605+00:00 0:00:01.604596 459055 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T23:00:15.266294+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T21:00:00+00:00 EmrJobFlowSensor 2023-12-18T22:01:06.601143+00:00 2023-12-18T22:24:10.097777+00:00 0:23:03.496634 459041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T22:01:04.454294+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T22:00:44.484642+00:00 2023-12-18T22:00:45.618752+00:00 0:00:01.134110 459039 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T22:00:42.382985+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T21:00:00+00:00 PythonOperator 2023-12-18T22:00:24.463218+00:00 2023-12-18T22:00:26.013347+00:00 0:00:01.550129 459037 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T22:00:22.360929+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T20:00:00+00:00 EmrJobFlowSensor 2023-12-18T21:01:05.562515+00:00 2023-12-18T21:27:09.383239+00:00 0:26:03.820724 459023 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T21:01:03.778859+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T21:00:45.501298+00:00 2023-12-18T21:00:46.512869+00:00 0:00:01.011571 459021 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T21:00:43.758079+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T20:00:00+00:00 PythonOperator 2023-12-18T21:00:23.764667+00:00 2023-12-18T21:00:25.303354+00:00 0:00:01.538687 459019 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T21:00:21.685156+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T19:00:00+00:00 EmrJobFlowSensor 2023-12-18T20:00:53.559775+00:00 2023-12-18T20:28:57.946345+00:00 0:28:04.386570 459004 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T20:00:51.781333+00:00 2 default_pool