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_emr_steps 04-02T17:00:00+00:00 PythonOperator 04-02T18:00:07.678049+00:00 04-02T18:00:10.070164+00:00 0:00:02.392115 508227 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T18:00:05.812680+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T16:00:00+00:00 EmrJobFlowSensor 04-02T17:01:01.324577+00:00 04-02T17:30:05.602864+00:00 0:29:04.278287 508221 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T17:00:59.323957+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T16:00:00+00:00 EmrCreateJobFlowOperator 04-02T17:00:41.036717+00:00 04-02T17:00:41.961490+00:00 0:00:00.924773 508219 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T17:00:39.305967+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T16:00:00+00:00 PythonOperator 04-02T17:00:19.198735+00:00 04-02T17:00:21.152980+00:00 0:00:01.954245 508217 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T17:00:17.288394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T15:00:00+00:00 EmrJobFlowSensor 04-02T16:01:04.184596+00:00 04-02T16:27:08.117889+00:00 0:26:03.933293 508204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T16:01:02.516405+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T15:00:00+00:00 EmrCreateJobFlowOperator 04-02T16:00:42.489443+00:00 04-02T16:00:43.420811+00:00 0:00:00.931368 508202 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T16:00:40.495379+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T15:00:00+00:00 PythonOperator 04-02T16:00:20.382801+00:00 04-02T16:00:22.182018+00:00 0:00:01.799217 508200 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T16:00:18.476549+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T14:00:00+00:00 EmrJobFlowSensor 04-02T15:12:06.286756+00:00 04-02T15:26:08.832832+00:00 0:14:02.546076 508191 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T15:12:04.284292+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T14:00:00+00:00 EmrCreateJobFlowOperator 04-02T15:00:27.757944+00:00 04-02T15:00:28.902290+00:00 0:00:01.144346 508183 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T15:00:25.685841+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T14:00:00+00:00 PythonOperator 04-02T15:00:07.891434+00:00 04-02T15:00:10.809389+00:00 0:00:02.917955 508180 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T15:00:05.670861+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T13:00:00+00:00 EmrJobFlowSensor 04-02T14:00:51.332240+00:00 04-02T14:25:55.181037+00:00 0:25:03.848797 508173 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T14:00:49.327315+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T13:00:00+00:00 EmrCreateJobFlowOperator 04-02T14:00:31.029379+00:00 04-02T14:00:32.060481+00:00 0:00:01.031102 508171 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T14:00:29.309382+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T13:00:00+00:00 PythonOperator 04-02T14:00:09.327171+00:00 04-02T14:00:11.159782+00:00 0:00:01.832611 508168 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T14:00:07.291309+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T12:00:00+00:00 EmrJobFlowSensor 04-02T13:01:06.649966+00:00 04-02T13:26:10.407379+00:00 0:25:03.757413 508161 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T13:01:04.614522+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T12:00:00+00:00 EmrCreateJobFlowOperator 04-02T13:00:46.574761+00:00 04-02T13:00:47.509126+00:00 0:00:00.934365 508159 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T13:00:44.597289+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T12:00:00+00:00 PythonOperator 04-02T13:00:22.904461+00:00 04-02T13:00:24.761969+00:00 0:00:01.857508 508157 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T13:00:20.583415+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T11:00:00+00:00 EmrJobFlowSensor 04-02T12:17:04.419416+00:00 04-02T12:26:06.279620+00:00 0:09:01.860204 508153 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T12:17:02.673592+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T11:00:00+00:00 EmrCreateJobFlowOperator 04-02T12:00:31.843399+00:00 04-02T12:00:32.952802+00:00 0:00:01.109403 508146 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T12:00:29.822577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T11:00:00+00:00 PythonOperator 04-02T12:00:09.572205+00:00 04-02T12:00:11.239867+00:00 0:00:01.667662 508143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T12:00:07.809178+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T10:00:00+00:00 EmrJobFlowSensor 04-02T11:00:48.782484+00:00 04-02T11:25:52.841285+00:00 0:25:04.058801 508134 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T11:00:47.081319+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T10:00:00+00:00 EmrCreateJobFlowOperator 04-02T11:00:29.680893+00:00 04-02T11:00:30.546245+00:00 0:00:00.865352 508133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T11:00:27.064539+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T10:00:00+00:00 PythonOperator 04-02T11:00:06.747936+00:00 04-02T11:00:08.366172+00:00 0:00:01.618236 508130 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T11:00:05.043307+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T09:00:00+00:00 EmrJobFlowSensor 04-02T10:10:38.932031+00:00 04-02T10:26:41.513661+00:00 0:16:02.581630 508127 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T10:10:36.938866+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T09:00:00+00:00 EmrCreateJobFlowOperator 04-02T10:00:40.392622+00:00 04-02T10:00:41.284639+00:00 0:00:00.892017 508119 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T10:00:38.418050+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T09:00:00+00:00 PythonOperator 04-02T10:00:18.145614+00:00 04-02T10:00:20.309579+00:00 0:00:02.163965 508117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T10:00:16.399797+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T08:00:00+00:00 EmrJobFlowSensor 04-02T09:01:01.285257+00:00 04-02T09:26:05.226245+00:00 0:25:03.940988 508110 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T09:00:59.689628+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T08:00:00+00:00 EmrCreateJobFlowOperator 04-02T09:00:39.331565+00:00 04-02T09:00:40.285090+00:00 0:00:00.953525 508108 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T09:00:37.666314+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T08:00:00+00:00 PythonOperator 04-02T09:00:17.670218+00:00 04-02T09:00:19.562529+00:00 0:00:01.892311 508106 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T09:00:15.649321+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T07:00:00+00:00 EmrJobFlowSensor 04-02T08:00:50.603528+00:00 04-02T08:26:54.756897+00:00 0:26:04.153369 508096 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T08:00:48.904781+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T07:00:00+00:00 EmrCreateJobFlowOperator 04-02T08:00:30.614842+00:00 04-02T08:00:31.605097+00:00 0:00:00.990255 508094 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T08:00:28.887864+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T07:00:00+00:00 PythonOperator 04-02T08:00:09.062125+00:00 04-02T08:00:10.946546+00:00 0:00:01.884421 508092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T08:00:06.870038+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T06:00:00+00:00 EmrJobFlowSensor 04-02T07:12:19.052847+00:00 04-02T07:27:21.462684+00:00 0:15:02.409837 508089 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T07:12:17.083423+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T06:00:00+00:00 EmrCreateJobFlowOperator 04-02T07:00:41.860310+00:00 04-02T07:00:43.060670+00:00 0:00:01.200360 508082 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T07:00:38.490571+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T06:00:00+00:00 PythonOperator 04-02T07:00:21.832925+00:00 04-02T07:00:24.740910+00:00 0:00:02.907985 508080 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T07:00:18.474362+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T05:00:00+00:00 EmrJobFlowSensor 04-02T06:01:04.225624+00:00 04-02T06:27:08.132067+00:00 0:26:03.906443 508070 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T06:01:02.110463+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T05:00:00+00:00 EmrCreateJobFlowOperator 04-02T06:00:42.102630+00:00 04-02T06:00:43.045665+00:00 0:00:00.943035 508068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T06:00:40.087272+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T05:00:00+00:00 PythonOperator 04-02T06:00:20.832292+00:00 04-02T06:00:22.761776+00:00 0:00:01.929484 508067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T06:00:18.070700+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T04:00:00+00:00 EmrJobFlowSensor 04-02T05:00:58.958174+00:00 04-02T05:26:03.554304+00:00 0:25:04.596130 508057 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T05:00:55.625305+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T04:00:00+00:00 EmrCreateJobFlowOperator 04-02T05:00:37.286426+00:00 04-02T05:00:38.230882+00:00 0:00:00.944456 508055 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T05:00:35.608358+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T04:00:00+00:00 PythonOperator 04-02T05:00:15.654018+00:00 04-02T05:00:17.618680+00:00 0:00:01.964662 508053 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T05:00:13.590241+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T03:00:00+00:00 EmrJobFlowSensor 04-02T04:12:17.725710+00:00 04-02T04:27:20.262838+00:00 0:15:02.537128 508048 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T04:12:15.801581+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T03:00:00+00:00 EmrCreateJobFlowOperator 04-02T04:00:41.105725+00:00 04-02T04:00:42.001410+00:00 0:00:00.895685 508040 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T04:00:39.182252+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T03:00:00+00:00 PythonOperator 04-02T04:00:19.144705+00:00 04-02T04:00:21.039073+00:00 0:00:01.894368 508037 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T04:00:17.164346+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T02:00:00+00:00 EmrJobFlowSensor 04-02T03:01:04.276104+00:00 04-02T03:27:08.686174+00:00 0:26:04.410070 508027 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T03:01:00.951801+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T02:00:00+00:00 EmrCreateJobFlowOperator 04-02T03:00:42.965799+00:00 04-02T03:00:43.832071+00:00 0:00:00.866272 508025 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T03:00:40.932938+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T02:00:00+00:00 PythonOperator 04-02T03:00:20.937350+00:00 04-02T03:00:23.012708+00:00 0:00:02.075358 508023 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T03:00:18.914052+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T01:00:00+00:00 EmrJobFlowSensor 04-02T02:01:11.745563+00:00 04-02T02:26:16.201261+00:00 0:25:04.455698 508015 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T02:01:08.391202+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T01:00:00+00:00 EmrCreateJobFlowOperator 04-02T02:00:48.363028+00:00 04-02T02:00:49.240353+00:00 0:00:00.877325 508012 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T02:00:46.370581+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T01:00:00+00:00 PythonOperator 04-02T02:00:26.379154+00:00 04-02T02:00:28.177672+00:00 0:00:01.798518 508009 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T02:00:24.350158+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-02T00:00:00+00:00 EmrJobFlowSensor 04-02T01:13:12.097577+00:00 04-02T01:26:14.170217+00:00 0:13:02.072640 508000 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T01:13:10.065189+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-02T00:00:00+00:00 EmrCreateJobFlowOperator 04-02T01:00:31.474714+00:00 04-02T01:00:32.375799+00:00 0:00:00.901085 507992 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T01:00:29.400456+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-02T00:00:00+00:00 PythonOperator 04-02T01:00:10.907872+00:00 04-02T01:00:13.712046+00:00 0:00:02.804174 507989 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T01:00:07.390198+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T23:00:00+00:00 EmrJobFlowSensor 04-02T00:16:59.607930+00:00 04-02T00:27:01.523754+00:00 0:10:01.915824 507987 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-02T00:16:57.582457+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T23:00:00+00:00 EmrCreateJobFlowOperator 04-02T00:00:26.036340+00:00 04-02T00:00:27.280528+00:00 0:00:01.244188 507979 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-02T00:00:22.726832+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T23:00:00+00:00 PythonOperator 04-02T00:00:04.863595+00:00 04-02T00:00:06.903703+00:00 0:00:02.040108 507976 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-02T00:00:02.716819+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T22:00:00+00:00 EmrJobFlowSensor 04-01T23:12:44.366949+00:00 04-01T23:26:47.118916+00:00 0:14:02.751967 507973 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T23:12:40.350242+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T22:00:00+00:00 EmrCreateJobFlowOperator 04-01T23:00:41.704174+00:00 04-01T23:00:42.610265+00:00 0:00:00.906091 507963 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T23:00:39.721241+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T22:00:00+00:00 PythonOperator 04-01T23:00:20.086034+00:00 04-01T23:00:21.987993+00:00 0:00:01.901959 507960 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T23:00:17.702372+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T21:00:00+00:00 EmrJobFlowSensor 04-01T22:00:55.259255+00:00 04-01T22:27:59.152257+00:00 0:27:03.893002 507950 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T22:00:53.250960+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T21:00:00+00:00 EmrCreateJobFlowOperator 04-01T22:00:35.228918+00:00 04-01T22:00:36.145813+00:00 0:00:00.916895 507948 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T22:00:33.232703+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T21:00:00+00:00 PythonOperator 04-01T22:00:13.235874+00:00 04-01T22:00:15.082316+00:00 0:00:01.846442 507946 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T22:00:11.216813+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T20:00:00+00:00 EmrJobFlowSensor 04-01T21:12:36.424871+00:00 04-01T21:29:39.776675+00:00 0:17:03.351804 507943 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T21:12:33.183806+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T20:00:00+00:00 EmrCreateJobFlowOperator 04-01T21:00:46.676601+00:00 04-01T21:00:47.570096+00:00 0:00:00.893495 507933 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T21:00:44.572410+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T20:00:00+00:00 PythonOperator 04-01T21:00:24.686162+00:00 04-01T21:00:26.492799+00:00 0:00:01.806637 507930 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T21:00:22.556483+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T19:00:00+00:00 EmrJobFlowSensor 04-01T20:01:05.207450+00:00 04-01T20:34:10.708994+00:00 0:33:05.501544 507923 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T20:01:01.988725+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T19:00:00+00:00 EmrCreateJobFlowOperator 04-01T20:00:43.355407+00:00 04-01T20:00:44.544855+00:00 0:00:01.189448 507921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T20:00:39.970097+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T19:00:00+00:00 PythonOperator 04-01T20:00:22.031575+00:00 04-01T20:00:23.852909+00:00 0:00:01.821334 507919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T20:00:19.952196+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T18:00:00+00:00 EmrJobFlowSensor 04-01T19:12:50.292542+00:00 04-01T19:35:53.767098+00:00 0:23:03.474556 507915 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T19:12:48.329562+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T18:00:00+00:00 EmrCreateJobFlowOperator 04-01T19:02:15.450760+00:00 04-01T19:02:16.360084+00:00 0:00:00.909324 507909 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T19:02:13.777810+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T18:00:00+00:00 PythonOperator 04-01T19:00:09.120297+00:00 04-01T19:00:11.944523+00:00 0:00:02.824226 507903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T19:00:05.665093+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T17:00:00+00:00 EmrJobFlowSensor 04-01T18:25:52.593281+00:00 04-01T19:01:57.652684+00:00 0:36:05.059403 507901 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T18:25:50.623171+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T17:00:00+00:00 EmrCreateJobFlowOperator 04-01T18:25:30.541931+00:00 04-01T18:25:31.492591+00:00 0:00:00.950660 507900 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T18:25:28.601682+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T17:00:00+00:00 PythonOperator 04-01T18:00:24.793350+00:00 04-01T18:00:27.566575+00:00 0:00:02.773225 507892 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T18:00:21.290863+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T16:00:00+00:00 EmrJobFlowSensor 04-01T17:52:16.874984+00:00 04-01T18:25:21.565476+00:00 0:33:04.690492 507889 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T17:52:14.876057+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T16:00:00+00:00 EmrCreateJobFlowOperator 04-01T17:51:58.226160+00:00 04-01T17:51:59.438477+00:00 0:00:01.212317 507888 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T17:51:54.858754+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T16:00:00+00:00 PythonOperator 04-01T17:20:37.301759+00:00 04-01T17:20:40.163558+00:00 0:00:02.861799 507886 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T17:20:33.988272+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T15:00:00+00:00 EmrJobFlowSensor 04-01T17:20:35.949628+00:00 04-01T17:51:40.287790+00:00 0:31:04.338162 507885 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T17:20:33.988246+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T15:00:00+00:00 EmrCreateJobFlowOperator 04-01T17:20:15.939329+00:00 04-01T17:20:16.766240+00:00 0:00:00.826911 507884 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T17:20:13.970559+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T15:00:00+00:00 PythonOperator 04-01T16:00:19.824774+00:00 04-01T16:00:22.730395+00:00 0:00:02.905621 507863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T16:00:16.578938+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T14:00:00+00:00 EmrJobFlowSensor 04-01T15:24:36.647285+00:00 04-01T17:19:54.078871+00:00 1:55:17.431586 507859 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T15:24:33.331708+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T14:00:00+00:00 EmrCreateJobFlowOperator 04-01T15:23:53.297755+00:00 04-01T15:23:54.241590+00:00 0:00:00.943835 507858 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T15:23:51.294538+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T14:00:00+00:00 PythonOperator 04-01T15:23:33.206244+00:00 04-01T15:23:35.147753+00:00 0:00:01.941509 507857 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T15:23:31.276734+00:00 3 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T13:00:00+00:00 EmrJobFlowSensor 04-01T14:01:07.675336+00:00 04-01T14:27:11.528824+00:00 0:26:03.853488 507834 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T14:01:05.734121+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T13:00:00+00:00 EmrCreateJobFlowOperator 04-01T14:00:45.788493+00:00 04-01T14:00:46.749964+00:00 0:00:00.961471 507832 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T14:00:43.712121+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T13:00:00+00:00 PythonOperator 04-01T14:00:25.779826+00:00 04-01T14:00:27.704529+00:00 0:00:01.924703 507830 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T14:00:23.743993+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T12:00:00+00:00 EmrJobFlowSensor 04-01T13:16:55.242626+00:00 04-01T13:25:57.288978+00:00 0:09:02.046352 507826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T13:16:51.880044+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T12:00:00+00:00 EmrCreateJobFlowOperator 04-01T13:00:40.993928+00:00 04-01T13:00:41.932463+00:00 0:00:00.938535 507817 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T13:00:39.035797+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T12:00:00+00:00 PythonOperator 04-01T13:00:22.978429+00:00 04-01T13:00:25.842126+00:00 0:00:02.863697 507815 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T13:00:19.019405+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T11:00:00+00:00 EmrJobFlowSensor 04-01T12:12:34.420301+00:00 04-01T12:25:36.996625+00:00 0:13:02.576324 507812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T12:12:31.194119+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T11:00:00+00:00 EmrCreateJobFlowOperator 04-01T12:00:34.569914+00:00 04-01T12:00:35.445013+00:00 0:00:00.875099 507802 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T12:00:32.553155+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T11:00:00+00:00 PythonOperator 04-01T12:00:15.550890+00:00 04-01T12:00:18.677808+00:00 0:00:03.126918 507801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T12:00:10.522479+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T10:00:00+00:00 EmrJobFlowSensor 04-01T11:01:07.480587+00:00 04-01T11:26:11.833215+00:00 0:25:04.352628 507791 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T11:01:04.199805+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T10:00:00+00:00 EmrCreateJobFlowOperator 04-01T11:00:45.550374+00:00 04-01T11:00:46.758389+00:00 0:00:01.208015 507789 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T11:00:42.227271+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T10:00:00+00:00 PythonOperator 04-01T11:00:24.160761+00:00 04-01T11:00:26.941985+00:00 0:00:02.781224 507787 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T11:00:22.163848+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T09:00:00+00:00 EmrJobFlowSensor 04-01T10:00:49.789669+00:00 04-01T10:25:54.228372+00:00 0:25:04.438703 507778 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T10:00:45.673709+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T09:00:00+00:00 EmrCreateJobFlowOperator 04-01T10:00:27.994568+00:00 04-01T10:00:28.947770+00:00 0:00:00.953202 507776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T10:00:25.657133+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T09:00:00+00:00 PythonOperator 04-01T10:00:05.878621+00:00 04-01T10:00:07.716501+00:00 0:00:01.837880 507773 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T10:00:03.637429+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 04-01T08:00:00+00:00 EmrJobFlowSensor 04-01T09:12:51.239862+00:00 04-01T09:26:53.697374+00:00 0:14:02.457512 507771 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 04-01T09:12:49.240602+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 04-01T08:00:00+00:00 EmrCreateJobFlowOperator 04-01T09:00:37.343145+00:00 04-01T09:00:38.259753+00:00 0:00:00.916608 507763 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 04-01T09:00:34.608035+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 04-01T08:00:00+00:00 PythonOperator 04-01T09:00:14.880965+00:00 04-01T09:00:16.731510+00:00 0:00:01.850545 507760 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 04-01T09:00:12.587268+00:00 2 default_pool