fix(disaggregation): check_status not found case crackdown

This commit is contained in:
laoyao0822
2026-03-25 21:21:39 +08:00
committed by wxiwnd
parent ef607c35c9
commit 6efa9b4350

View File

@@ -175,7 +175,11 @@ class CommonKVManager(BaseKVManager):
)
def check_status(self, bootstrap_room: int) -> KVPoll:
return self.request_status[bootstrap_room]
# return self.request_status[bootstrap_room]
if bootstrap_room is None:
return KVPoll.Failed
kvpoll = self.request_status.get(bootstrap_room, KVPoll.Failed)
return kvpoll
def update_status(self, bootstrap_room: int, status: KVPoll):
if bootstrap_room not in self.request_status: