Skip to content

Commit 438a6dd

Browse files
committed
enable GPUDirect support for intel xpu on Dynamo
Signed-off-by: Spycsh <sihan.chen@intel.com>
1 parent ec04692 commit 438a6dd

2 files changed

Lines changed: 71 additions & 1 deletion

File tree

components/src/dynamo/vllm/multimodal_utils/chat_processor.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,11 @@
2222
from vllm.entrypoints.chat_utils import ConversationMessage
2323
from vllm.inputs.data import TokensPrompt
2424
from vllm.sampling_params import SamplingParams
25-
from vllm.tokenizers import TokenizerLike as AnyTokenizer
25+
26+
try:
27+
from vllm.tokenizers import TokenizerLike as AnyTokenizer
28+
except ImportError:
29+
from vllm.transformers_utils.tokenizer import AnyTokenizer
2630

2731
# Try importing from new vLLM (https://github.com/vllm-project/vllm/pull/32369), fallback to old structure
2832
try:
Lines changed: 66 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,66 @@
1+
2+
#!/bin/bash
3+
# SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
4+
# SPDX-License-Identifier: Apache-2.0
5+
set -e
6+
trap 'echo Cleaning up...; kill 0' EXIT
7+
8+
# Set deterministic hash for KV event IDs
9+
export PYTHONHASHSEED=0
10+
11+
# Common configuration
12+
MODEL="Qwen/Qwen3-0.6B"
13+
BLOCK_SIZE=64
14+
VLLM_NIXL_DEVICE_TO_DEVICE=true
15+
NIXL_BUFFER_DEVICE=xpu
16+
VLLM_NIXL_BACKEND=UCX
17+
export UCX_MEMTYPE_CACHE=0
18+
export UCX_NET_DEVICES=mlx5_0:1,mlx5_1:1,mlx5_2:1,mlx5_3:1
19+
export UCX_TLS=ib,rc,ze_copy
20+
21+
22+
# Start frontend with KV routing
23+
# The frontend will automatically detect prefill workers and activate an internal prefill router
24+
# edit --router-mode to random / round-robin / kv
25+
python -m dynamo.frontend \
26+
--router-mode kv \
27+
--http-port 8000 \
28+
--router-reset-states &
29+
30+
# two decode workers
31+
VLLM_NIXL_SIDE_CHANNEL_PORT=20096 \
32+
ZE_AFFINITY_MASK=0 python3 -m dynamo.vllm \
33+
--model $MODEL \
34+
--block-size $BLOCK_SIZE \
35+
--kv-transfer-config "{\"kv_connector\": \"NixlConnector\", \"kv_role\": \"kv_both\", \"kv_buffer_device\": \"${NIXL_BUFFER_DEVICE}\", \"kv_connector_extra_config\": {\"backends\": [\"${VLLM_NIXL_BACKEND}\"]}}" \
36+
--connector none \
37+
--kv-events-config '{"publisher":"zmq","topic":"kv-events","endpoint":"tcp://*:5556", "enable_kv_cache_events":true}' &
38+
39+
VLLM_NIXL_SIDE_CHANNEL_PORT=20097 \
40+
ZE_AFFINITY_MASK=1 python3 -m dynamo.vllm \
41+
--model $MODEL \
42+
--block-size $BLOCK_SIZE \
43+
--kv-transfer-config "{\"kv_connector\": \"NixlConnector\", \"kv_role\": \"kv_both\", \"kv_buffer_device\": \"${NIXL_BUFFER_DEVICE}\", \"kv_connector_extra_config\": {\"backends\": [\"${VLLM_NIXL_BACKEND}\"]}}" \
44+
--connector none \
45+
--kv-events-config '{"publisher":"zmq","topic":"kv-events","endpoint":"tcp://*:5557", "enable_kv_cache_events":true}' &
46+
47+
# two prefill workers
48+
# When registered with --is-prefill-worker, these workers are automatically detected
49+
# by the frontend, which activates an internal prefill router for KV-aware prefill routing
50+
VLLM_NIXL_SIDE_CHANNEL_PORT=20098 \
51+
ZE_AFFINITY_MASK=2 python3 -m dynamo.vllm \
52+
--model $MODEL \
53+
--block-size $BLOCK_SIZE \
54+
--kv-transfer-config "{\"kv_connector\": \"NixlConnector\", \"kv_role\": \"kv_both\", \"kv_buffer_device\": \"${NIXL_BUFFER_DEVICE}\", \"kv_connector_extra_config\": {\"backends\": [\"${VLLM_NIXL_BACKEND}\"]}}" \
55+
--connector none \
56+
--is-prefill-worker \
57+
--kv-events-config '{"publisher":"zmq","topic":"kv-events","endpoint":"tcp://*:5558", "enable_kv_cache_events":true}' &
58+
59+
VLLM_NIXL_SIDE_CHANNEL_PORT=20099 \
60+
ZE_AFFINITY_MASK=3 python3 -m dynamo.vllm \
61+
--model $MODEL \
62+
--block-size $BLOCK_SIZE \
63+
--kv-transfer-config "{\"kv_connector\": \"NixlConnector\", \"kv_role\": \"kv_both\", \"kv_buffer_device\": \"${NIXL_BUFFER_DEVICE}\", \"kv_connector_extra_config\": {\"backends\": [\"${VLLM_NIXL_BACKEND}\"]}}" \
64+
--connector none \
65+
--is-prefill-worker \
66+
--kv-events-config '{"publisher":"zmq","topic":"kv-events","endpoint":"tcp://*:5559", "enable_kv_cache_events":true}'

0 commit comments

Comments
 (0)