From 43d2a276ccaf496ac0da30b950cd55254221239e Mon Sep 17 00:00:00 2001 From: gufengc Date: Fri, 17 Oct 2025 17:09:34 +0800 Subject: [PATCH] fix(scheduler): do not check heartbeat of deactive node --- src/scheduling/scheduler.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/scheduling/scheduler.py b/src/scheduling/scheduler.py index 6d143c10..2112f3c6 100644 --- a/src/scheduling/scheduler.py +++ b/src/scheduling/scheduler.py @@ -240,6 +240,8 @@ def enqueue_node_update( def checking_node_heartbeat(self) -> None: """Check the heartbeat of all nodes.""" for node in self.nodes: + if not node.is_active: + continue if time.time() - node.last_heartbeat > self.heartbeat_timeout: logger.debug(f"Node {node.node_id} heartbeat timeout") self.leave(node.node_id)