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_emr_steps 2023-12-13T02:00:00+00:00 PythonOperator 2023-12-13T03:00:18.364908+00:00 2023-12-13T03:00:20.029102+00:00 0:00:01.664194 456370 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T03:00:16.321536+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T01:00:00+00:00 EmrJobFlowSensor 2023-12-13T02:01:11.616324+00:00 2023-12-13T02:29:15.712278+00:00 0:28:04.095954 456352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T02:01:09.084945+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T02:00:42.879616+00:00 2023-12-13T02:00:43.837996+00:00 0:00:00.958380 456350 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T02:00:41.092136+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T01:00:00+00:00 PythonOperator 2023-12-13T02:00:21.285009+00:00 2023-12-13T02:00:23.042303+00:00 0:00:01.757294 456348 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T02:00:19.071041+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-13T00:00:00+00:00 EmrJobFlowSensor 2023-12-13T01:01:44.385028+00:00 2023-12-13T01:27:48.458282+00:00 0:26:04.073254 456325 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T01:01:42.276283+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-13T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T01:00:41.661808+00:00 2023-12-13T01:00:42.709390+00:00 0:00:01.047582 456322 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T01:00:39.647214+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-13T00:00:00+00:00 PythonOperator 2023-12-13T01:00:21.884724+00:00 2023-12-13T01:00:23.594549+00:00 0:00:01.709825 456320 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T01:00:19.626530+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T23:00:00+00:00 EmrJobFlowSensor 2023-12-13T00:01:28.347929+00:00 2023-12-13T00:27:32.449642+00:00 0:26:04.101713 456303 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-13T00:01:26.717183+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-13T00:00:27.004554+00:00 2023-12-13T00:00:28.036148+00:00 0:00:01.031594 456299 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-13T00:00:25.291214+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T23:00:00+00:00 PythonOperator 2023-12-13T00:00:05.726777+00:00 2023-12-13T00:00:07.436068+00:00 0:00:01.709291 456297 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-13T00:00:03.272991+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T22:00:00+00:00 EmrJobFlowSensor 2023-12-12T23:01:09.251896+00:00 2023-12-12T23:29:13.229933+00:00 0:28:03.978037 456280 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T23:01:07.115576+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T23:00:33.784817+00:00 2023-12-12T23:00:34.701400+00:00 0:00:00.916583 456276 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T23:00:31.699165+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T22:00:00+00:00 PythonOperator 2023-12-12T23:00:11.346394+00:00 2023-12-12T23:00:12.985531+00:00 0:00:01.639137 456273 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T23:00:09.674844+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T21:00:00+00:00 EmrJobFlowSensor 2023-12-12T22:01:19.261767+00:00 2023-12-12T22:25:23.051715+00:00 0:24:03.789948 456256 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T22:01:17.160521+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T22:00:39.555642+00:00 2023-12-12T22:00:40.587531+00:00 0:00:01.031889 456253 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T22:00:37.489617+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T21:00:00+00:00 PythonOperator 2023-12-12T22:00:19.156242+00:00 2023-12-12T22:00:20.828082+00:00 0:00:01.671840 456251 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T22:00:17.475232+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T20:00:00+00:00 EmrJobFlowSensor 2023-12-12T21:01:11.478751+00:00 2023-12-12T21:28:15.527620+00:00 0:27:04.048869 456233 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T21:01:09.073355+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T21:00:44.574612+00:00 2023-12-12T21:00:45.557852+00:00 0:00:00.983240 456231 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T21:00:42.448976+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T20:00:00+00:00 PythonOperator 2023-12-12T21:00:24.567489+00:00 2023-12-12T21:00:26.253489+00:00 0:00:01.686000 456229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T21:00:22.431967+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T19:00:00+00:00 EmrJobFlowSensor 2023-12-12T20:01:14.754332+00:00 2023-12-12T20:31:19.879334+00:00 0:30:05.125002 456211 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T20:01:12.955339+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T20:00:39.636270+00:00 2023-12-12T20:00:40.563491+00:00 0:00:00.927221 456209 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T20:00:37.534231+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T19:00:00+00:00 PythonOperator 2023-12-12T20:00:19.568250+00:00 2023-12-12T20:00:21.227620+00:00 0:00:01.659370 456207 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T20:00:17.514949+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T18:00:00+00:00 EmrJobFlowSensor 2023-12-12T19:01:20.579826+00:00 2023-12-12T19:30:24.870332+00:00 0:29:04.290506 456190 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T19:01:18.835582+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T19:00:42.184211+00:00 2023-12-12T19:00:43.255586+00:00 0:00:01.071375 456187 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T19:00:40.523564+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T18:00:00+00:00 PythonOperator 2023-12-12T19:00:20.553721+00:00 2023-12-12T19:00:22.242118+00:00 0:00:01.688397 456185 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T19:00:18.504944+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T17:00:00+00:00 EmrJobFlowSensor 2023-12-12T18:01:29.395872+00:00 2023-12-12T18:28:33.587766+00:00 0:27:04.191894 456168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T18:01:27.279931+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T18:00:40.251609+00:00 2023-12-12T18:00:41.242424+00:00 0:00:00.990815 456165 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T18:00:38.364952+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T17:00:00+00:00 PythonOperator 2023-12-12T18:00:20.159462+00:00 2023-12-12T18:00:21.834656+00:00 0:00:01.675194 456163 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T18:00:18.352668+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T16:00:00+00:00 EmrJobFlowSensor 2023-12-12T17:01:16.113534+00:00 2023-12-12T17:27:20.307829+00:00 0:26:04.194295 456146 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T17:01:13.729705+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T17:00:43.272539+00:00 2023-12-12T17:00:44.235013+00:00 0:00:00.962474 456143 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T17:00:41.602844+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T16:00:00+00:00 PythonOperator 2023-12-12T17:00:23.684829+00:00 2023-12-12T17:00:25.317064+00:00 0:00:01.632235 456141 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T17:00:21.581958+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T15:00:00+00:00 EmrJobFlowSensor 2023-12-12T16:01:01.164688+00:00 2023-12-12T16:28:05.421136+00:00 0:27:04.256448 456126 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T16:00:58.975570+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T16:00:41.116772+00:00 2023-12-12T16:00:42.203117+00:00 0:00:01.086345 456124 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T16:00:38.961852+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T15:00:00+00:00 PythonOperator 2023-12-12T16:00:18.541131+00:00 2023-12-12T16:00:20.234630+00:00 0:00:01.693499 456122 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T16:00:16.886243+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T14:00:00+00:00 EmrJobFlowSensor 2023-12-12T15:00:56.796415+00:00 2023-12-12T15:29:01.281925+00:00 0:28:04.485510 456104 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T15:00:54.584076+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T15:00:35.249402+00:00 2023-12-12T15:00:36.177975+00:00 0:00:00.928573 456102 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T15:00:32.511172+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T14:00:00+00:00 PythonOperator 2023-12-12T15:00:14.187550+00:00 2023-12-12T15:00:15.962673+00:00 0:00:01.775123 456100 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T15:00:12.495350+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T13:00:00+00:00 EmrJobFlowSensor 2023-12-12T14:01:46.760017+00:00 2023-12-12T14:29:50.902401+00:00 0:28:04.142384 456083 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T14:01:45.092793+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T14:01:27.136848+00:00 2023-12-12T14:01:28.231702+00:00 0:00:01.094854 456081 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T14:01:25.071470+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T13:00:00+00:00 PythonOperator 2023-12-12T14:01:04.772108+00:00 2023-12-12T14:01:06.596738+00:00 0:00:01.824630 456079 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T14:01:03.056296+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T12:00:00+00:00 EmrJobFlowSensor 2023-12-12T13:02:50.478710+00:00 2023-12-12T13:30:54.646699+00:00 0:28:04.167989 456055 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T13:02:48.815021+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T13:02:30.471376+00:00 2023-12-12T13:02:31.455309+00:00 0:00:00.983933 456053 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T13:02:28.796982+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T12:00:00+00:00 PythonOperator 2023-12-12T13:02:08.893991+00:00 2023-12-12T13:02:10.538864+00:00 0:00:01.644873 456051 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T13:02:06.776965+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T11:00:00+00:00 EmrJobFlowSensor 2023-12-12T12:01:02.479542+00:00 2023-12-12T12:29:06.784421+00:00 0:28:04.304879 456034 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T12:01:00.341650+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T12:00:39.953900+00:00 2023-12-12T12:00:41.045414+00:00 0:00:01.091514 456031 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T12:00:38.320317+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T11:00:00+00:00 PythonOperator 2023-12-12T12:00:18.779816+00:00 2023-12-12T12:00:20.436560+00:00 0:00:01.656744 456029 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T12:00:16.362901+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T10:00:00+00:00 EmrJobFlowSensor 2023-12-12T11:01:07.949777+00:00 2023-12-12T11:28:12.109865+00:00 0:27:04.160088 456014 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T11:01:05.926494+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T11:00:48.545476+00:00 2023-12-12T11:00:49.531117+00:00 0:00:00.985641 456012 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T11:00:45.906186+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T10:00:00+00:00 PythonOperator 2023-12-12T11:00:26.408535+00:00 2023-12-12T11:00:28.123587+00:00 0:00:01.715052 456010 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T11:00:23.887919+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T09:00:00+00:00 EmrJobFlowSensor 2023-12-12T10:00:47.142787+00:00 2023-12-12T10:26:50.926924+00:00 0:26:03.784137 455991 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T10:00:45.468503+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T10:00:27.151579+00:00 2023-12-12T10:00:28.382412+00:00 0:00:01.230833 455989 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T10:00:25.449915+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T09:00:00+00:00 PythonOperator 2023-12-12T10:00:05.210913+00:00 2023-12-12T10:00:06.996418+00:00 0:00:01.785505 455987 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T10:00:03.433386+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T08:00:00+00:00 EmrJobFlowSensor 2023-12-12T09:00:52.340185+00:00 2023-12-12T09:27:56.552068+00:00 0:27:04.211883 455969 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T09:00:50.681131+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T09:00:32.775700+00:00 2023-12-12T09:00:33.716912+00:00 0:00:00.941212 455967 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T09:00:30.666980+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T08:00:00+00:00 PythonOperator 2023-12-12T09:00:10.810125+00:00 2023-12-12T09:00:12.511729+00:00 0:00:01.701604 455965 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T09:00:08.646140+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T07:00:00+00:00 EmrJobFlowSensor 2023-12-12T08:01:01.801629+00:00 2023-12-12T08:29:06.130012+00:00 0:28:04.328383 455949 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T08:00:59.663188+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T08:00:39.272514+00:00 2023-12-12T08:00:40.215799+00:00 0:00:00.943285 455947 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T08:00:37.598901+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T07:00:00+00:00 PythonOperator 2023-12-12T08:00:19.239279+00:00 2023-12-12T08:00:20.942495+00:00 0:00:01.703216 455945 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T08:00:17.580538+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T06:00:00+00:00 EmrJobFlowSensor 2023-12-12T07:01:00.058156+00:00 2023-12-12T07:29:04.467660+00:00 0:28:04.409504 455927 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T07:00:58.350336+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T07:00:38.389391+00:00 2023-12-12T07:00:39.365130+00:00 0:00:00.975739 455925 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T07:00:36.329721+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T06:00:00+00:00 PythonOperator 2023-12-12T07:00:18.399143+00:00 2023-12-12T07:00:20.122332+00:00 0:00:01.723189 455923 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T07:00:16.316456+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T05:00:00+00:00 EmrJobFlowSensor 2023-12-12T06:00:48.531347+00:00 2023-12-12T06:25:52.546615+00:00 0:25:04.015268 455905 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T06:00:46.478964+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T06:00:26.541912+00:00 2023-12-12T06:00:27.465290+00:00 0:00:00.923378 455903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T06:00:24.456646+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T05:00:00+00:00 PythonOperator 2023-12-12T06:00:06.724523+00:00 2023-12-12T06:00:08.396622+00:00 0:00:01.672099 455901 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T06:00:04.441168+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T04:00:00+00:00 EmrJobFlowSensor 2023-12-12T05:00:59.738501+00:00 2023-12-12T05:26:03.763994+00:00 0:25:04.025493 455885 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T05:00:57.578433+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T05:00:37.343205+00:00 2023-12-12T05:00:38.397759+00:00 0:00:01.054554 455882 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T05:00:35.562514+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T04:00:00+00:00 PythonOperator 2023-12-12T05:00:17.463405+00:00 2023-12-12T05:00:19.146483+00:00 0:00:01.683078 455880 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T05:00:15.492244+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T03:00:00+00:00 EmrJobFlowSensor 2023-12-12T04:00:55.229437+00:00 2023-12-12T04:25:59.125684+00:00 0:25:03.896247 455862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T04:00:53.468668+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T04:00:33.147404+00:00 2023-12-12T04:00:34.044202+00:00 0:00:00.896798 455859 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T04:00:31.407186+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T03:00:00+00:00 PythonOperator 2023-12-12T04:00:13.492493+00:00 2023-12-12T04:00:15.329864+00:00 0:00:01.837371 455856 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T04:00:11.390079+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T02:00:00+00:00 EmrJobFlowSensor 2023-12-12T03:00:55.341497+00:00 2023-12-12T03:25:59.110711+00:00 0:25:03.769214 455837 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T03:00:53.589231+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T03:00:35.793344+00:00 2023-12-12T03:00:37.118027+00:00 0:00:01.324683 455835 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T03:00:33.574311+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T02:00:00+00:00 PythonOperator 2023-12-12T03:00:13.504381+00:00 2023-12-12T03:00:15.226577+00:00 0:00:01.722196 455833 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T03:00:11.568000+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T01:00:00+00:00 EmrJobFlowSensor 2023-12-12T02:00:59.582448+00:00 2023-12-12T02:25:03.441739+00:00 0:24:03.859291 455816 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T02:00:57.764423+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T02:00:40.548592+00:00 2023-12-12T02:00:41.481252+00:00 0:00:00.932660 455814 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T02:00:37.754746+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T01:00:00+00:00 PythonOperator 2023-12-12T02:00:18.443555+00:00 2023-12-12T02:00:20.149229+00:00 0:00:01.705674 455812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T02:00:15.681907+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-12T00:00:00+00:00 EmrJobFlowSensor 2023-12-12T01:00:48.802217+00:00 2023-12-12T01:25:52.925733+00:00 0:25:04.123516 455787 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T01:00:46.579131+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-12T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T01:00:28.609545+00:00 2023-12-12T01:00:29.670355+00:00 0:00:01.060810 455785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T01:00:26.504107+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-12T00:00:00+00:00 PythonOperator 2023-12-12T01:00:06.738218+00:00 2023-12-12T01:00:08.522133+00:00 0:00:01.783915 455783 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T01:00:04.486788+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T23:00:00+00:00 EmrJobFlowSensor 2023-12-12T00:00:54.644068+00:00 2023-12-12T00:25:58.582265+00:00 0:25:03.938197 455766 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-12T00:00:52.867983+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-12T00:00:35.074548+00:00 2023-12-12T00:00:36.023552+00:00 0:00:00.949004 455764 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-12T00:00:32.862415+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T23:00:00+00:00 PythonOperator 2023-12-12T00:00:12.882247+00:00 2023-12-12T00:00:14.529661+00:00 0:00:01.647414 455762 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-12T00:00:10.786970+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T22:00:00+00:00 EmrJobFlowSensor 2023-12-11T23:00:51.734358+00:00 2023-12-11T23:25:55.413534+00:00 0:25:03.679176 455743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T23:00:49.549541+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T23:00:29.247045+00:00 2023-12-11T23:00:30.213969+00:00 0:00:00.966924 455739 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T23:00:27.481394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T22:00:00+00:00 PythonOperator 2023-12-11T23:00:09.942341+00:00 2023-12-11T23:00:11.611113+00:00 0:00:01.668772 455737 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T23:00:07.483210+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T21:00:00+00:00 EmrJobFlowSensor 2023-12-11T22:00:54.477427+00:00 2023-12-11T22:23:58.013949+00:00 0:23:03.536522 455716 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T22:00:52.809914+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T22:00:34.960747+00:00 2023-12-11T22:00:35.918142+00:00 0:00:00.957395 455714 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T22:00:32.854429+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T21:00:00+00:00 PythonOperator 2023-12-11T22:00:12.569639+00:00 2023-12-11T22:00:14.209538+00:00 0:00:01.639899 455712 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T22:00:10.771266+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T20:00:00+00:00 EmrJobFlowSensor 2023-12-11T21:00:57.184703+00:00 2023-12-11T21:28:01.231206+00:00 0:27:04.046503 455694 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T21:00:55.362497+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T21:00:37.548805+00:00 2023-12-11T21:00:38.473322+00:00 0:00:00.924517 455693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T21:00:35.288221+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T20:00:00+00:00 PythonOperator 2023-12-11T21:00:15.185211+00:00 2023-12-11T21:00:16.921371+00:00 0:00:01.736160 455690 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T21:00:13.288721+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T19:00:00+00:00 EmrJobFlowSensor 2023-12-11T20:00:55.762385+00:00 2023-12-11T20:28:59.860529+00:00 0:28:04.098144 455673 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T20:00:53.268004+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T20:00:33.064515+00:00 2023-12-11T20:00:34.006780+00:00 0:00:00.942265 455670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T20:00:31.258749+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T19:00:00+00:00 PythonOperator 2023-12-11T20:00:12.962207+00:00 2023-12-11T20:00:14.687324+00:00 0:00:01.725117 455669 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T20:00:11.184319+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T18:00:00+00:00 EmrJobFlowSensor 2023-12-11T19:00:58.630529+00:00 2023-12-11T19:28:02.808532+00:00 0:27:04.178003 455651 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T19:00:56.879148+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T19:00:36.665129+00:00 2023-12-11T19:00:37.631543+00:00 0:00:00.966414 455648 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T19:00:34.859083+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T18:00:00+00:00 PythonOperator 2023-12-11T19:00:16.987585+00:00 2023-12-11T19:00:18.630310+00:00 0:00:01.642725 455647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T19:00:14.858347+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-11T17:00:00+00:00 EmrJobFlowSensor 2023-12-11T18:00:46.887666+00:00 2023-12-11T18:25:50.664496+00:00 0:25:03.776830 455628 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-11T18:00:45.084382+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-11T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-11T18:00:25.192291+00:00 2023-12-11T18:00:26.208362+00:00 0:00:01.016071 455626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-11T18:00:23.071912+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-11T17:00:00+00:00 PythonOperator 2023-12-11T18:00:05.383450+00:00 2023-12-11T18:00:07.149001+00:00 0:00:01.765551 455624 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-11T18:00:03.039615+00:00 2 default_pool