From 5323672bc2b448e94ba027b16d99c93aba9c72a4 Mon Sep 17 00:00:00 2001 From: youkaichao Date: Sat, 28 Feb 2026 08:42:37 +0800 Subject: [PATCH] [misc] cleanup one level of error stack when nixl fails to initialize (#35517) Signed-off-by: youkaichao --- vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py b/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py index b3f2ae703..87091d650 100644 --- a/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py +++ b/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py @@ -2506,6 +2506,9 @@ class NixlConnectorWorker: def shutdown(self): """Shutdown the connector worker.""" + if not hasattr(self, "_handshake_initiation_executor"): + # error happens during init, no need to shutdown + return self._handshake_initiation_executor.shutdown(wait=False) for handles in self._recving_transfers.values(): for handle in handles: