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-11T16:00:00+00:00 EmrJobFlowSensor 2023-12-11T17:07:30.567902+00:00 2023-12-11T17:24:33.381620+00:00 0:17:02.813718 455607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T17:07:28.067518+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T17:00:40.364610+00:00 2023-12-11T17:00:41.564864+00:00 0:00:01.200254 455604 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T17:00:38.356977+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T16:00:00+00:00 PythonOperator 2023-12-11T17:00:20.257048+00:00 2023-12-11T17:00:21.942243+00:00 0:00:01.685195 455602 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T17:00:18.343288+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T15:00:00+00:00 EmrJobFlowSensor 2023-12-11T16:28:05.169851+00:00 2023-12-11T16:28:05.743157+00:00 0:00:00.573306 455599 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T16:28:02.865532+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T16:00:40.487161+00:00 2023-12-11T16:00:41.557650+00:00 0:00:01.070489 455584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T16:00:38.526170+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T15:00:00+00:00 PythonOperator 2023-12-11T16:00:18.356496+00:00 2023-12-11T16:00:20.005038+00:00 0:00:01.648542 455582 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T16:00:16.504895+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T14:00:00+00:00 EmrJobFlowSensor 2023-12-11T15:00:59.768240+00:00 2023-12-11T15:26:03.765003+00:00 0:25:03.996763 455565 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T15:00:57.767276+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T15:00:37.443145+00:00 2023-12-11T15:00:38.469840+00:00 0:00:01.026695 455563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T15:00:35.750846+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T14:00:00+00:00 PythonOperator 2023-12-11T15:00:17.852459+00:00 2023-12-11T15:00:19.528930+00:00 0:00:01.676471 455561 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T15:00:15.734352+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T13:00:00+00:00 EmrJobFlowSensor 2023-12-11T14:01:39.575873+00:00 2023-12-11T14:26:43.418992+00:00 0:25:03.843119 455544 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T14:01:37.885476+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T14:01:19.924066+00:00 2023-12-11T14:01:20.860555+00:00 0:00:00.936489 455542 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T14:01:17.866971+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T13:00:00+00:00 PythonOperator 2023-12-11T14:00:57.567740+00:00 2023-12-11T14:00:59.230959+00:00 0:00:01.663219 455540 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T14:00:55.846482+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T12:00:00+00:00 EmrJobFlowSensor 2023-12-11T13:01:47.410601+00:00 2023-12-11T13:26:51.171474+00:00 0:25:03.760873 455522 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T13:01:45.517371+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T13:01:27.357487+00:00 2023-12-11T13:01:28.183326+00:00 0:00:00.825839 455520 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T13:01:25.499767+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T12:00:00+00:00 PythonOperator 2023-12-11T13:01:05.711772+00:00 2023-12-11T13:01:07.446510+00:00 0:00:01.734738 455518 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T13:01:03.479134+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T11:00:00+00:00 EmrJobFlowSensor 2023-12-11T12:00:57.851954+00:00 2023-12-11T12:26:02.054839+00:00 0:25:04.202885 455499 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T12:00:55.929009+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T12:00:35.574786+00:00 2023-12-11T12:00:36.658222+00:00 0:00:01.083436 455497 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T12:00:33.910597+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T11:00:00+00:00 PythonOperator 2023-12-11T12:00:16.173944+00:00 2023-12-11T12:00:18.012705+00:00 0:00:01.838761 455496 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T12:00:13.892540+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T10:00:00+00:00 EmrJobFlowSensor 2023-12-11T11:00:56.336814+00:00 2023-12-11T11:27:00.419533+00:00 0:26:04.082719 455477 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T11:00:54.561774+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T11:00:34.529764+00:00 2023-12-11T11:00:35.500584+00:00 0:00:00.970820 455476 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T11:00:32.489123+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T10:00:00+00:00 PythonOperator 2023-12-11T11:00:15.723232+00:00 2023-12-11T11:00:17.528028+00:00 0:00:01.804796 455474 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T11:00:12.464399+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T09:00:00+00:00 EmrJobFlowSensor 2023-12-11T10:01:02.949374+00:00 2023-12-11T10:25:06.621989+00:00 0:24:03.672615 455455 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T10:01:01.235880+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T10:00:41.252873+00:00 2023-12-11T10:00:42.296191+00:00 0:00:01.043318 455453 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T10:00:39.268076+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T09:00:00+00:00 PythonOperator 2023-12-11T10:00:21.159395+00:00 2023-12-11T10:00:22.847155+00:00 0:00:01.687760 455451 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T10:00:19.251261+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T08:00:00+00:00 EmrJobFlowSensor 2023-12-11T09:00:49.230418+00:00 2023-12-11T09:22:52.520950+00:00 0:22:03.290532 455433 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T09:00:47.161637+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T09:00:28.983961+00:00 2023-12-11T09:00:29.914370+00:00 0:00:00.930409 455431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T09:00:27.031372+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T08:00:00+00:00 PythonOperator 2023-12-11T09:00:07.218764+00:00 2023-12-11T09:00:08.923305+00:00 0:00:01.704541 455429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T09:00:05.069337+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T07:00:00+00:00 EmrJobFlowSensor 2023-12-11T08:00:47.193842+00:00 2023-12-11T08:23:50.827789+00:00 0:23:03.633947 455411 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T08:00:45.161927+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T08:00:26.995365+00:00 2023-12-11T08:00:27.866261+00:00 0:00:00.870896 455409 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T08:00:25.032944+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T07:00:00+00:00 PythonOperator 2023-12-11T08:00:04.859761+00:00 2023-12-11T08:00:06.582116+00:00 0:00:01.722355 455407 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T08:00:03.010653+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T06:00:00+00:00 EmrJobFlowSensor 2023-12-11T07:00:48.429541+00:00 2023-12-11T07:23:51.967275+00:00 0:23:03.537734 455389 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T07:00:46.500906+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T07:00:28.249620+00:00 2023-12-11T07:00:29.257177+00:00 0:00:01.007557 455387 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T07:00:26.556489+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T06:00:00+00:00 PythonOperator 2023-12-11T07:00:06.287464+00:00 2023-12-11T07:00:08.006089+00:00 0:00:01.718625 455385 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T07:00:04.451314+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T05:00:00+00:00 EmrJobFlowSensor 2023-12-11T06:00:56.645866+00:00 2023-12-11T06:22:59.915591+00:00 0:22:03.269725 455368 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T06:00:54.911337+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T06:00:34.649598+00:00 2023-12-11T06:00:35.683607+00:00 0:00:01.034009 455366 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T06:00:32.892007+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T05:00:00+00:00 PythonOperator 2023-12-11T06:00:13.466616+00:00 2023-12-11T06:00:15.092030+00:00 0:00:01.625414 455364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T06:00:10.885692+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T04:00:00+00:00 EmrJobFlowSensor 2023-12-11T05:01:03.855332+00:00 2023-12-11T05:23:07.299537+00:00 0:22:03.444205 455348 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T05:01:02.150840+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T05:00:43.826900+00:00 2023-12-11T05:00:44.876302+00:00 0:00:01.049402 455346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T05:00:42.132914+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T04:00:00+00:00 PythonOperator 2023-12-11T05:00:22.086648+00:00 2023-12-11T05:00:23.736792+00:00 0:00:01.650144 455344 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T05:00:20.113577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T03:00:00+00:00 EmrJobFlowSensor 2023-12-11T04:00:49.269131+00:00 2023-12-11T04:22:52.644287+00:00 0:22:03.375156 455324 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T04:00:47.379722+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T04:00:29.251812+00:00 2023-12-11T04:00:30.129299+00:00 0:00:00.877487 455321 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T04:00:27.362399+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T03:00:00+00:00 PythonOperator 2023-12-11T04:00:07.319140+00:00 2023-12-11T04:00:09.019103+00:00 0:00:01.699963 455318 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T04:00:05.358850+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T02:00:00+00:00 EmrJobFlowSensor 2023-12-11T03:01:04.375583+00:00 2023-12-11T03:23:07.710291+00:00 0:22:03.334708 455299 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T03:01:02.365787+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T03:00:42.257287+00:00 2023-12-11T03:00:43.456076+00:00 0:00:01.198789 455296 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T03:00:40.343095+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T02:00:00+00:00 PythonOperator 2023-12-11T03:00:22.596783+00:00 2023-12-11T03:00:24.293666+00:00 0:00:01.696883 455295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T03:00:20.327591+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T01:00:00+00:00 EmrJobFlowSensor 2023-12-11T02:00:56.067751+00:00 2023-12-11T02:22:59.628035+00:00 0:22:03.560284 455275 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T02:00:54.150367+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T02:00:34.290426+00:00 2023-12-11T02:00:35.286444+00:00 0:00:00.996018 455273 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T02:00:32.133258+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T01:00:00+00:00 PythonOperator 2023-12-11T02:00:14.645812+00:00 2023-12-11T02:00:16.400878+00:00 0:00:01.755066 455271 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T02:00:12.114154+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T00:00:00+00:00 EmrJobFlowSensor 2023-12-11T01:01:06.331631+00:00 2023-12-11T01:23:09.913971+00:00 0:22:03.582340 455248 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T01:01:04.274243+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T01:00:44.288002+00:00 2023-12-11T01:00:45.293644+00:00 0:00:01.005642 455246 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T01:00:42.248530+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T00:00:00+00:00 PythonOperator 2023-12-11T01:00:24.216960+00:00 2023-12-11T01:00:26.001474+00:00 0:00:01.784514 455244 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T01:00:22.230007+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T23:00:00+00:00 EmrJobFlowSensor 2023-12-11T00:00:54.444258+00:00 2023-12-11T00:23:57.907086+00:00 0:23:03.462828 455225 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T00:00:52.459068+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T00:00:32.419307+00:00 2023-12-11T00:00:33.397730+00:00 0:00:00.978423 455223 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T00:00:30.451752+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T23:00:00+00:00 PythonOperator 2023-12-11T00:00:10.607181+00:00 2023-12-11T00:00:12.277109+00:00 0:00:01.669928 455221 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T00:00:08.473470+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T22:00:00+00:00 EmrJobFlowSensor 2023-12-10T23:00:47.538706+00:00 2023-12-10T23:23:51.010773+00:00 0:23:03.472067 455201 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T23:00:45.867775+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T23:00:26.285219+00:00 2023-12-10T23:00:27.183843+00:00 0:00:00.898624 455198 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T23:00:23.853442+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T22:00:00+00:00 PythonOperator 2023-12-10T23:00:04.080995+00:00 2023-12-10T23:00:05.777135+00:00 0:00:01.696140 455195 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T23:00:01.885107+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T21:00:00+00:00 EmrJobFlowSensor 2023-12-10T22:00:50.950636+00:00 2023-12-10T22:22:54.276953+00:00 0:22:03.326317 455177 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T22:00:49.333697+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T22:00:31.274674+00:00 2023-12-10T22:00:32.182715+00:00 0:00:00.908041 455175 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T22:00:29.316088+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T21:00:00+00:00 PythonOperator 2023-12-10T22:00:09.079392+00:00 2023-12-10T22:00:10.725687+00:00 0:00:01.646295 455173 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T22:00:07.298181+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T20:00:00+00:00 EmrJobFlowSensor 2023-12-10T21:01:01.640004+00:00 2023-12-10T21:26:05.583189+00:00 0:25:03.943185 455156 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T21:00:59.760067+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T21:00:41.411821+00:00 2023-12-10T21:00:42.439277+00:00 0:00:01.027456 455154 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T21:00:39.739284+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T20:00:00+00:00 PythonOperator 2023-12-10T21:00:19.694072+00:00 2023-12-10T21:00:21.508218+00:00 0:00:01.814146 455152 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T21:00:17.721136+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T19:00:00+00:00 EmrJobFlowSensor 2023-12-10T20:00:55.228774+00:00 2023-12-10T20:26:59.474499+00:00 0:26:04.245725 455133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T20:00:53.540905+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T20:00:35.454192+00:00 2023-12-10T20:00:36.429923+00:00 0:00:00.975731 455131 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T20:00:33.523441+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T19:00:00+00:00 PythonOperator 2023-12-10T20:00:13.547955+00:00 2023-12-10T20:00:15.295684+00:00 0:00:01.747729 455129 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T20:00:11.502948+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T18:00:00+00:00 EmrJobFlowSensor 2023-12-10T19:00:47.253244+00:00 2023-12-10T19:27:51.289055+00:00 0:27:04.035811 455111 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T19:00:44.761961+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T19:00:24.642405+00:00 2023-12-10T19:00:25.574213+00:00 0:00:00.931808 455109 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T19:00:22.736276+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T18:00:00+00:00 PythonOperator 2023-12-10T19:00:03.192251+00:00 2023-12-10T19:00:04.881565+00:00 0:00:01.689314 455107 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T19:00:00.780498+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T17:00:00+00:00 EmrJobFlowSensor 2023-12-10T18:01:02.596012+00:00 2023-12-10T18:27:06.581558+00:00 0:26:03.985546 455090 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T18:01:00.653086+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T18:00:40.327637+00:00 2023-12-10T18:00:41.322214+00:00 0:00:00.994577 455088 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T18:00:38.632568+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T17:00:00+00:00 PythonOperator 2023-12-10T18:00:20.560059+00:00 2023-12-10T18:00:22.231502+00:00 0:00:01.671443 455086 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T18:00:18.613404+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T16:00:00+00:00 EmrJobFlowSensor 2023-12-10T17:02:06.201628+00:00 2023-12-10T17:25:09.709019+00:00 0:23:03.507391 455069 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T17:02:04.200593+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T17:01:46.089216+00:00 2023-12-10T17:01:47.066535+00:00 0:00:00.977319 455067 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T17:01:44.181801+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T16:00:00+00:00 PythonOperator 2023-12-10T17:01:23.875465+00:00 2023-12-10T17:01:25.497533+00:00 0:00:01.622068 455065 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T17:01:22.162626+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T15:00:00+00:00 EmrJobFlowSensor 2023-12-10T16:00:59.759181+00:00 2023-12-10T16:23:03.249032+00:00 0:22:03.489851 455046 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T16:00:57.785544+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T16:00:37.434115+00:00 2023-12-10T16:00:38.477939+00:00 0:00:01.043824 455044 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T16:00:35.753776+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T15:00:00+00:00 PythonOperator 2023-12-10T16:00:17.665173+00:00 2023-12-10T16:00:19.360639+00:00 0:00:01.695466 455042 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T16:00:15.732748+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T14:00:00+00:00 EmrJobFlowSensor 2023-12-10T15:00:57.231980+00:00 2023-12-10T15:23:00.693993+00:00 0:22:03.462013 455025 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T15:00:55.551779+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T15:00:35.334510+00:00 2023-12-10T15:00:36.323230+00:00 0:00:00.988720 455023 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T15:00:33.473415+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T14:00:00+00:00 PythonOperator 2023-12-10T15:00:15.170263+00:00 2023-12-10T15:00:16.866105+00:00 0:00:01.695842 455021 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T15:00:13.454941+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T13:00:00+00:00 EmrJobFlowSensor 2023-12-10T14:00:55.130213+00:00 2023-12-10T14:22:58.667794+00:00 0:22:03.537581 455003 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T14:00:53.217188+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T14:00:32.904191+00:00 2023-12-10T14:00:34.032460+00:00 0:00:01.128269 455001 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T14:00:31.194658+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T13:00:00+00:00 PythonOperator 2023-12-10T14:00:11.163000+00:00 2023-12-10T14:00:12.860276+00:00 0:00:01.697276 454999 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T14:00:09.161777+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T12:00:00+00:00 EmrJobFlowSensor 2023-12-10T13:00:47.250561+00:00 2023-12-10T13:22:50.684522+00:00 0:22:03.433961 454981 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T13:00:45.262812+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T13:00:25.173335+00:00 2023-12-10T13:00:26.091558+00:00 0:00:00.918223 454979 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T13:00:23.184162+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T12:00:00+00:00 PythonOperator 2023-12-10T13:00:04.964277+00:00 2023-12-10T13:00:06.738629+00:00 0:00:01.774352 454977 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T13:00:03.162192+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T11:00:00+00:00 EmrJobFlowSensor 2023-12-10T12:00:59.775870+00:00 2023-12-10T12:23:03.373208+00:00 0:22:03.597338 454961 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T12:00:57.866792+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T12:00:37.538965+00:00 2023-12-10T12:00:38.797555+00:00 0:00:01.258590 454959 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T12:00:35.852596+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T11:00:00+00:00 PythonOperator 2023-12-10T12:00:17.520026+00:00 2023-12-10T12:00:19.291870+00:00 0:00:01.771844 454957 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T12:00:15.829455+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T10:00:00+00:00 EmrJobFlowSensor 2023-12-10T11:01:03.876700+00:00 2023-12-10T11:23:07.258082+00:00 0:22:03.381382 454940 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T11:01:01.952725+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T11:00:41.851619+00:00 2023-12-10T11:00:42.848059+00:00 0:00:00.996440 454938 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T11:00:39.931041+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T10:00:00+00:00 PythonOperator 2023-12-10T11:00:19.822654+00:00 2023-12-10T11:00:21.635778+00:00 0:00:01.813124 454936 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T11:00:17.914826+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T09:00:00+00:00 EmrJobFlowSensor 2023-12-10T10:02:29.928809+00:00 2023-12-10T10:25:33.490255+00:00 0:23:03.561446 454918 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T10:02:28.028217+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T10:02:09.939116+00:00 2023-12-10T10:02:10.853592+00:00 0:00:00.914476 454916 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T10:02:08.007907+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T09:00:00+00:00 PythonOperator 2023-12-10T10:01:48.334588+00:00 2023-12-10T10:01:50.010531+00:00 0:00:01.675943 454914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T10:01:45.993123+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T08:00:00+00:00 EmrJobFlowSensor 2023-12-10T09:00:55.975428+00:00 2023-12-10T09:22:59.527952+00:00 0:22:03.552524 454897 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T09:00:54.257013+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-10T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-10T09:00:34.240472+00:00 2023-12-10T09:00:35.217481+00:00 0:00:00.977009 454895 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-10T09:00:32.283873+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-10T08:00:00+00:00 PythonOperator 2023-12-10T09:00:12.646634+00:00 2023-12-10T09:00:14.316198+00:00 0:00:01.669564 454893 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-10T09:00:10.276807+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-10T07:00:00+00:00 EmrJobFlowSensor 2023-12-10T08:01:03.141249+00:00 2023-12-10T08:23:06.537788+00:00 0:22:03.396539 454876 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-10T08:01:01.455676+00:00 2 default_pool