Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T07:53:56.705655+00:00 2023-11-20T07:53:57.835135+00:00 0:00:01.129480 448269 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T07:53:54.661678+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T05:00:00+00:00 PythonOperator 2023-11-20T07:27:28.085930+00:00 2023-11-20T07:27:30.304421+00:00 0:00:02.218491 448264 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T07:27:26.023668+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T04:00:00+00:00 EmrJobFlowSensor 2023-11-20T07:27:27.736167+00:00 2023-11-20T07:53:31.913476+00:00 0:26:04.177309 448263 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T07:27:26.023641+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T07:27:06.145662+00:00 2023-11-20T07:27:07.161343+00:00 0:00:01.015681 448262 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T07:27:03.993273+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T03:00:00+00:00 EmrJobFlowSensor 2023-11-20T07:00:37.662733+00:00 2023-11-20T07:26:41.540462+00:00 0:26:03.877729 448254 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T07:00:35.605405+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T04:00:00+00:00 PythonOperator 2023-11-20T07:00:37.433511+00:00 2023-11-20T07:00:39.319514+00:00 0:00:01.886003 448253 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T07:00:35.605443+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T07:00:15.731043+00:00 2023-11-20T07:00:16.692625+00:00 0:00:00.961582 448252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T07:00:13.580423+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T02:00:00+00:00 EmrJobFlowSensor 2023-11-20T06:45:08.940781+00:00 448249 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T06:45:06.784886+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T03:00:00+00:00 PythonOperator 2023-11-20T06:45:08.543360+00:00 2023-11-20T06:45:10.469841+00:00 0:00:01.926481 448248 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T06:45:06.784913+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T06:44:46.746809+00:00 2023-11-20T06:44:48.087666+00:00 0:00:01.340857 448247 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T06:44:44.785567+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T02:00:00+00:00 PythonOperator 2023-11-20T06:18:34.670538+00:00 2023-11-20T06:18:36.879321+00:00 0:00:02.208783 448243 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T06:18:32.588278+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T01:00:00+00:00 EmrJobFlowSensor 2023-11-20T06:18:34.334139+00:00 2023-11-20T06:44:38.314879+00:00 0:26:03.980740 448242 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T06:18:32.588250+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T06:18:12.157887+00:00 2023-11-20T06:18:13.463046+00:00 0:00:01.305159 448240 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T06:18:10.523579+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T01:00:00+00:00 PythonOperator 2023-11-19T02:00:12.087687+00:00 2023-11-19T02:00:13.973519+00:00 0:00:01.885832 447931 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-19T02:00:10.273514+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T00:00:00+00:00 EmrJobFlowSensor 2023-11-19T01:26:00.746365+00:00 2023-11-19T01:26:01.247770+00:00 0:00:00.501405 447920 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-19T01:25:58.672127+00:00 6 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-19T01:00:40.882998+00:00 2023-11-19T01:00:41.922331+00:00 0:00:01.039333 447908 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-19T01:00:39.203711+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T00:00:00+00:00 PythonOperator 2023-11-19T01:00:18.997476+00:00 2023-11-19T01:00:21.029321+00:00 0:00:02.031845 447907 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-19T01:00:17.165837+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T23:00:00+00:00 EmrJobFlowSensor 2023-11-19T00:01:02.846334+00:00 2023-11-19T00:27:06.906179+00:00 0:26:04.059845 447895 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-19T00:01:01.174123+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-19T00:00:43.057781+00:00 2023-11-19T00:00:44.087913+00:00 0:00:01.030132 447894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-19T00:00:41.098014+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T23:00:00+00:00 PythonOperator 2023-11-19T00:00:20.862261+00:00 2023-11-19T00:00:22.806392+00:00 0:00:01.944131 447893 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-19T00:00:19.080788+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T22:00:00+00:00 EmrJobFlowSensor 2023-11-18T23:00:51.349014+00:00 2023-11-18T23:25:55.343102+00:00 0:25:03.994088 447880 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T23:00:49.197971+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T23:00:28.866227+00:00 2023-11-18T23:00:29.855187+00:00 0:00:00.988960 447878 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T23:00:27.187696+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T22:00:00+00:00 PythonOperator 2023-11-18T23:00:07.355573+00:00 2023-11-18T23:00:09.544319+00:00 0:00:02.188746 447876 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T23:00:05.177625+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T21:00:00+00:00 EmrJobFlowSensor 2023-11-18T22:00:57.270817+00:00 2023-11-18T22:24:00.928163+00:00 0:23:03.657346 447864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T22:00:55.536254+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T22:00:35.550011+00:00 2023-11-18T22:00:36.785335+00:00 0:00:01.235324 447863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T22:00:33.564259+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T21:00:00+00:00 PythonOperator 2023-11-18T22:00:13.258716+00:00 2023-11-18T22:00:15.198400+00:00 0:00:01.939684 447862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T22:00:11.499652+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T20:00:00+00:00 EmrJobFlowSensor 2023-11-18T21:00:46.947267+00:00 2023-11-18T21:25:50.906354+00:00 0:25:03.959087 447850 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T21:00:45.014929+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T21:00:25.073339+00:00 2023-11-18T21:00:26.368758+00:00 0:00:01.295419 447849 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T21:00:22.990734+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T20:00:00+00:00 PythonOperator 2023-11-18T21:00:04.958335+00:00 2023-11-18T21:00:07.375683+00:00 0:00:02.417348 447848 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T21:00:02.926946+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T19:00:00+00:00 EmrJobFlowSensor 2023-11-18T20:00:53.179628+00:00 2023-11-18T20:26:57.316312+00:00 0:26:04.136684 447836 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T20:00:51.196907+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T20:00:31.277430+00:00 2023-11-18T20:00:32.261640+00:00 0:00:00.984210 447835 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T20:00:29.177262+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T19:00:00+00:00 PythonOperator 2023-11-18T20:00:11.419022+00:00 2023-11-18T20:00:13.606368+00:00 0:00:02.187346 447834 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T20:00:09.163854+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T18:00:00+00:00 EmrJobFlowSensor 2023-11-18T19:00:53.456770+00:00 2023-11-18T19:26:57.731980+00:00 0:26:04.275210 447822 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T19:00:51.768440+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T19:00:33.751519+00:00 2023-11-18T19:00:34.764783+00:00 0:00:01.013264 447821 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T19:00:31.748892+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T18:00:00+00:00 PythonOperator 2023-11-18T19:00:12.064094+00:00 2023-11-18T19:00:14.249911+00:00 0:00:02.185817 447820 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T19:00:09.787340+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T17:00:00+00:00 EmrJobFlowSensor 2023-11-18T18:00:59.975436+00:00 2023-11-18T18:26:03.957222+00:00 0:25:03.981786 447808 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T18:00:57.983436+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T18:00:37.639060+00:00 2023-11-18T18:00:38.751817+00:00 0:00:01.112757 447807 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T18:00:35.986981+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T17:00:00+00:00 PythonOperator 2023-11-18T18:00:17.748764+00:00 2023-11-18T18:00:19.681267+00:00 0:00:01.932503 447806 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T18:00:15.944445+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T16:00:00+00:00 EmrJobFlowSensor 2023-11-18T17:01:03.052691+00:00 2023-11-18T17:24:06.531012+00:00 0:23:03.478321 447794 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T17:01:01.392961+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T17:00:43.117323+00:00 2023-11-18T17:00:44.172668+00:00 0:00:01.055345 447793 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T17:00:41.384888+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T16:00:00+00:00 PythonOperator 2023-11-18T17:00:21.363252+00:00 2023-11-18T17:00:23.534405+00:00 0:00:02.171153 447792 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T17:00:19.335926+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T15:00:00+00:00 EmrJobFlowSensor 2023-11-18T16:00:52.839462+00:00 2023-11-18T16:25:56.901579+00:00 0:25:04.062117 447780 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T16:00:51.178205+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T16:00:33.155542+00:00 2023-11-18T16:00:34.200640+00:00 0:00:01.045098 447779 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T16:00:31.160300+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T15:00:00+00:00 PythonOperator 2023-11-18T16:00:10.965257+00:00 2023-11-18T16:00:12.931319+00:00 0:00:01.966062 447778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T16:00:09.139487+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T14:00:00+00:00 EmrJobFlowSensor 2023-11-18T15:06:31.556404+00:00 2023-11-18T15:31:35.121648+00:00 0:25:03.565244 447772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T15:06:29.926172+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T15:06:11.575535+00:00 2023-11-18T15:06:12.564396+00:00 0:00:00.988861 447770 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T15:06:09.904629+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T14:00:00+00:00 PythonOperator 2023-11-18T15:05:49.586665+00:00 2023-11-18T15:05:51.518856+00:00 0:00:01.932191 447768 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T15:05:47.884433+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T13:00:00+00:00 EmrJobFlowSensor 2023-11-18T14:02:30.173297+00:00 2023-11-18T14:27:33.988721+00:00 0:25:03.815424 447756 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T14:02:28.471454+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T14:02:10.121982+00:00 2023-11-18T14:02:11.102082+00:00 0:00:00.980100 447755 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T14:02:08.452316+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T13:00:00+00:00 PythonOperator 2023-11-18T14:01:48.801173+00:00 2023-11-18T14:01:50.945614+00:00 0:00:02.144441 447754 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T14:01:46.440063+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T12:00:00+00:00 EmrJobFlowSensor 2023-11-18T13:00:58.565577+00:00 2023-11-18T13:26:02.442920+00:00 0:25:03.877343 447743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T13:00:56.592828+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T13:00:36.464298+00:00 2023-11-18T13:00:37.511527+00:00 0:00:01.047229 447742 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T13:00:34.548172+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T12:00:00+00:00 PythonOperator 2023-11-18T13:00:16.552869+00:00 2023-11-18T13:00:18.725848+00:00 0:00:02.172979 447741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T13:00:14.530055+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T11:00:00+00:00 EmrJobFlowSensor 2023-11-18T12:00:58.279581+00:00 2023-11-18T12:25:02.057124+00:00 0:24:03.777543 447729 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T12:00:56.272829+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T12:00:36.206587+00:00 2023-11-18T12:00:37.267808+00:00 0:00:01.061221 447728 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T12:00:34.251793+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T11:00:00+00:00 PythonOperator 2023-11-18T12:00:14.355433+00:00 2023-11-18T12:00:16.527654+00:00 0:00:02.172221 447727 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T12:00:12.231850+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T10:00:00+00:00 EmrJobFlowSensor 2023-11-18T11:00:50.745651+00:00 2023-11-18T11:24:54.882659+00:00 0:24:04.137008 447715 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T11:00:48.850383+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T11:00:28.963420+00:00 2023-11-18T11:00:29.980210+00:00 0:00:01.016790 447714 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T11:00:26.883123+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T10:00:00+00:00 PythonOperator 2023-11-18T11:00:09.170353+00:00 2023-11-18T11:00:11.374236+00:00 0:00:02.203883 447713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T11:00:06.870979+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T09:00:00+00:00 EmrJobFlowSensor 2023-11-18T10:01:07.045517+00:00 2023-11-18T10:26:10.831979+00:00 0:25:03.786462 447701 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T10:01:05.074624+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T10:00:45.084831+00:00 2023-11-18T10:00:46.111943+00:00 0:00:01.027112 447700 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T10:00:43.058783+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T09:00:00+00:00 PythonOperator 2023-11-18T10:00:25.119386+00:00 2023-11-18T10:00:27.359777+00:00 0:00:02.240391 447699 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T10:00:22.988577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T08:00:00+00:00 EmrJobFlowSensor 2023-11-18T09:01:05.546172+00:00 2023-11-18T09:25:09.467877+00:00 0:24:03.921705 447687 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T09:01:03.383574+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T09:00:43.355571+00:00 2023-11-18T09:00:44.362799+00:00 0:00:01.007228 447686 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T09:00:41.348049+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T08:00:00+00:00 PythonOperator 2023-11-18T09:00:23.402632+00:00 2023-11-18T09:00:25.626287+00:00 0:00:02.223655 447685 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T09:00:21.330636+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T07:00:00+00:00 EmrJobFlowSensor 2023-11-18T08:01:01.310404+00:00 2023-11-18T08:26:05.309414+00:00 0:25:03.999010 447673 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T08:00:59.283637+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T08:00:39.151600+00:00 2023-11-18T08:00:40.140750+00:00 0:00:00.989150 447672 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T08:00:37.246107+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T07:00:00+00:00 PythonOperator 2023-11-18T08:00:19.264216+00:00 2023-11-18T08:00:21.513964+00:00 0:00:02.249748 447671 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T08:00:17.227190+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T06:00:00+00:00 EmrJobFlowSensor 2023-11-18T07:00:51.401820+00:00 2023-11-18T07:25:55.128009+00:00 0:25:03.726189 447659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T07:00:49.421520+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T07:00:29.436051+00:00 2023-11-18T07:00:30.443796+00:00 0:00:01.007745 447658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T07:00:27.401672+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T06:00:00+00:00 PythonOperator 2023-11-18T07:00:09.450327+00:00 2023-11-18T07:00:11.659360+00:00 0:00:02.209033 447657 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T07:00:07.382157+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T05:00:00+00:00 EmrJobFlowSensor 2023-11-18T06:03:00.210240+00:00 2023-11-18T06:28:04.000673+00:00 0:25:03.790433 447647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T06:02:58.193634+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T06:02:40.253275+00:00 2023-11-18T06:02:41.186820+00:00 0:00:00.933545 447646 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T06:02:38.174193+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T05:00:00+00:00 PythonOperator 2023-11-18T06:00:23.364540+00:00 2023-11-18T06:00:25.529397+00:00 0:00:02.164857 447644 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T06:00:21.357661+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T04:00:00+00:00 EmrJobFlowSensor 2023-11-18T05:02:22.364651+00:00 2023-11-18T05:27:26.174948+00:00 0:25:03.810297 447633 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T05:02:20.451492+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T05:02:00.514521+00:00 2023-11-18T05:02:01.456851+00:00 0:00:00.942330 447632 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T05:01:58.432561+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T04:00:00+00:00 PythonOperator 2023-11-18T05:00:24.314511+00:00 2023-11-18T05:00:26.503988+00:00 0:00:02.189477 447630 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T05:00:22.131198+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T03:00:00+00:00 EmrJobFlowSensor 2023-11-18T04:01:02.348968+00:00 2023-11-18T04:26:06.218155+00:00 0:25:03.869187 447618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T04:01:00.331674+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T04:00:40.388023+00:00 2023-11-18T04:00:41.399122+00:00 0:00:01.011099 447616 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T04:00:38.309180+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T03:00:00+00:00 PythonOperator 2023-11-18T04:00:18.636264+00:00 2023-11-18T04:00:20.937844+00:00 0:00:02.301580 447614 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T04:00:16.354050+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T02:00:00+00:00 EmrJobFlowSensor 2023-11-18T03:01:02.493055+00:00 2023-11-18T03:25:06.288332+00:00 0:24:03.795277 447602 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T03:01:00.553205+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T03:00:42.459090+00:00 2023-11-18T03:00:43.428461+00:00 0:00:00.969371 447601 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T03:00:40.534730+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T02:00:00+00:00 PythonOperator 2023-11-18T03:00:20.858302+00:00 2023-11-18T03:00:23.055395+00:00 0:00:02.197093 447600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T03:00:18.566560+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T01:00:00+00:00 EmrJobFlowSensor 2023-11-18T02:00:48.559958+00:00 2023-11-18T02:24:52.374256+00:00 0:24:03.814298 447588 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T02:00:46.520770+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T02:00:26.526885+00:00 2023-11-18T02:00:27.578568+00:00 0:00:01.051683 447587 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T02:00:24.499763+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T01:00:00+00:00 PythonOperator 2023-11-18T02:00:04.747009+00:00 2023-11-18T02:00:07.182232+00:00 0:00:02.435223 447586 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T02:00:02.477593+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-18T00:00:00+00:00 EmrJobFlowSensor 2023-11-18T01:00:53.362319+00:00 2023-11-18T01:25:57.240222+00:00 0:25:03.877903 447570 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T01:00:51.289247+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-18T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T01:00:31.218135+00:00 2023-11-18T01:00:32.230655+00:00 0:00:01.012520 447569 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T01:00:29.225277+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-18T00:00:00+00:00 PythonOperator 2023-11-18T01:00:11.297651+00:00 2023-11-18T01:00:13.509612+00:00 0:00:02.211961 447568 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T01:00:09.208835+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T23:00:00+00:00 EmrJobFlowSensor 2023-11-18T00:00:54.860892+00:00 2023-11-18T00:25:58.905679+00:00 0:25:04.044787 447556 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-18T00:00:52.867619+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-18T00:00:34.853982+00:00 2023-11-18T00:00:35.856277+00:00 0:00:01.002295 447555 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-18T00:00:32.861685+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T23:00:00+00:00 PythonOperator 2023-11-18T00:00:12.858504+00:00 2023-11-18T00:00:15.037024+00:00 0:00:02.178520 447554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-18T00:00:10.781739+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T22:00:00+00:00 EmrJobFlowSensor 2023-11-17T23:00:54.549902+00:00 2023-11-17T23:25:58.417331+00:00 0:25:03.867429 447542 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T23:00:52.557777+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T23:00:34.447279+00:00 2023-11-17T23:00:35.493365+00:00 0:00:01.046086 447540 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T23:00:32.481211+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T22:00:00+00:00 PythonOperator 2023-11-17T23:00:12.346033+00:00 2023-11-17T23:00:14.524452+00:00 0:00:02.178419 447538 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T23:00:10.410192+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T21:00:00+00:00 EmrJobFlowSensor 2023-11-17T22:01:04.942499+00:00 2023-11-17T22:24:08.552189+00:00 0:23:03.609690 447525 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T22:01:02.959905+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T22:00:42.972954+00:00 2023-11-17T22:00:44.016422+00:00 0:00:01.043468 447524 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T22:00:40.884708+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-17T21:00:00+00:00 PythonOperator 2023-11-17T22:00:23.109033+00:00 2023-11-17T22:00:25.293021+00:00 0:00:02.183988 447523 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-17T22:00:20.878028+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-17T20:00:00+00:00 EmrJobFlowSensor 2023-11-17T21:00:51.101992+00:00 2023-11-17T21:24:54.796046+00:00 0:24:03.694054 447511 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-17T21:00:48.989254+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-17T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-17T21:00:30.966858+00:00 2023-11-17T21:00:31.998172+00:00 0:00:01.031314 447510 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-17T21:00:28.965566+00:00 2 default_pool