执行摘要

• 一句话：修复 P/D 服务中投机解码请求因缺少本地运行任务而无法正确填充形状的问题。
• 推荐动作：本 PR 是一个目标明确、效果显著的 bug 修复。其解决方案优雅（仅修改一个逻辑条件），通过详实的性能数据证明了其价值，并附带了针对性的回归测试。对于关注 P/D 服务、投机解码性能或调度器稳定性的工程师来说，这是一个值得精读的案例，它清晰地展示了调度逻辑中的一个细微条件如何对系统整体性能产生巨大影响。建议技术管理者将此作为改进 DP 集群效率的一个参考。

功能与动机

在 P/D 服务场景下，当一个数据并行 rank 通过同步 KV 连接器解析了等待的请求时，该请求在调度循环中被视为恢复请求（num_computed_tokens 已更新但 request.num_computed_tokens 尚未）。现有的投机解码填充条件要求 scheduled_running_reqs 为真，导致没有运行任务的 rank 只能调度单个 token（qlen=1）。这与其他运行了 1 + num_spec_tokens 形状的 rank 不一致，破坏了该调度步骤下整个 DP 组使用完整解码 CUDA 图的能力，从而导致了严重的尾部延迟（P99 ITL 飙升）。

实现拆解

1. 核心调度逻辑调整：在 vllm/v1/core/sched/scheduler.py 的 schedule() 方法中，修改了投机解码请求形状填充的条件判断。将原有的 (scheduled_running_reqs and not prefill_scheduled) 调整为 not prefill_scheduled and (scheduled_running_reqs or num_computed_tokens > 0)。这一改变将“有正在运行请求”和“请求本身已计算过 token（恢复请求）”作为两个等效的触发条件，确保同步恢复的请求即使没有同 rank 上的先例也能被正确填充。
2. 新增回归测试：在 tests/v1/core/test_scheduler.py 中，新增测试函数 test_spec_decode_padding_resumed_request_without_running_requests。该测试模拟了一个同步 KV 连接器（mock_kv 匹配 32 个 token）场景，验证只有一个恢复请求且没有其他运行任务时，调度器是否能正确输出填充后的 token 数和占位符草稿 token。
3. 验证与兼容性：变更仅调整了一个逻辑条件，不影响普通预填充、扩散投机解码或异步 KV 加载的现有行为。作者通过在大规模（16 DP rank）和复杂配置（EAGLE3, MoE, FlashInfer）下的性能压测验证了其有效性和稳定性，无精度损失。

关键文件：

• vllm/v1/core/sched/scheduler.py（模块 调度器；类别 source；类型 core-logic）: 核心调度器，本次 bug 修复的逻辑变更点，直接决定了投机解码请求的填充条件。
• tests/v1/core/test_scheduler.py（模块 调度器测试；类别 test；类型 test-coverage；符号 test_spec_decode_padding_resumed_request_without_running_requests）: 测试文件，新增的回归测试直接验证了本次修复的场景，是理解变更意图和确保正确性的关键证据。

关键符号：schedule

关键源码片段

tests/v1/core/test_scheduler.py

测试文件，新增的回归测试直接验证了本次修复的场景，是理解变更意图和确保正确性的关键证据。

def test_spec_decode_padding_resumed_request_without_running_requests():
    """Pad a synchronously resumed request even without local running work."""
    num_spec = 3
    # 创建启用投机解码和同步 mock KV 连接器的调度器。
    # mock_kv(matched_tokens=32) 模拟了 32 个 token 被 KV 连接器同步匹配的场景。
    scheduler = create_scheduler(
        num_speculative_tokens=num_spec,
        use_kv_connector=mock_kv(matched_tokens=32, is_async=False),
    )
    # 创建一个 33 token 的请求，其中前 32 个 token 会被 mock_kv 匹配。
    (resumed,) = create_requests(num_requests=1, num_tokens=33, max_tokens=16)
​
    # 将请求加入调度器并调度一步。
    # 此时请求的 num_computed_tokens 应为 32 ( 来自 mock_kv)，但 request.num_computed_tokens 为 0。
    scheduler.add_request(resumed)
    out = scheduler.schedule()
​
    # 验证：即使没有其他正在运行的请求 (scheduled_running_reqs 为空 )，
    # 因为 num_computed_tokens > 0，该恢复请求也被填充到了 1 + num_spec 的形状，
    # 并附带了占位符 (-1) 的草稿 token。
    assert out.num_scheduled_tokens[resumed.request_id] == 1 + num_spec
    assert out.scheduled_spec_decode_tokens[resumed.request_id] == [-1] * num_spec

评论区精华

本次 PR 的 review 讨论较少，核心决策和验证过程已在 PR body 中详细阐述。

1. 技术澄清：作者在 PR body 中主动排除了与几个已知投机解码 PR（#54102, #53812, #54028, #50518）的重复，明确了本 PR 聚焦于“同步恢复请求在无本地运行工作时”的特定场景。
2. 充分的性能验证：提供了在 4xGB300 集群上进行的完整 QPS 扫描结果，展示了 P99 ITL 的显著改善（高达 -83.4%），并分析了改善的原理（当所有 rank 繁忙时，原始逻辑已生效）。
3. 维护者确认：核心维护者 njhill 简洁地批准了变更，表明对方案和测试结果的认可。

• 投机解码填充条件与 P/D 服务 CUDA 图一致性 (design): 采纳作者方案，将填充条件从 (scheduled_running_reqs and not prefill_scheduled) 修改为 not prefill_scheduled and (scheduled_running_reqs or num_computed_tokens > 0)。

风险与影响

• 风险：

  1. 逻辑变更回归风险：核心变更是一个 AND 到 OR 的逻辑调整。虽然扩展了填充条件，但新的 num_computed_tokens > 0 分支仅在没有 scheduled_running_reqs 且没有 prefill_scheduled 时生效。该逻辑路径理论上是隔离的，回归风险较低。新增的单元测试直接覆盖了此场景。
  2. 性能风险：变更的唯一影响是让更多恢复请求被填充到 1 + num_spec_tokens 形状。在请求密集（每个 rank 都有任务）时，填充逻辑本就不会触发，因此不会增加额外开销。性能验证数据支持此结论。
  3. 兼容性风险：未改变现有的 KV 连接器交互、模型计算或内核。仅影响调度器的形状分配策略，与现有功能兼容。
     - 影响：用户影响：直接提升了在 P/D 分离模式下，使用同步 KV 连接器进行投机解码时的用户体验。在典型负载（QPS 2-5）下，尾部延迟（P99 ITL）获得大幅降低（15%-83%），系统稳定性和吞吐效率提升。
     系统影响：修复了数据并行组内 CUDA 图形状不一致的问题，使得投机解码的调度更加高效和统一。这有助于更好地利用 GPU 计算资源，特别是在大规模 DP 部署中。
     团队影响：为 P/D 架构和投机解码功能的结合提供了一个可靠、经过验证的修复。代码修改精简且集中，易于理解和维护。

• 风险标记：条件逻辑变更

关联脉络

• PR #54102 [SpecDec] Mamba alignment, rejection sentinels, adaptive verification, and verifier graph topology: 同属投机解码功能线，但专注于其他改进（Mamba 对齐、拒绝哨兵、自适应验证、验证器图拓扑），并保留了导致本次问题的 scheduled_running_reqs 要求。
• PR #53812 [Bugfix][Scheduler] Prevent resumed spec decode padding from exceeding max_model_len: 同属投机解码调度器修复，防止恢复填充超过 max_model_len，与本 PR 的填充逻辑改进在不同方面互补。
• PR #54028 [Bugfix][Scheduler] Prevent spec decode padding from conflicting with the long-prefill threshold: 同属投机解码调度器修复，防止填充与长预填充阈值冲突，与本 PR 的填充逻辑改进在不同方面互补。
• PR #54878 [Bugfix][KV Connector] Fix DecodeBenchConnector prefix block selection: 同属 kv-connector 模块的 bug 修复，解决前缀缓存命中时的块选择问题，与本修复的 P/D 场景相关。
• PR #54879 [Bugfix][KV Connector] Safely fill circular buffers in DecodeBench: 同属 kv-connector 模块的 bug 修复，解决 CircularBufferSpec 元数据损坏问题，与本修复的 P/D 测试场景（使用 DecodeBenchConnector）直接相关。