diff --git a/python/sglang/srt/disaggregation/common/conn.py b/python/sglang/srt/disaggregation/common/conn.py index 840063094..1fcd91d9c 100644 --- a/python/sglang/srt/disaggregation/common/conn.py +++ b/python/sglang/srt/disaggregation/common/conn.py @@ -608,6 +608,8 @@ class CommonKVReceiver(BaseKVReceiver): 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 @@ class CommonKVReceiver(BaseKVReceiver): self.kv_mgr.update_status( self.bootstrap_room, KVPoll.Failed ) + self.bootstrap_infos = None return self.bootstrap_infos = bootstrap_infos