diff --git a/vllm/v1/engine/utils.py b/vllm/v1/engine/utils.py index 00943046d605a..81f746c53fa67 100644 --- a/vllm/v1/engine/utils.py +++ b/vllm/v1/engine/utils.py @@ -603,7 +603,8 @@ def launch_core_engines( engines_to_handshake = [CoreEngine(index=dp_rank, local=True)] elif dp_rank == 0: # Rank 0 holds Coordinator, so it handshakes will all Cores, - # in addition to those that it is managing. + # including in external DPLB mode where it is not managing + # the remote EngineCore. engines_to_handshake = [ CoreEngine(index=i, local=(i < local_engine_count)) for i in range(dp_size)