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,