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-11-12T02:00:00+00:00 EmrJobFlowSensor 2023-11-12T03:01:06.021410+00:00 2023-11-12T03:26:09.948571+00:00 0:25:03.927161 445608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T03:01:04.059466+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T03:00:44.105521+00:00 2023-11-12T03:00:45.116620+00:00 0:00:01.011099 445607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T03:00:42.038776+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T02:00:00+00:00 PythonOperator 2023-11-12T03:00:22.874557+00:00 2023-11-12T03:00:25.111785+00:00 0:00:02.237228 445606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T03:00:20.073217+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T01:00:00+00:00 EmrJobFlowSensor 2023-11-12T02:00:46.363243+00:00 2023-11-12T02:25:50.222624+00:00 0:25:03.859381 445595 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T02:00:44.409443+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T02:00:26.349449+00:00 2023-11-12T02:00:27.421856+00:00 0:00:01.072407 445594 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T02:00:24.388957+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T01:00:00+00:00 PythonOperator 2023-11-12T02:00:04.793372+00:00 2023-11-12T02:00:06.982483+00:00 0:00:02.189111 445593 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T02:00:02.369613+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-12T00:00:00+00:00 EmrJobFlowSensor 2023-11-12T01:00:54.856603+00:00 2023-11-12T01:25:58.589228+00:00 0:25:03.732625 445578 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T01:00:52.792295+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-12T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T01:00:34.879031+00:00 2023-11-12T01:00:36.092289+00:00 0:00:01.213258 445577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T01:00:32.782139+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-12T00:00:00+00:00 PythonOperator 2023-11-12T01:00:12.757554+00:00 2023-11-12T01:00:15.041354+00:00 0:00:02.283800 445576 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T01:00:10.703162+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T23:00:00+00:00 EmrJobFlowSensor 2023-11-12T00:00:49.051763+00:00 2023-11-12T00:25:52.970428+00:00 0:25:03.918665 445566 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-12T00:00:47.059737+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-12T00:00:27.164337+00:00 2023-11-12T00:00:28.121280+00:00 0:00:00.956943 445565 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-12T00:00:25.088842+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T23:00:00+00:00 PythonOperator 2023-11-12T00:00:07.147391+00:00 2023-11-12T00:00:09.326244+00:00 0:00:02.178853 445564 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-12T00:00:05.018530+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T22:00:00+00:00 EmrJobFlowSensor 2023-11-11T23:01:05.678147+00:00 2023-11-11T23:27:09.793190+00:00 0:26:04.115043 445555 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T23:01:03.555250+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T23:00:45.709358+00:00 2023-11-11T23:00:46.729380+00:00 0:00:01.020022 445553 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T23:00:43.490319+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T22:00:00+00:00 PythonOperator 2023-11-11T23:00:24.023855+00:00 2023-11-11T23:00:26.156433+00:00 0:00:02.132578 445551 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T23:00:21.446639+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T21:00:00+00:00 EmrJobFlowSensor 2023-11-11T22:01:00.645847+00:00 2023-11-11T22:24:04.290945+00:00 0:23:03.645098 445539 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T22:00:58.626644+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T22:00:38.549854+00:00 2023-11-11T22:00:39.643369+00:00 0:00:01.093515 445538 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T22:00:36.607478+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T21:00:00+00:00 PythonOperator 2023-11-11T22:00:16.948122+00:00 2023-11-11T22:00:19.113743+00:00 0:00:02.165621 445537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T22:00:14.585452+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T20:00:00+00:00 EmrJobFlowSensor 2023-11-11T21:01:06.369523+00:00 2023-11-11T21:26:10.159074+00:00 0:25:03.789551 445525 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T21:01:04.437063+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T21:00:44.374838+00:00 2023-11-11T21:00:45.273031+00:00 0:00:00.898193 445524 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T21:00:42.413370+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T20:00:00+00:00 PythonOperator 2023-11-11T21:00:22.861146+00:00 2023-11-11T21:00:24.970436+00:00 0:00:02.109290 445523 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T21:00:20.455887+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T19:00:00+00:00 EmrJobFlowSensor 2023-11-11T20:00:54.850438+00:00 2023-11-11T20:27:58.968998+00:00 0:27:04.118560 445512 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T20:00:52.881884+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T20:00:32.747591+00:00 2023-11-11T20:00:33.717579+00:00 0:00:00.969988 445511 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T20:00:30.809612+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T19:00:00+00:00 PythonOperator 2023-11-11T20:00:12.868677+00:00 2023-11-11T20:00:15.124887+00:00 0:00:02.256210 445510 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T20:00:10.792147+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T18:00:00+00:00 EmrJobFlowSensor 2023-11-11T19:00:51.630599+00:00 2023-11-11T19:27:55.875398+00:00 0:27:04.244799 445499 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T19:00:49.697709+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T19:00:31.645191+00:00 2023-11-11T19:00:32.623383+00:00 0:00:00.978192 445498 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T19:00:29.681144+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T18:00:00+00:00 PythonOperator 2023-11-11T19:00:09.943546+00:00 2023-11-11T19:00:12.094410+00:00 0:00:02.150864 445497 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T19:00:07.659043+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T17:00:00+00:00 EmrJobFlowSensor 2023-11-11T18:01:05.993473+00:00 2023-11-11T18:27:10.098356+00:00 0:26:04.104883 445485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T18:01:04.067405+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T18:00:45.993331+00:00 2023-11-11T18:00:47.044128+00:00 0:00:01.050797 445484 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T18:00:44.051660+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T17:00:00+00:00 PythonOperator 2023-11-11T18:00:24.162836+00:00 2023-11-11T18:00:26.309939+00:00 0:00:02.147103 445483 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T18:00:22.032406+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T16:00:00+00:00 EmrJobFlowSensor 2023-11-11T17:01:25.130721+00:00 2023-11-11T17:25:28.678176+00:00 0:24:03.547455 445474 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T17:01:23.197219+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T17:01:05.157196+00:00 2023-11-11T17:01:06.487525+00:00 0:00:01.330329 445473 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T17:01:03.180128+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T16:00:00+00:00 PythonOperator 2023-11-11T17:00:43.308210+00:00 2023-11-11T17:00:45.479418+00:00 0:00:02.171208 445472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T17:00:41.161579+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T15:00:00+00:00 EmrJobFlowSensor 2023-11-11T16:01:04.153772+00:00 2023-11-11T16:26:08.000524+00:00 0:25:03.846752 445460 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T16:01:02.170175+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T16:00:42.154424+00:00 2023-11-11T16:00:43.153770+00:00 0:00:00.999346 445459 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T16:00:40.148401+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T15:00:00+00:00 PythonOperator 2023-11-11T16:00:20.348751+00:00 2023-11-11T16:00:22.477416+00:00 0:00:02.128665 445458 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T16:00:18.174992+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T14:00:00+00:00 EmrJobFlowSensor 2023-11-11T15:01:46.859102+00:00 2023-11-11T15:26:50.644637+00:00 0:25:03.785535 445449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T15:01:44.915173+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T15:01:26.862838+00:00 2023-11-11T15:01:27.829659+00:00 0:00:00.966821 445448 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T15:01:24.895334+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T14:00:00+00:00 PythonOperator 2023-11-11T15:01:04.936660+00:00 2023-11-11T15:01:07.169996+00:00 0:00:02.233336 445447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T15:01:02.876043+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T13:00:00+00:00 EmrJobFlowSensor 2023-11-11T14:26:15.823566+00:00 2023-11-11T14:37:17.758838+00:00 0:11:01.935272 445443 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T14:26:13.560618+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T14:11:32.440155+00:00 2023-11-11T14:11:33.424423+00:00 0:00:00.984268 445436 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T14:11:30.287909+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T13:00:00+00:00 PythonOperator 2023-11-11T14:11:12.555767+00:00 2023-11-11T14:11:14.888805+00:00 0:00:02.333038 445434 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T14:11:10.272756+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T12:00:00+00:00 EmrJobFlowSensor 2023-11-11T13:00:48.738110+00:00 2023-11-11T13:25:52.621216+00:00 0:25:03.883106 445423 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T13:00:46.757261+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T13:00:26.648151+00:00 2023-11-11T13:00:27.685267+00:00 0:00:01.037116 445422 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T13:00:24.737895+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T12:00:00+00:00 PythonOperator 2023-11-11T13:00:04.974202+00:00 2023-11-11T13:00:07.235031+00:00 0:00:02.260829 445421 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T13:00:02.719634+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T11:00:00+00:00 EmrJobFlowSensor 2023-11-11T12:01:08.295072+00:00 2023-11-11T12:26:12.330048+00:00 0:25:04.034976 445411 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T12:01:06.340194+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T12:00:48.256631+00:00 2023-11-11T12:00:49.432359+00:00 0:00:01.175728 445410 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T12:00:46.320076+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T11:00:00+00:00 PythonOperator 2023-11-11T12:00:26.541558+00:00 2023-11-11T12:00:28.669537+00:00 0:00:02.127979 445409 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T12:00:24.302346+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T10:00:00+00:00 EmrJobFlowSensor 2023-11-11T11:01:59.380247+00:00 2023-11-11T11:26:03.098011+00:00 0:24:03.717764 445398 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T11:01:57.277742+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T11:00:28.713465+00:00 2023-11-11T11:00:29.808999+00:00 0:00:01.095534 445396 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T11:00:26.755994+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T10:00:00+00:00 PythonOperator 2023-11-11T11:00:07.096248+00:00 2023-11-11T11:00:09.176596+00:00 0:00:02.080348 445395 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T11:00:04.733600+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T09:00:00+00:00 EmrJobFlowSensor 2023-11-11T10:01:01.169250+00:00 2023-11-11T10:26:05.071605+00:00 0:25:03.902355 445385 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T10:00:59.164320+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T10:00:39.147224+00:00 2023-11-11T10:00:40.122652+00:00 0:00:00.975428 445384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T10:00:37.098208+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T09:00:00+00:00 PythonOperator 2023-11-11T10:00:19.158461+00:00 2023-11-11T10:00:21.357016+00:00 0:00:02.198555 445383 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T10:00:17.080381+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T08:00:00+00:00 EmrJobFlowSensor 2023-11-11T09:01:11.594041+00:00 2023-11-11T09:25:15.186767+00:00 0:24:03.592726 445373 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T09:01:09.662754+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T09:00:49.982559+00:00 2023-11-11T09:00:50.883540+00:00 0:00:00.900981 445372 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T09:00:47.645902+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T08:00:00+00:00 PythonOperator 2023-11-11T09:00:05.629272+00:00 2023-11-11T09:00:07.856979+00:00 0:00:02.227707 445370 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T09:00:03.549681+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T07:00:00+00:00 EmrJobFlowSensor 2023-11-11T08:00:47.144265+00:00 2023-11-11T08:26:51.050572+00:00 0:26:03.906307 445362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T08:00:45.231920+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T08:00:27.187119+00:00 2023-11-11T08:00:28.237769+00:00 0:00:01.050650 445361 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T08:00:25.208639+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T07:00:00+00:00 PythonOperator 2023-11-11T08:00:05.582489+00:00 2023-11-11T08:00:07.767200+00:00 0:00:02.184711 445360 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T08:00:03.188116+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T06:00:00+00:00 EmrJobFlowSensor 2023-11-11T07:11:29.672207+00:00 2023-11-11T07:37:33.519345+00:00 0:26:03.847138 445355 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T07:11:27.602553+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T07:11:07.659337+00:00 2023-11-11T07:11:08.708802+00:00 0:00:01.049465 445353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T07:11:05.584845+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T06:00:00+00:00 PythonOperator 2023-11-11T07:10:48.230865+00:00 2023-11-11T07:10:50.411733+00:00 0:00:02.180868 445351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T07:10:45.568701+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T05:00:00+00:00 EmrJobFlowSensor 2023-11-11T06:11:10.479388+00:00 2023-11-11T06:37:14.403688+00:00 0:26:03.924300 445344 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T06:11:06.917768+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T06:10:50.443125+00:00 2023-11-11T06:10:51.569525+00:00 0:00:01.126400 445341 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T06:10:46.899088+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T05:00:00+00:00 PythonOperator 2023-11-11T06:10:28.571597+00:00 2023-11-11T06:10:30.979022+00:00 0:00:02.407425 445340 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T06:10:24.880156+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T04:00:00+00:00 EmrJobFlowSensor 2023-11-11T05:02:07.071197+00:00 2023-11-11T05:25:10.745725+00:00 0:23:03.674528 445329 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T05:02:04.773449+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T05:00:26.561849+00:00 2023-11-11T05:00:27.754915+00:00 0:00:01.193066 445327 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T05:00:24.591673+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T04:00:00+00:00 PythonOperator 2023-11-11T05:00:06.658404+00:00 2023-11-11T05:00:08.787994+00:00 0:00:02.129590 445326 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T05:00:04.575358+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T03:00:00+00:00 EmrJobFlowSensor 2023-11-11T04:01:10.109810+00:00 2023-11-11T04:25:13.705507+00:00 0:24:03.595697 445317 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T04:01:08.056774+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T04:00:47.966906+00:00 2023-11-11T04:00:49.085301+00:00 0:00:01.118395 445315 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T04:00:46.030134+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T03:00:00+00:00 PythonOperator 2023-11-11T04:00:27.979235+00:00 2023-11-11T04:00:30.183982+00:00 0:00:02.204747 445313 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T04:00:26.009910+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T02:00:00+00:00 EmrJobFlowSensor 2023-11-11T03:15:08.101846+00:00 2023-11-11T03:40:12.160680+00:00 0:25:04.058834 445306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T03:15:06.126878+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T03:14:46.109028+00:00 2023-11-11T03:14:47.086538+00:00 0:00:00.977510 445304 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T03:14:44.105677+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T02:00:00+00:00 PythonOperator 2023-11-11T03:14:27.499630+00:00 2023-11-11T03:14:29.743099+00:00 0:00:02.243469 445302 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T03:14:24.133692+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T01:00:00+00:00 EmrJobFlowSensor 2023-11-11T02:00:52.003024+00:00 2023-11-11T02:24:55.614791+00:00 0:24:03.611767 445291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T02:00:50.040632+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T02:00:30.084709+00:00 2023-11-11T02:00:31.159543+00:00 0:00:01.074834 445290 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T02:00:28.070804+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T01:00:00+00:00 PythonOperator 2023-11-11T02:00:10.456660+00:00 2023-11-11T02:00:12.641276+00:00 0:00:02.184616 445289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T02:00:08.004275+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-11T00:00:00+00:00 EmrJobFlowSensor 2023-11-11T01:00:50.454628+00:00 2023-11-11T01:25:54.251465+00:00 0:25:03.796837 445275 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T01:00:48.529777+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-11T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T01:00:28.543182+00:00 2023-11-11T01:00:29.620619+00:00 0:00:01.077437 445274 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T01:00:26.507660+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-11T00:00:00+00:00 PythonOperator 2023-11-11T01:00:06.869535+00:00 2023-11-11T01:00:09.104058+00:00 0:00:02.234523 445273 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T01:00:04.491462+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T23:00:00+00:00 EmrJobFlowSensor 2023-11-11T00:00:56.649974+00:00 2023-11-11T00:26:00.516954+00:00 0:25:03.866980 445262 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-11T00:00:54.700539+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-11T00:00:34.599254+00:00 2023-11-11T00:00:35.602445+00:00 0:00:01.003191 445261 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-11T00:00:32.668826+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T23:00:00+00:00 PythonOperator 2023-11-11T00:00:14.798311+00:00 2023-11-11T00:00:16.982891+00:00 0:00:02.184580 445260 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-11T00:00:12.650907+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T22:00:00+00:00 EmrJobFlowSensor 2023-11-10T23:00:59.659109+00:00 2023-11-10T23:26:03.518663+00:00 0:25:03.859554 445247 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T23:00:57.765545+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T23:00:37.655071+00:00 2023-11-10T23:00:38.727119+00:00 0:00:01.072048 445245 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T23:00:35.744534+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T22:00:00+00:00 PythonOperator 2023-11-10T23:00:17.800656+00:00 2023-11-10T23:00:20.099346+00:00 0:00:02.298690 445243 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T23:00:15.726915+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T21:00:00+00:00 EmrJobFlowSensor 2023-11-10T22:01:00.544295+00:00 2023-11-10T22:25:04.252808+00:00 0:24:03.708513 445231 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T22:00:58.606945+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T22:00:40.550176+00:00 2023-11-10T22:00:41.651808+00:00 0:00:01.101632 445230 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T22:00:38.587701+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T21:00:00+00:00 PythonOperator 2023-11-10T22:00:18.688353+00:00 2023-11-10T22:00:20.811490+00:00 0:00:02.123137 445229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T22:00:16.571715+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T20:00:00+00:00 EmrJobFlowSensor 2023-11-10T21:01:01.693337+00:00 2023-11-10T21:27:05.672305+00:00 0:26:03.978968 445217 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T21:00:59.770330+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T21:00:39.665043+00:00 2023-11-10T21:00:40.654142+00:00 0:00:00.989099 445216 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T21:00:37.753164+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T20:00:00+00:00 PythonOperator 2023-11-10T21:00:19.849047+00:00 2023-11-10T21:00:21.975262+00:00 0:00:02.126215 445215 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T21:00:17.734017+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T19:00:00+00:00 EmrJobFlowSensor 2023-11-10T20:01:31.687105+00:00 2023-11-10T20:28:35.786162+00:00 0:27:04.099057 445205 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T20:01:29.705548+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T20:01:09.660075+00:00 2023-11-10T20:01:10.659401+00:00 0:00:00.999326 445204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T20:01:07.686625+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T19:00:00+00:00 PythonOperator 2023-11-10T20:00:49.749927+00:00 2023-11-10T20:00:51.940170+00:00 0:00:02.190243 445203 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T20:00:47.669516+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T18:00:00+00:00 EmrJobFlowSensor 2023-11-10T19:00:46.844372+00:00 2023-11-10T19:27:50.782717+00:00 0:27:03.938345 445192 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T19:00:44.883557+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-10T19:00:26.763030+00:00 2023-11-10T19:00:28.108799+00:00 0:00:01.345769 445191 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-10T19:00:24.826280+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T18:00:00+00:00 PythonOperator 2023-11-10T19:00:04.902378+00:00 2023-11-10T19:00:07.075417+00:00 0:00:02.173039 445190 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-10T19:00:02.806033+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T17:00:00+00:00 EmrJobFlowSensor 2023-11-10T18:00:50.239909+00:00 2023-11-10T18:25:53.874617+00:00 0:25:03.634708 445179 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-10T18:00:48.202274+00:00 2 default_pool