EngineX-Hygon/sglang
5
0
Fork 0
Code Issues Pull Requests Actions 7 Projects Releases Wiki Activity

Fix draft decode max batch size (#3676)

Browse Source
This commit is contained in:
Ke Bao
2025-02-18 23:03:26 +08:00
committed by GitHub
parent f983213a1f
commit e5ce395a6c
3 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
python/sglang/srt/layers/attention/flashinfer_backend.py
View File

@@ -1094,7 +1094,7 @@ class FlashInferMultiStepDraftBackend:
self.topk = topk self.topk = topk
self.speculative_num_steps = speculative_num_steps self.speculative_num_steps = speculative_num_steps
self.generate_draft_decode_kv_indices = generate_draft_decode_kv_indices self.generate_draft_decode_kv_indices = generate_draft_decode_kv_indices
max_bs = model_runner.req_to_token_pool.size max_bs = model_runner.req_to_token_pool.size * self.topk
self.kv_indptr = torch.zeros( self.kv_indptr = torch.zeros(
( (
self.speculative_num_steps, self.speculative_num_steps,

2
python/sglang/srt/layers/attention/triton_backend.py
View File

@@ -474,7 +474,7 @@ class TritonMultiStepDraftBackend:
self.topk = topk self.topk = topk
self.speculative_num_steps = speculative_num_steps self.speculative_num_steps = speculative_num_steps
self.generate_draft_decode_kv_indices = generate_draft_decode_kv_indices self.generate_draft_decode_kv_indices = generate_draft_decode_kv_indices
max_bs = model_runner.req_to_token_pool.size max_bs = model_runner.req_to_token_pool.size * self.topk
self.kv_indptr = torch.zeros( self.kv_indptr = torch.zeros(
( (
self.speculative_num_steps, self.speculative_num_steps,

3
python/sglang/srt/layers/attention/triton_ops/decode_attention.py
View File

@@ -635,6 +635,9 @@ def decode_attention_fwd(
logit_cap=0.0, logit_cap=0.0,
): ):
assert num_kv_splits == attn_logits.shape[2] assert num_kv_splits == attn_logits.shape[2]
assert q.shape[0] <= kv_indptr.shape[0] - 1
assert q.shape[0] <= attn_logits.shape[0]
kv_group_num = q.shape[1] // v_buffer.shape[1] kv_group_num = q.shape[1] // v_buffer.shape[1]
if kv_group_num == 1: if kv_group_num == 1: