Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T14:00:00+00:00 EmrJobFlowSensor 2023-11-20T22:34:55.099067+00:00 2023-11-20T22:59:58.660843+00:00 0:25:03.561776 448527 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T22:34:53.415563+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T22:34:35.596930+00:00 2023-11-20T22:34:36.633452+00:00 0:00:01.036522 448526 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T22:34:33.398211+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T13:00:00+00:00 EmrJobFlowSensor 2023-11-20T22:09:09.484717+00:00 2023-11-20T22:34:13.442598+00:00 0:25:03.957881 448522 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T22:09:07.489391+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T14:00:00+00:00 PythonOperator 2023-11-20T22:09:09.142843+00:00 2023-11-20T22:09:11.119094+00:00 0:00:01.976251 448521 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T22:09:07.489421+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T22:08:47.119332+00:00 2023-11-20T22:08:48.197192+00:00 0:00:01.077860 448520 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T22:08:45.458985+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T12:00:00+00:00 EmrJobFlowSensor 2023-11-20T21:41:36.680968+00:00 2023-11-20T22:08:40.781702+00:00 0:27:04.100734 448512 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T21:41:34.632129+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T13:00:00+00:00 PythonOperator 2023-11-20T21:41:36.357951+00:00 2023-11-20T21:41:38.380814+00:00 0:00:02.022863 448511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T21:41:34.632157+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T21:41:14.456939+00:00 2023-11-20T21:41:15.547601+00:00 0:00:01.090662 448510 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T21:41:12.657702+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T12:00:00+00:00 PythonOperator 2023-11-20T21:14:02.079410+00:00 2023-11-20T21:14:04.333793+00:00 0:00:02.254383 448506 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T21:14:00.096178+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T11:00:00+00:00 EmrJobFlowSensor 2023-11-20T21:14:01.768300+00:00 2023-11-20T21:41:05.902882+00:00 0:27:04.134582 448505 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T21:14:00.096151+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T21:13:40.088624+00:00 2023-11-20T21:13:41.243372+00:00 0:00:01.154748 448504 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T21:13:38.071326+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T11:00:00+00:00 PythonOperator 2023-11-20T20:46:22.663688+00:00 2023-11-20T20:46:24.890369+00:00 0:00:02.226681 448496 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T20:46:20.664563+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T10:00:00+00:00 EmrJobFlowSensor 2023-11-20T20:46:22.354132+00:00 2023-11-20T21:13:26.192904+00:00 0:27:03.838772 448495 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T20:46:20.664534+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T20:46:00.685685+00:00 2023-11-20T20:46:01.890583+00:00 0:00:01.204898 448494 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T20:45:58.589870+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T10:00:00+00:00 PythonOperator 2023-11-20T20:17:30.453489+00:00 2023-11-20T20:17:32.632195+00:00 0:00:02.178706 448489 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T20:17:28.526805+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T09:00:00+00:00 EmrJobFlowSensor 2023-11-20T20:17:30.198996+00:00 2023-11-20T20:45:34.522391+00:00 0:28:04.323395 448488 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T20:17:28.526775+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T20:17:08.997925+00:00 2023-11-20T20:17:10.004425+00:00 0:00:01.006500 448487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T20:17:06.504504+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T09:00:00+00:00 PythonOperator 2023-11-20T19:48:54.645281+00:00 2023-11-20T19:48:56.799382+00:00 0:00:02.154101 448479 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T19:48:52.697033+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T08:00:00+00:00 EmrJobFlowSensor 2023-11-20T19:48:54.349909+00:00 2023-11-20T20:16:58.472195+00:00 0:28:04.122286 448478 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T19:48:52.697007+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T19:48:32.780802+00:00 2023-11-20T19:48:33.939167+00:00 0:00:01.158365 448477 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T19:48:30.674498+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T08:00:00+00:00 PythonOperator 2023-11-20T19:19:14.497887+00:00 2023-11-20T19:19:16.711131+00:00 0:00:02.213244 448472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T19:19:12.391043+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T07:00:00+00:00 EmrJobFlowSensor 2023-11-20T19:19:14.152849+00:00 2023-11-20T19:48:18.607458+00:00 0:29:04.454609 448471 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T19:19:12.391002+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T19:18:52.059646+00:00 2023-11-20T19:18:53.006789+00:00 0:00:00.947143 448470 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T19:18:50.316458+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T06:00:00+00:00 EmrJobFlowSensor 2023-11-20T18:50:30.698401+00:00 2023-11-20T19:18:34.852267+00:00 0:28:04.153866 448463 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T18:50:28.404650+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T07:00:00+00:00 PythonOperator 2023-11-20T18:50:30.457752+00:00 2023-11-20T18:50:32.381075+00:00 0:00:01.923323 448462 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T18:50:28.404674+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T18:49:46.882933+00:00 2023-11-20T18:49:47.939431+00:00 0:00:01.056498 448460 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T18:49:44.744069+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T05:00:00+00:00 EmrJobFlowSensor 2023-11-20T18:21:19.187321+00:00 2023-11-20T18:49:23.512278+00:00 0:28:04.324957 448456 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T18:21:17.156509+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T06:00:00+00:00 PythonOperator 2023-11-20T18:21:18.831748+00:00 2023-11-20T18:21:20.752569+00:00 0:00:01.920821 448455 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T18:21:17.156536+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T18:20:57.069415+00:00 2023-11-20T18:20:58.158137+00:00 0:00:01.088722 448454 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T18:20:55.140795+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T05:00:00+00:00 PythonOperator 2023-11-20T17:52:04.939619+00:00 2023-11-20T17:52:07.228018+00:00 0:00:02.288399 448446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T17:52:02.872594+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T04:00:00+00:00 EmrJobFlowSensor 2023-11-20T17:52:04.531326+00:00 2023-11-20T18:20:08.844166+00:00 0:28:04.312840 448445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T17:52:02.872565+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T17:51:42.560760+00:00 2023-11-20T17:51:43.466264+00:00 0:00:00.905504 448444 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T17:51:40.798030+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T04:00:00+00:00 PythonOperator 2023-11-20T17:24:23.554993+00:00 2023-11-20T17:24:25.749715+00:00 0:00:02.194722 448439 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T17:24:21.600964+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T03:00:00+00:00 EmrJobFlowSensor 2023-11-20T17:24:23.266066+00:00 2023-11-20T17:51:27.307167+00:00 0:27:04.041101 448438 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T17:24:21.600928+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T17:24:01.690727+00:00 2023-11-20T17:24:03.101337+00:00 0:00:01.410610 448437 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T17:23:59.578250+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T03:00:00+00:00 PythonOperator 2023-11-20T16:56:37.172350+00:00 2023-11-20T16:56:39.399407+00:00 0:00:02.227057 448429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T16:56:35.098749+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T02:00:00+00:00 EmrJobFlowSensor 2023-11-20T16:56:36.864795+00:00 2023-11-20T17:23:40.885834+00:00 0:27:04.021039 448428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T16:56:35.098722+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T16:56:15.224530+00:00 2023-11-20T16:56:16.203582+00:00 0:00:00.979052 448427 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T16:56:13.079122+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T01:00:00+00:00 EmrJobFlowSensor 2023-11-20T16:30:01.185781+00:00 2023-11-20T16:56:05.745837+00:00 0:26:04.560056 448423 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T16:29:59.216775+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T02:00:00+00:00 PythonOperator 2023-11-20T16:30:00.867399+00:00 2023-11-20T16:30:02.816295+00:00 0:00:01.948896 448422 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T16:29:59.216801+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T16:29:39.583110+00:00 2023-11-20T16:29:40.543730+00:00 0:00:00.960620 448421 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T16:29:37.199590+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-20T00:00:00+00:00 EmrJobFlowSensor 2023-11-20T16:02:21.788587+00:00 2023-11-20T16:28:25.903498+00:00 0:26:04.114911 448414 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T16:02:19.658284+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T01:00:00+00:00 PythonOperator 2023-11-20T16:02:21.461522+00:00 2023-11-20T16:02:23.423364+00:00 0:00:01.961842 448413 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T16:02:19.658312+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-20T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T16:01:59.896175+00:00 2023-11-20T16:02:01.009198+00:00 0:00:01.113023 448412 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T16:01:57.585141+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-20T00:00:00+00:00 PythonOperator 2023-11-20T15:36:42.899993+00:00 2023-11-20T15:36:45.168797+00:00 0:00:02.268804 448408 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T15:36:40.877349+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T23:00:00+00:00 EmrJobFlowSensor 2023-11-20T15:36:42.531472+00:00 2023-11-20T16:01:46.433325+00:00 0:25:03.901853 448407 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T15:36:40.877322+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T15:36:20.656466+00:00 2023-11-20T15:36:21.743520+00:00 0:00:01.087054 448406 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T15:36:18.859498+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T23:00:00+00:00 PythonOperator 2023-11-20T15:11:07.204458+00:00 2023-11-20T15:11:09.384225+00:00 0:00:02.179767 448403 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T15:11:05.168567+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T22:00:00+00:00 EmrJobFlowSensor 2023-11-20T15:11:06.851786+00:00 2023-11-20T15:36:10.754846+00:00 0:25:03.903060 448402 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T15:11:05.168539+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T15:10:45.250680+00:00 2023-11-20T15:10:46.345817+00:00 0:00:01.095137 448401 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T15:10:43.086874+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T21:00:00+00:00 EmrJobFlowSensor 2023-11-20T14:48:33.957983+00:00 2023-11-20T15:10:37.504559+00:00 0:22:03.546576 448394 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T14:48:32.031433+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T22:00:00+00:00 PythonOperator 2023-11-20T14:48:33.645128+00:00 2023-11-20T14:48:35.655813+00:00 0:00:02.010685 448393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T14:48:32.031460+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T14:48:12.278447+00:00 2023-11-20T14:48:13.503018+00:00 0:00:01.224571 448392 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T14:48:10.014341+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T20:00:00+00:00 EmrJobFlowSensor 2023-11-20T14:11:37.082719+00:00 2023-11-20T14:34:40.732359+00:00 0:23:03.649640 448386 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T14:11:33.509368+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T21:00:00+00:00 PythonOperator 2023-11-20T14:11:35.164179+00:00 2023-11-20T14:11:37.135357+00:00 0:00:01.971178 448385 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T14:11:33.509393+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T14:11:13.236567+00:00 2023-11-20T14:11:14.185567+00:00 0:00:00.949000 448383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T14:11:11.487734+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T19:00:00+00:00 EmrJobFlowSensor 2023-11-20T13:46:15.042778+00:00 2023-11-20T14:08:18.504023+00:00 0:22:03.461245 448379 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T13:46:12.967924+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T20:00:00+00:00 PythonOperator 2023-11-20T13:46:14.634994+00:00 2023-11-20T13:46:16.627822+00:00 0:00:01.992828 448378 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T13:46:12.967952+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T13:45:52.697755+00:00 2023-11-20T13:45:53.666902+00:00 0:00:00.969147 448377 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T13:45:50.948800+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T18:00:00+00:00 EmrJobFlowSensor 2023-11-20T13:23:27.712089+00:00 2023-11-20T13:45:30.999736+00:00 0:22:03.287647 448374 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T13:23:25.686240+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T19:00:00+00:00 PythonOperator 2023-11-20T13:23:27.345987+00:00 2023-11-20T13:23:29.296587+00:00 0:00:01.950600 448373 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T13:23:25.686267+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T13:23:06.020902+00:00 2023-11-20T13:23:07.124534+00:00 0:00:01.103632 448372 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T13:23:03.717394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T18:00:00+00:00 PythonOperator 2023-11-20T12:55:27.913161+00:00 2023-11-20T12:55:30.200629+00:00 0:00:02.287468 448365 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T12:55:25.784006+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T17:00:00+00:00 EmrJobFlowSensor 2023-11-20T12:55:27.543499+00:00 2023-11-20T13:17:31.074158+00:00 0:22:03.530659 448364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T12:55:25.783978+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T12:55:05.584994+00:00 2023-11-20T12:55:06.592357+00:00 0:00:01.007363 448363 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T12:55:03.757899+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T16:00:00+00:00 EmrJobFlowSensor 2023-11-20T12:32:56.510061+00:00 2023-11-20T12:55:00.198169+00:00 0:22:03.688108 448359 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T12:32:54.555301+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T17:00:00+00:00 PythonOperator 2023-11-20T12:32:56.201466+00:00 2023-11-20T12:32:58.115163+00:00 0:00:01.913697 448358 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T12:32:54.555329+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T12:32:34.551657+00:00 2023-11-20T12:32:35.603627+00:00 0:00:01.051970 448357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T12:32:32.557691+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T16:00:00+00:00 PythonOperator 2023-11-20T12:07:05.438358+00:00 2023-11-20T12:07:07.743617+00:00 0:00:02.305259 448353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T12:07:03.322696+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T15:00:00+00:00 EmrJobFlowSensor 2023-11-20T12:07:04.966213+00:00 2023-11-20T12:32:08.980239+00:00 0:25:04.014026 448352 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T12:07:03.322666+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T12:06:43.293748+00:00 2023-11-20T12:06:44.332407+00:00 0:00:01.038659 448351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T12:06:41.300364+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T14:00:00+00:00 EmrJobFlowSensor 2023-11-20T11:41:31.780693+00:00 2023-11-20T12:06:35.635063+00:00 0:25:03.854370 448344 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T11:41:29.266210+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T15:00:00+00:00 PythonOperator 2023-11-20T11:41:31.451556+00:00 2023-11-20T11:41:33.377911+00:00 0:00:01.926355 448343 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T11:41:29.266243+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T11:41:05.065986+00:00 2023-11-20T11:41:06.093977+00:00 0:00:01.027991 448341 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T11:41:03.329125+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T13:00:00+00:00 EmrJobFlowSensor 2023-11-20T11:15:41.706530+00:00 2023-11-20T11:40:45.470428+00:00 0:25:03.763898 448337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T11:15:39.577793+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T14:00:00+00:00 PythonOperator 2023-11-20T11:15:41.346913+00:00 2023-11-20T11:15:43.239607+00:00 0:00:01.892694 448336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T11:15:39.577838+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T11:15:19.768921+00:00 2023-11-20T11:15:20.734659+00:00 0:00:00.965738 448335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T11:15:17.554063+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T12:00:00+00:00 EmrJobFlowSensor 2023-11-20T10:49:50.710183+00:00 2023-11-20T11:14:54.725373+00:00 0:25:04.015190 448328 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T10:49:48.685430+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T13:00:00+00:00 PythonOperator 2023-11-20T10:49:50.351929+00:00 2023-11-20T10:49:52.356791+00:00 0:00:02.004862 448327 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T10:49:48.685458+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T10:49:28.752176+00:00 2023-11-20T10:49:29.891271+00:00 0:00:01.139095 448326 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T10:49:26.667809+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T12:00:00+00:00 PythonOperator 2023-11-20T10:24:12.405900+00:00 2023-11-20T10:24:14.679456+00:00 0:00:02.273556 448315 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T10:24:10.372580+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T11:00:00+00:00 EmrJobFlowSensor 2023-11-20T10:24:12.078146+00:00 2023-11-20T10:49:15.990410+00:00 0:25:03.912264 448314 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T10:24:10.372549+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T10:23:50.379335+00:00 2023-11-20T10:23:51.437132+00:00 0:00:01.057797 448313 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T10:23:48.353883+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T10:00:00+00:00 EmrJobFlowSensor 2023-11-20T09:58:40.097554+00:00 2023-11-20T10:23:43.822352+00:00 0:25:03.724798 448306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T09:58:37.963855+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T11:00:00+00:00 PythonOperator 2023-11-20T09:58:39.644289+00:00 2023-11-20T09:58:41.551139+00:00 0:00:01.906850 448305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T09:58:37.963884+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T09:58:17.644265+00:00 2023-11-20T09:58:18.609535+00:00 0:00:00.965270 448304 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T09:58:15.854016+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T09:00:00+00:00 EmrJobFlowSensor 2023-11-20T09:33:03.008803+00:00 2023-11-20T09:58:07.139967+00:00 0:25:04.131164 448299 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T09:33:01.011615+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T10:00:00+00:00 PythonOperator 2023-11-20T09:33:02.645694+00:00 2023-11-20T09:33:04.571459+00:00 0:00:01.925765 448298 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T09:33:01.011643+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T09:32:40.763088+00:00 2023-11-20T09:32:41.807542+00:00 0:00:01.044454 448297 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T09:32:38.987031+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T09:00:00+00:00 PythonOperator 2023-11-20T09:08:31.571975+00:00 2023-11-20T09:08:33.755955+00:00 0:00:02.183980 448293 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T09:08:29.585840+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T08:00:00+00:00 EmrJobFlowSensor 2023-11-20T09:08:31.296520+00:00 2023-11-20T09:32:35.300145+00:00 0:24:04.003625 448292 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T09:08:29.585813+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T09:08:07.742099+00:00 2023-11-20T09:08:08.927808+00:00 0:00:01.185709 448291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T09:08:05.570980+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T07:00:00+00:00 EmrJobFlowSensor 2023-11-20T08:41:59.858219+00:00 2023-11-20T09:08:03.978988+00:00 0:26:04.120769 448284 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T08:41:57.907324+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T08:00:00+00:00 PythonOperator 2023-11-20T08:41:59.573902+00:00 2023-11-20T08:42:01.516712+00:00 0:00:01.942810 448283 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T08:41:57.907353+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T08:41:38.014296+00:00 2023-11-20T08:41:38.990814+00:00 0:00:00.976518 448282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T08:41:35.887615+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T07:00:00+00:00 PythonOperator 2023-11-20T08:20:02.370198+00:00 2023-11-20T08:20:04.598649+00:00 0:00:02.228451 448279 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T08:20:00.286037+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T06:00:00+00:00 EmrJobFlowSensor 2023-11-20T08:20:01.998537+00:00 448278 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T08:20:00.286007+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-19T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-20T08:19:40.282998+00:00 2023-11-20T08:19:41.298649+00:00 0:00:01.015651 448277 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-20T08:19:38.220818+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-19T05:00:00+00:00 EmrJobFlowSensor 2023-11-20T07:54:18.635075+00:00 2023-11-20T08:19:22.490750+00:00 0:25:03.855675 448271 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-20T07:54:16.679776+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-19T06:00:00+00:00 PythonOperator 2023-11-20T07:54:18.344256+00:00 2023-11-20T07:54:20.287948+00:00 0:00:01.943692 448270 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-20T07:54:16.679803+00:00 2 default_pool