From d1f5a0f1c808de8f709f071aba980877124da1f3 Mon Sep 17 00:00:00 2001 From: gufengc Date: Thu, 13 Nov 2025 15:52:04 +0800 Subject: [PATCH] fix(scheduler): ignore node update if it is not in node list --- src/scheduling/scheduler.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/scheduling/scheduler.py b/src/scheduling/scheduler.py index c6d0b081..a2335fb4 100644 --- a/src/scheduling/scheduler.py +++ b/src/scheduling/scheduler.py @@ -509,6 +509,9 @@ def _process_node_updates(self) -> None: node_id, cur, lat, rtts, is_active = self._pending_node_updates.get_nowait() except queue.Empty: break + if node_id not in self.node_id_to_node: + logger.warning(f"Node {node_id} not found in node list, ignore the update") + continue self.update_node_info( self.node_id_to_node[node_id], current_requests=cur,