Skip to content

Commit e1dda1d

Browse files
authored
fix(scheduler): ignore node update if it is not in node list (#232)
1 parent 9264392 commit e1dda1d

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/scheduling/scheduler.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -554,6 +554,9 @@ def _process_node_updates(self) -> None:
554554
node_id, cur, lat, rtts, is_active = self._pending_node_updates.get_nowait()
555555
except queue.Empty:
556556
break
557+
if node_id not in self.node_id_to_node:
558+
logger.warning(f"Node {node_id} not found in node list, ignore the update")
559+
continue
557560
self.update_node_info(
558561
self.node_id_to_node[node_id],
559562
current_requests=cur,

0 commit comments

Comments
 (0)