Adjusted heartbeat format (#3459)
Browse files### What problem does this PR solve?
Adjusted heartbeat format
### Type of change
- [x] Refactoring
- api/apps/system_app.py +2 -0
api/apps/system_app.py
CHANGED
@@ -15,6 +15,7 @@
|
|
15 |
#
|
16 |
import logging
|
17 |
from datetime import datetime
|
|
|
18 |
|
19 |
from flask_login import login_required, current_user
|
20 |
|
@@ -160,6 +161,7 @@ def status():
|
|
160 |
now = datetime.now().timestamp()
|
161 |
for task_executor_id in task_executors:
|
162 |
heartbeats = REDIS_CONN.zrangebyscore(task_executor_id, now - 60*30, now)
|
|
|
163 |
task_executor_heartbeats[task_executor_id] = heartbeats
|
164 |
except Exception:
|
165 |
logging.exception("get task executor heartbeats failed!")
|
|
|
15 |
#
|
16 |
import logging
|
17 |
from datetime import datetime
|
18 |
+
import json
|
19 |
|
20 |
from flask_login import login_required, current_user
|
21 |
|
|
|
161 |
now = datetime.now().timestamp()
|
162 |
for task_executor_id in task_executors:
|
163 |
heartbeats = REDIS_CONN.zrangebyscore(task_executor_id, now - 60*30, now)
|
164 |
+
heartbeats = [json.loads(heartbeat) for heartbeat in heartbeats]
|
165 |
task_executor_heartbeats[task_executor_id] = heartbeats
|
166 |
except Exception:
|
167 |
logging.exception("get task executor heartbeats failed!")
|