xinyun/vllm
1
0
Fork 0
mirror of https://git.datalinker.icu/vllm-project/vllm.git synced 2026-06-06 22:09:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

format

Browse Source 
Signed-off-by: inkcherry <mingzhi.liu@amd.com>
This commit is contained in:
inkcherry 2025-11-24 09:02:04 +00:00
parent 63e6cff196
commit 7d3a93f1e7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
vllm/distributed/kv_transfer/kv_connector/v1/moriio_connector.py
View File

@ -1603,12 +1603,13 @@ class MoRIIOConnectorWorker:
"Max retries (%s) exceeded. Stopping ping loop.", "Max retries (%s) exceeded. Stopping ping loop.",
MoRIIOConstants.MAX_PING_RETRIES, MoRIIOConstants.MAX_PING_RETRIES,
) )
raise RuntimeError(f"Ping failed after {retry_count} retries") raise RuntimeError(
f"Ping failed after {retry_count} retries"
) from e
finally: finally:
time.sleep(MoRIIOConstants.PING_INTERVAL) time.sleep(MoRIIOConstants.PING_INTERVAL)
index += 1 index += 1
def close(self): def close(self):
if hasattr(self, "_handshake_initiation_executor"): if hasattr(self, "_handshake_initiation_executor"):
@ -2262,7 +2263,6 @@ class MoRIIOConnectorWorker:
offs[2], offs[0], offs[1], sessions[sess_idx] offs[2], offs[0], offs[1], sessions[sess_idx]
) )
with self.moriio_wrapper.lock: with self.moriio_wrapper.lock:
self._recving_transfers[request_id].append(transfer_status) self._recving_transfers[request_id].append(transfer_status)
self._recving_transfers_callback_addr[request_id] = ( self._recving_transfers_callback_addr[request_id] = (
remote_host, remote_host,