The scheduler does not appear to be running. Last heartbeat was received .

The DAGs list may not update, and new tasks will not be scheduled.

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-12-27T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T06:00:33.978811+00:00 2023-12-27T06:00:34.908106+00:00 0:00:00.929295 462644 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T06:00:31.917284+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-27T05:00:00+00:00 PythonOperator 2023-12-27T06:00:12.480563+00:00 2023-12-27T06:00:14.027052+00:00 0:00:01.546489 462642 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T06:00:09.957449+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-27T04:00:00+00:00 EmrJobFlowSensor 2023-12-27T05:01:00.963220+00:00 2023-12-27T05:26:04.932329+00:00 0:25:03.969109 462628 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-27T05:00:59.257923+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-27T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T05:00:40.167011+00:00 2023-12-27T05:00:41.124977+00:00 0:00:00.957966 462626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T05:00:37.353972+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-27T04:00:00+00:00 PythonOperator 2023-12-27T05:00:18.004484+00:00 2023-12-27T05:00:19.626662+00:00 0:00:01.622178 462624 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T05:00:15.287478+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-27T03:00:00+00:00 EmrJobFlowSensor 2023-12-27T04:01:00.486620+00:00 2023-12-27T04:26:04.620191+00:00 0:25:04.133571 462610 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-27T04:00:58.372134+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-27T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T04:00:38.588174+00:00 2023-12-27T04:00:39.587593+00:00 0:00:00.999419 462607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T04:00:36.376404+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-27T03:00:00+00:00 PythonOperator 2023-12-27T04:00:18.061947+00:00 2023-12-27T04:00:19.654228+00:00 0:00:01.592281 462603 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T04:00:16.311317+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-27T02:00:00+00:00 EmrJobFlowSensor 2023-12-27T03:00:49.184801+00:00 2023-12-27T03:25:53.212319+00:00 0:25:04.027518 462588 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-27T03:00:46.935375+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-27T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T03:00:27.789596+00:00 2023-12-27T03:00:28.691562+00:00 0:00:00.901966 462586 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T03:00:24.969939+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-27T02:00:00+00:00 PythonOperator 2023-12-27T03:00:07.466959+00:00 2023-12-27T03:00:09.084202+00:00 0:00:01.617243 462584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T03:00:04.964748+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-27T01:00:00+00:00 EmrJobFlowSensor 2023-12-27T02:00:49.883924+00:00 2023-12-27T02:25:53.719627+00:00 0:25:03.835703 462571 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-27T02:00:47.665292+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-27T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T02:00:29.903142+00:00 2023-12-27T02:00:30.793273+00:00 0:00:00.890131 462569 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T02:00:27.655805+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-27T01:00:00+00:00 PythonOperator 2023-12-27T02:00:08.181749+00:00 2023-12-27T02:00:09.840937+00:00 0:00:01.659188 462567 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T02:00:05.586440+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-27T00:00:00+00:00 EmrJobFlowSensor 2023-12-27T01:01:05.869431+00:00 2023-12-27T01:27:10.257826+00:00 0:26:04.388395 462547 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-27T01:01:03.694199+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-27T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T01:00:44.106750+00:00 2023-12-27T01:00:45.456214+00:00 0:00:01.349464 462545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T01:00:41.690539+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-27T00:00:00+00:00 PythonOperator 2023-12-27T01:00:21.865694+00:00 2023-12-27T01:00:23.471178+00:00 0:00:01.605484 462543 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T01:00:19.684467+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T23:00:00+00:00 EmrJobFlowSensor 2023-12-27T00:00:51.462337+00:00 2023-12-27T00:25:55.661275+00:00 0:25:04.198938 462529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-27T00:00:49.442070+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-27T00:00:29.094332+00:00 2023-12-27T00:00:30.179877+00:00 0:00:01.085545 462527 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-27T00:00:27.422677+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T23:00:00+00:00 PythonOperator 2023-12-27T00:00:07.146042+00:00 2023-12-27T00:00:08.820993+00:00 0:00:01.674951 462525 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-27T00:00:05.401487+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T22:00:00+00:00 EmrJobFlowSensor 2023-12-26T23:12:39.387202+00:00 2023-12-26T23:25:41.584294+00:00 0:13:02.197092 462515 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T23:12:37.728852+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T23:00:34.781612+00:00 2023-12-26T23:00:35.977203+00:00 0:00:01.195591 462504 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T23:00:32.664391+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T22:00:00+00:00 PythonOperator 2023-12-26T23:00:12.872816+00:00 2023-12-26T23:00:15.211570+00:00 0:00:02.338754 462501 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T23:00:10.752484+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T21:00:00+00:00 EmrJobFlowSensor 2023-12-26T22:00:49.169188+00:00 2023-12-26T22:23:53.142311+00:00 0:23:03.973123 462487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T22:00:47.118112+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T22:00:26.963307+00:00 2023-12-26T22:00:27.970115+00:00 0:00:01.006808 462485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T22:00:25.159265+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T21:00:00+00:00 PythonOperator 2023-12-26T22:00:07.684911+00:00 2023-12-26T22:00:09.275439+00:00 0:00:01.590528 462483 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T22:00:05.091186+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T20:00:00+00:00 EmrJobFlowSensor 2023-12-26T21:01:07.466334+00:00 2023-12-26T21:26:11.671373+00:00 0:25:04.205039 462470 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T21:01:05.425768+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T21:00:45.097298+00:00 2023-12-26T21:00:46.105566+00:00 0:00:01.008268 462468 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T21:00:43.405718+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T20:00:00+00:00 PythonOperator 2023-12-26T21:00:23.158415+00:00 2023-12-26T21:00:24.724992+00:00 0:00:01.566577 462466 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T21:00:21.388341+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T19:00:00+00:00 EmrJobFlowSensor 2023-12-26T20:01:00.350292+00:00 2023-12-26T20:28:04.733009+00:00 0:27:04.382717 462451 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T20:00:58.639421+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T20:00:38.836727+00:00 2023-12-26T20:00:39.761461+00:00 0:00:00.924734 462449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T20:00:36.676550+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T19:00:00+00:00 PythonOperator 2023-12-26T20:00:17.243299+00:00 2023-12-26T20:00:18.868494+00:00 0:00:01.625195 462447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T20:00:14.661693+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T18:00:00+00:00 EmrJobFlowSensor 2023-12-26T19:00:55.341774+00:00 2023-12-26T19:26:59.616548+00:00 0:26:04.274774 462431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T19:00:53.146152+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T19:00:33.376923+00:00 2023-12-26T19:00:34.515773+00:00 0:00:01.138850 462429 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T19:00:31.177355+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T18:00:00+00:00 PythonOperator 2023-12-26T19:00:13.663483+00:00 2023-12-26T19:00:15.332542+00:00 0:00:01.669059 462427 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T19:00:11.159219+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T17:00:00+00:00 EmrJobFlowSensor 2023-12-26T18:07:24.551935+00:00 2023-12-26T18:33:28.312126+00:00 0:26:03.760191 462416 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T18:07:22.753439+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T18:07:02.355894+00:00 2023-12-26T18:07:03.786059+00:00 0:00:01.430165 462413 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T18:07:00.703461+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T17:00:00+00:00 PythonOperator 2023-12-26T18:06:42.398222+00:00 2023-12-26T18:06:44.015698+00:00 0:00:01.617476 462410 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T18:06:40.689210+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T16:00:00+00:00 EmrJobFlowSensor 2023-12-26T17:02:01.838767+00:00 2023-12-26T17:25:05.644404+00:00 0:23:03.805637 462396 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T17:01:59.676568+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T17:01:41.775388+00:00 2023-12-26T17:01:42.704819+00:00 0:00:00.929431 462394 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T17:01:39.612708+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T16:00:00+00:00 PythonOperator 2023-12-26T17:01:19.495204+00:00 2023-12-26T17:01:21.142739+00:00 0:00:01.647535 462391 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T17:01:17.591935+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T15:00:00+00:00 EmrJobFlowSensor 2023-12-26T16:02:13.567812+00:00 2023-12-26T16:27:17.621694+00:00 0:25:04.053882 462378 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T16:02:11.384891+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T16:01:51.066185+00:00 2023-12-26T16:01:52.236842+00:00 0:00:01.170657 462375 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T16:01:49.355706+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T15:00:00+00:00 PythonOperator 2023-12-26T16:01:31.280157+00:00 2023-12-26T16:01:32.843491+00:00 0:00:01.563334 462373 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T16:01:29.338968+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T14:00:00+00:00 EmrJobFlowSensor 2023-12-26T15:00:53.995510+00:00 2023-12-26T15:26:58.123724+00:00 0:26:04.128214 462360 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T15:00:51.904577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T15:00:32.003079+00:00 2023-12-26T15:00:33.038313+00:00 0:00:01.035234 462358 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T15:00:29.886997+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T14:00:00+00:00 PythonOperator 2023-12-26T15:00:12.059786+00:00 2023-12-26T15:00:13.654309+00:00 0:00:01.594523 462356 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T15:00:09.840759+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T13:00:00+00:00 EmrJobFlowSensor 2023-12-26T14:00:48.055901+00:00 2023-12-26T14:25:51.939833+00:00 0:25:03.883932 462346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T14:00:46.134488+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T14:00:26.070025+00:00 2023-12-26T14:00:27.079942+00:00 0:00:01.009917 462344 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T14:00:24.184516+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T13:00:00+00:00 PythonOperator 2023-12-26T14:00:06.115433+00:00 2023-12-26T14:00:07.729738+00:00 0:00:01.614305 462342 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T14:00:04.155228+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T12:00:00+00:00 EmrJobFlowSensor 2023-12-26T13:07:25.101580+00:00 2023-12-26T13:32:28.994470+00:00 0:25:03.892890 462331 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T13:07:23.016940+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T13:07:02.649322+00:00 2023-12-26T13:07:03.931368+00:00 0:00:01.282046 462328 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T13:07:00.993142+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T12:00:00+00:00 PythonOperator 2023-12-26T13:06:43.493736+00:00 2023-12-26T13:06:45.203873+00:00 0:00:01.710137 462325 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T13:06:41.040310+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T11:00:00+00:00 EmrJobFlowSensor 2023-12-26T12:01:49.640065+00:00 2023-12-26T12:25:53.616286+00:00 0:24:03.976221 462313 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T12:01:48.014762+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T12:00:29.969310+00:00 2023-12-26T12:00:30.985304+00:00 0:00:01.015994 462309 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T12:00:28.317117+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T11:00:00+00:00 PythonOperator 2023-12-26T12:00:08.761611+00:00 2023-12-26T12:00:10.364388+00:00 0:00:01.602777 462307 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T12:00:06.358468+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T10:00:00+00:00 EmrJobFlowSensor 2023-12-26T11:02:04.966873+00:00 2023-12-26T11:26:08.689880+00:00 0:24:03.723007 462295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T11:02:02.885969+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T11:00:45.133959+00:00 2023-12-26T11:00:46.113771+00:00 0:00:00.979812 462292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T11:00:42.884026+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T10:00:00+00:00 PythonOperator 2023-12-26T11:00:22.971414+00:00 2023-12-26T11:00:24.558525+00:00 0:00:01.587111 462290 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T11:00:20.863255+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T09:00:00+00:00 EmrJobFlowSensor 2023-12-26T10:12:00.121779+00:00 2023-12-26T10:37:04.423880+00:00 0:25:04.302101 462281 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T10:11:57.889577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T10:11:39.773967+00:00 2023-12-26T10:11:40.816940+00:00 0:00:01.042973 462278 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T10:11:37.855235+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T09:00:00+00:00 PythonOperator 2023-12-26T10:11:18.001115+00:00 2023-12-26T10:11:19.598400+00:00 0:00:01.597285 462274 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T10:11:15.844554+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T08:00:00+00:00 EmrJobFlowSensor 2023-12-26T09:00:48.023477+00:00 2023-12-26T09:26:52.062030+00:00 0:26:04.038553 462262 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T09:00:45.052854+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T09:00:26.758972+00:00 2023-12-26T09:00:27.806437+00:00 0:00:01.047465 462260 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T09:00:24.969868+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T08:00:00+00:00 PythonOperator 2023-12-26T09:00:04.784011+00:00 2023-12-26T09:00:06.352278+00:00 0:00:01.568267 462258 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T09:00:02.886261+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T07:00:00+00:00 EmrJobFlowSensor 2023-12-26T08:02:05.176548+00:00 2023-12-26T08:27:09.245359+00:00 0:25:04.068811 462248 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T08:02:03.461256+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T08:00:25.472123+00:00 2023-12-26T08:00:26.501640+00:00 0:00:01.029517 462244 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T08:00:22.995010+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T07:00:00+00:00 PythonOperator 2023-12-26T08:00:03.089324+00:00 2023-12-26T08:00:04.688371+00:00 0:00:01.599047 462242 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T08:00:00.990066+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T06:00:00+00:00 EmrJobFlowSensor 2023-12-26T07:00:45.176895+00:00 2023-12-26T07:26:49.538952+00:00 0:26:04.362057 462228 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T07:00:43.391885+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T07:00:25.507153+00:00 2023-12-26T07:00:26.440788+00:00 0:00:00.933635 462226 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T07:00:23.370480+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T06:00:00+00:00 PythonOperator 2023-12-26T07:00:03.706186+00:00 2023-12-26T07:00:05.270604+00:00 0:00:01.564418 462224 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T07:00:01.297491+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T05:00:00+00:00 EmrJobFlowSensor 2023-12-26T06:00:50.744992+00:00 2023-12-26T06:26:54.527955+00:00 0:26:03.782963 462211 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T06:00:48.976380+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T06:00:29.064984+00:00 2023-12-26T06:00:30.205221+00:00 0:00:01.140237 462209 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T06:00:26.969435+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T05:00:00+00:00 PythonOperator 2023-12-26T06:00:09.151921+00:00 2023-12-26T06:00:10.776525+00:00 0:00:01.624604 462207 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T06:00:06.896088+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T04:00:00+00:00 EmrJobFlowSensor 2023-12-26T05:01:06.269325+00:00 2023-12-26T05:26:10.017874+00:00 0:25:03.748549 462194 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T05:01:04.623900+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T05:00:45.640042+00:00 2023-12-26T05:00:46.728055+00:00 0:00:01.088013 462192 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T05:00:42.663124+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T04:00:00+00:00 PythonOperator 2023-12-26T05:00:23.375949+00:00 2023-12-26T05:00:25.052998+00:00 0:00:01.677049 462190 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T05:00:20.652433+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T03:00:00+00:00 EmrJobFlowSensor 2023-12-26T04:14:04.884151+00:00 2023-12-26T04:27:07.362298+00:00 0:13:02.478147 462183 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T04:14:03.059652+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T04:00:39.346707+00:00 2023-12-26T04:00:40.337447+00:00 0:00:00.990740 462172 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T04:00:37.643442+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T03:00:00+00:00 PythonOperator 2023-12-26T04:00:17.289583+00:00 2023-12-26T04:00:18.943201+00:00 0:00:01.653618 462168 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T04:00:15.626479+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T02:00:00+00:00 EmrJobFlowSensor 2023-12-26T03:01:39.053777+00:00 2023-12-26T03:26:42.755002+00:00 0:25:03.701225 462155 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T03:01:36.920267+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T03:00:32.477646+00:00 2023-12-26T03:00:33.374046+00:00 0:00:00.896400 462152 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T03:00:30.357421+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T02:00:00+00:00 PythonOperator 2023-12-26T03:00:10.595568+00:00 2023-12-26T03:00:12.213320+00:00 0:00:01.617752 462149 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T03:00:08.340058+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T01:00:00+00:00 EmrJobFlowSensor 2023-12-26T02:13:45.690434+00:00 2023-12-26T02:26:48.122170+00:00 0:13:02.431736 462142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T02:13:43.511174+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T02:00:44.820713+00:00 2023-12-26T02:00:45.867560+00:00 0:00:01.046847 462133 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T02:00:42.558310+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T01:00:00+00:00 PythonOperator 2023-12-26T02:00:22.673646+00:00 2023-12-26T02:00:24.470416+00:00 0:00:01.796770 462131 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T02:00:20.543657+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-26T00:00:00+00:00 EmrJobFlowSensor 2023-12-26T01:00:49.579683+00:00 2023-12-26T01:26:53.511037+00:00 0:26:03.931354 462111 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T01:00:47.427540+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-26T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T01:00:27.516064+00:00 2023-12-26T01:00:28.388228+00:00 0:00:00.872164 462109 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T01:00:25.408104+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-26T00:00:00+00:00 PythonOperator 2023-12-26T01:00:05.604084+00:00 2023-12-26T01:00:07.269429+00:00 0:00:01.665345 462107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T01:00:03.455913+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T23:00:00+00:00 EmrJobFlowSensor 2023-12-26T00:01:02.394573+00:00 2023-12-26T00:27:06.415431+00:00 0:26:04.020858 462094 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-26T00:01:00.295575+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-26T00:00:40.286379+00:00 2023-12-26T00:00:41.339378+00:00 0:00:01.052999 462092 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-26T00:00:38.229950+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T23:00:00+00:00 PythonOperator 2023-12-26T00:00:20.254778+00:00 2023-12-26T00:00:21.827240+00:00 0:00:01.572462 462090 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-26T00:00:18.213524+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T22:00:00+00:00 EmrJobFlowSensor 2023-12-25T23:00:58.698933+00:00 2023-12-25T23:26:02.786768+00:00 0:25:04.087835 462074 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T23:00:56.483208+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T23:00:38.479169+00:00 2023-12-25T23:00:39.361086+00:00 0:00:00.881917 462071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T23:00:36.427037+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T22:00:00+00:00 PythonOperator 2023-12-25T23:00:16.587773+00:00 2023-12-25T23:00:18.131036+00:00 0:00:01.543263 462068 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T23:00:14.408408+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T21:00:00+00:00 EmrJobFlowSensor 2023-12-25T22:00:59.047557+00:00 2023-12-25T22:24:03.116536+00:00 0:23:04.068979 462054 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T22:00:56.959242+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T22:00:36.552435+00:00 2023-12-25T22:00:37.603916+00:00 0:00:01.051481 462052 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T22:00:34.854518+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T21:00:00+00:00 PythonOperator 2023-12-25T22:00:16.696300+00:00 2023-12-25T22:00:18.280834+00:00 0:00:01.584534 462050 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T22:00:14.840861+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T20:00:00+00:00 EmrJobFlowSensor 2023-12-25T21:01:05.491369+00:00 2023-12-25T21:27:09.800390+00:00 0:26:04.309021 462037 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T21:01:03.287277+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T21:00:45.379332+00:00 2023-12-25T21:00:46.531292+00:00 0:00:01.151960 462035 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T21:00:43.244551+00:00 2 default_pool