From c5e3c40877c2b6d0e16d534641b39fe6744979b7 Mon Sep 17 00:00:00 2001 From: Robert Shaw <114415538+robertgshaw2-redhat@users.noreply.github.com> Date: Thu, 25 Jun 2026 16:13:08 -0400 Subject: [PATCH] Fix P/D with DP Supervisor (#46628) Signed-off-by: Robert Shaw <114415538+robertgshaw2-redhat@users.noreply.github.com> --- vllm/v1/engine/core.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/vllm/v1/engine/core.py b/vllm/v1/engine/core.py index 57a788631c..f97f697ded 100644 --- a/vllm/v1/engine/core.py +++ b/vllm/v1/engine/core.py @@ -1175,10 +1175,10 @@ class EngineCoreProc(EngineCore): numa_utils.log_current_affinity_state(process_title) if data_parallel and vllm_config.kv_transfer_config is not None: - # modify the engine_id and append the local_dp_rank to it to ensure + # modify the engine_id and append the dp_rank to it to ensure # that the kv_transfer_config is unique for each DP rank. vllm_config.kv_transfer_config.engine_id = ( - f"{vllm_config.kv_transfer_config.engine_id}_dp{local_dp_rank}" + f"{vllm_config.kv_transfer_config.engine_id}_dp{dp_rank}" ) logger.debug( "Setting kv_transfer_config.engine_id to %s",