diff --git a/python/sglang/srt/disaggregation/common/conn.py b/python/sglang/srt/disaggregation/common/conn.py index 8400630943da..1fcd91d9cdfc 100644 --- a/python/sglang/srt/disaggregation/common/conn.py +++ b/python/sglang/srt/disaggregation/common/conn.py @@ -608,6 +608,8 @@ def init(self, prefill_dp_rank: int): self.prefill_dp_rank = prefill_dp_rank self._setup_bootstrap_infos() + if self.conclude_state == KVPoll.Failed: + return self.kv_mgr.update_status(self.bootstrap_room, KVPoll.WaitingForInput) def _setup_bootstrap_infos(self): @@ -650,6 +652,7 @@ def _setup_bootstrap_infos(self): self.kv_mgr.update_status( self.bootstrap_room, KVPoll.Failed ) + self.bootstrap_infos = None return self.bootstrap_infos = bootstrap_infos