diff --git a/python/sglang/srt/disaggregation/ascend/transfer_engine.py b/python/sglang/srt/disaggregation/ascend/transfer_engine.py index 435ab8a1d..6ba4cbecc 100644 --- a/python/sglang/srt/disaggregation/ascend/transfer_engine.py +++ b/python/sglang/srt/disaggregation/ascend/transfer_engine.py @@ -48,10 +48,12 @@ class AscendTransferEngine(MooncakeTransferEngine): else: logger.error(f"Unsupported DisaggregationMode: {disaggregation_mode}") raise ValueError(f"Unsupported DisaggregationMode: {disaggregation_mode}") - self.session_id = NetworkAddress( - self.hostname, self.engine.get_rpc_port() - ).to_host_port_str() + rpc_port = self.engine.get_rpc_port() + self.session_id = NetworkAddress(self.hostname, rpc_port).to_host_port_str() self.initialize() + if rpc_port == 0: + rpc_port = self.engine.get_rpc_port() + self.session_id = NetworkAddress(self.hostname, rpc_port).to_host_port_str() def initialize(self) -> None: from sglang.srt.distributed.parallel_state import (