|
@@ -786,6 +786,7 @@ class AgentStateService:
|
|
|
for k, v in members.items():
|
|
|
sec = datetime.now().timestamp() - float(v)
|
|
|
if sec > self.agent_heartbeat_expire:
|
|
|
+ self.redis_handler.redis.hdel(key, k)
|
|
|
self.logger.error("agent heartbeat expired, %s %s", k, v)
|
|
|
self.busy(SAAS_ID, k, k)
|
|
|
|