GoldPancake
68dbe71d77
[BugFix] Fix clear_parameters hang issue in MTP during weight cleanup in RL ( #7522 )
...
CE Compile Job / ce_job_pre_check (push) Waiting to run
CE Compile Job / print_ce_job_pre_check_outputs (push) Blocked by required conditions
CE Compile Job / FD-Clone-Linux (push) Blocked by required conditions
CE Compile Job / Show Code Archive Output (push) Blocked by required conditions
CE Compile Job / BUILD_SM8090 (push) Blocked by required conditions
CE Compile Job / BUILD_SM8090_RL (push) Blocked by required conditions
CE Compile Job / BUILD_SM8689 (push) Blocked by required conditions
CE Compile Job / CE_UPLOAD (push) Blocked by required conditions
CE Compile Job / CE_UPLOAD_RL (push) Blocked by required conditions
Deploy GitHub Pages / deploy (push) Waiting to run
* fix mtp clear graph bugs in rl
2026-04-22 15:24:01 +08:00
周周周
e580cf0fef
[OP] latent moe deepgemm support ( #7537 )
...
* commit
* commit
* commit
* commit
* commit
* commit
* commit
* commit
2026-04-22 13:47:06 +08:00
xiaoxiaohehe001
a09792e085
[Optimization] Support multimodal runner for image/video feature processing ( #7485 )
...
* [NewFeature] support mm runner
* [NewFeature] support mm runner part1
* support mm runner part2
* support mm runner part3
* support mm runner part4
2026-04-22 11:58:33 +08:00
Jiang-Jia-Jun
76b960cb5b
Update args_utils.py
2026-04-22 11:01:34 +08:00
RuohengMa
36d47aa23e
[XPU] get_infer_param use inplace copy, remove block_tables abundant d2h copy ( #7431 )
...
* inplace_copy: encoder_batch_idx/decoder_batch_idx bs == 9 ok
* inplace_copy: encoder_seq_lod/decoder_seq_lod bs == 9 ok
* inplace_copy: all bs == 9 ok
* inplace_copy: all cpu bs == 9 ok
* inplace_copy: len_info_cpu bs == 9 ok
* finished and rm unused code
* prefix_block_tables reuse
* refine
* improve performance
* remove block_table copy to cpu
* fix unit test
* fix
* resolve conflict
* refine code
* fix
* fix
* fix
* fix
* fix
* try fix unit tests
* fix
* tmp save
* fix unit test
* get_infer_param try less return values
* add yinwei fix
---------
Co-authored-by: yinwei <yinwei_hust@163.com >
2026-04-22 11:01:32 +08:00
Jiang-Jia-Jun
2edb30c2d0
Change default value of enable_output_caching to False
2026-04-22 10:58:39 +08:00
Yuanle Liu
534c43c888
[BugFix] Fix skip_x_record_stream incompatibility across deep_ep versions ( #7542 )
...
* fix skip_x_record_stream
* fix
* optim
2026-04-21 06:31:00 -07:00
chen
c618a39562
add m_grouped_bf16_gemm_nn_contiguous, del paddle.batch_gemm ( #7527 )
2026-04-21 20:19:46 +08:00
qwes5s5
8883757bad
[BugFix] Fix bugs in /v1/abort_requests interface from PR( #6992 ) ( #7176 )
...
* abort api bug fix
* bug fix
---------
Co-authored-by: Jiang-Jia-Jun <163579578+Jiang-Jia-Jun@users.noreply.github.com >
2026-04-21 19:27:25 +08:00
RAM
d8cdda86cb
[RL][Cherry-Pick] Fix the out-of-bounds issue caused by int32 in the R3 kernel ( #7155 )
...
* [RL]Perf: Optimize batch delete prefix and fused put in R3 (#6604 )
* Optimizate delete batch and fused put
* refine code
* refine code
* refine code
* Support suspend r3
* [RL] Fix R3 Empty bug with TP=1 (#6777 )
* Fix int32 overflow
* refine code
---------
Co-authored-by: YuBaoku <49938469+EmmonsCurse@users.noreply.github.com >
2026-04-21 01:51:09 -07:00
Zhang Yulong
3c7ca62dc3
[benchmark] support swe temp ( #7530 )
2026-04-21 16:32:09 +08:00
zhouchong
4c6364eb53
Unify num_experts_per_tok to moe_k in ModelConfig for MoE model compatibility ( #7509 )
...
Co-authored-by: CSWYF3634076 <wangyafeng@baidu.com >
2026-04-21 15:20:30 +08:00
kevin
7707be8384
[Feature][KVCache] Implement Cache Manager V1 with GPU + CPU Cache Support (1/n) ( #7097 )
...
* [Feature][KVCache] Support cache manager v1 architecture
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* Update cache manager and related modules
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* chore: update cache_manager and related modules
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* fix: add node to evictable set in complete_swap_to_device
When a node transitions from SWAP_TO_DEVICE to DEVICE via
complete_swap_to_device, it was not being added to the
_evictable_device set. This caused nodes with ref_count=0 to
become "orphaned" - not appearing in any evictable set despite
having cache_status=DEVICE.
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* feat: update cache manager v1 and related modules
- Add new cache_manager.py with cache management functionality
- Add radix_tree.py for prefix caching
- Update block_pool.py and metadata.py
- Update request.py and resource_manager_v1.py for scheduling
- Update gpu_model_runner.py for GPU model execution
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* feat(cache): add cache controller v1 implementation
- Add CacheController class for cache management
- Update config.py with cache related configurations
- Refactor gpu_model_runner.py for improved cache handling
* feat(cache_manager): update cache manager v1
* fix(cache_manager): 修复 swap_cache H2D/D2H 方向的 block_ids 逻辑并清理 ForwardMeta
## Motivation
修复 swap_cache_optimized.cu 中 H2D 方向时 src/dst block_ids 使用错误的问题,
并清理 ForwardMeta 中已废弃的 cache_controller 字段。
## Modifications
- fix: swap_cache_optimized.cu 中根据 D2H 模板参数正确选取 src/dst block_ids,
修复 H2D 方向 src/dst 倒置 bug(同时修复 SwapCachePerLayerImpl 和 SwapCacheAllLayersBatchImpl)
- refactor: cache_manager/v1/__init__.py 将 LayerSwapTimeoutError 导入从
cache_controller 改为 cache_utils(正确来源)
- refactor: ForwardMeta 移除废弃的 cache_controller 字段
- refactor: gpu_model_runner.py 移除对应的 cache_controller 赋值语句
- test: 新增 tests/cache_manager/v1/test_swap_cache_ops.py 单元测试
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* feat(cache_manager): refactor cache manager v1 and optimize swap ops
## Motivation
对 cache manager v1 进行重构和优化,精简代码结构,提升可维护性。
## Modifications
- 重构 transfer_manager.py,大幅精简代码逻辑
- 优化 swap_cache_optimized.cu GPU 算子实现
- 调整 cache_manager.py、cache_controller.py 逻辑,修复 free_device_blocks 方法缺失问题
- 更新 block_pool.py、cache_utils.py、metadata.py、radix_tree.py
- 精简 gpu_model_runner.py、forward_meta.py、attention.py 中相关调用
- 更新对应单元测试(test_cache_controller、test_swap_cache_ops、test_transfer_manager)
- 调整 config.py 中相关配置项
* [KVCache][MTP] 支持 cache_manager_v1 下的 MTP KV Cache 初始化及多模态 hash
## Motivation
在 enable_cache_manager_v1 路径下,MTP(speculative decode)的 KV Cache 需要由
CacheController 统一管理,以复用 swap/transfer 能力,同时修复多模态场景下 block
hash 未携带 multimodal extra_keys 的问题。
## Modifications
- `cache_controller.py`
- 新增 `initialize_mtp_kv_cache`:通过 CacheController 初始化 MTP KV Cache,
并将其注册到 cache_kvs_map,使 transfer_manager 自动覆盖 MTP 层
- `initialize_host_cache` 中的 num_layers 改为包含 MTP 额外 cache 层数,保证
Host Cache 也为 MTP 分配足够空间
- `_free_gpu_cache` 改名为 `free_gpu_cache`(对外可调用)
- `cache_utils.py`
- 新增 `get_block_hash_extra_keys`:提取单个 block 内的多模态 hash 信息,
对齐 PrefixCacheManager 的 multimodal extra_keys 逻辑
- `get_request_block_hasher` 中在 hash_block_tokens 时携带 extra_keys,
修复多模态场景 prefix cache 命中率不准的问题
- `spec_decode/mtp.py`
- `update_mtp_block_num` 新增 `skip_cache_init` 参数,避免 v1 cache manager
路径下重复初始化 MTP KV Cache
- `gpu_model_runner.py`
- `initialize_kv_cache(v1)` 路径:在主模型 cache 初始化后,调用
`cache_controller.initialize_mtp_kv_cache` 完成 MTP cache 创建
- `clear_cache` / `wakeup` / `reset` 等路径:respect `enable_cache_manager_v1`
标志,跳过重复的 proposer.initialize_kv_cache 调用
## Usage or Command
```bash
# 启动支持 MTP + cache_manager_v1 的推理服务(示例)
bash run.sh
```
* fix(cache_manager): multi-GPU fix, mm hash boundary fix, and remove batch ops
1. Fix CuPy stream/event creation for multi-GPU: wrap all stream operations
with cp.cuda.Device(device_id) context to ensure streams/events are bound
to the correct device, preventing cross-device errors in multi-GPU setups.
2. Remove cudaSetDevice from SwapCacheAllLayers (handled by cupy context now).
3. Remove swap_cache_all_layers_batch op: simplified the implementation by
removing the batch upload variant; all-layer transfers now use the standard
swap_cache_all_layers with cupy device context.
4. Fix mm hash boundary comparison in get_block_hash_extra_keys: change
strict less-than (<) to less-than-or-equal (<=) so that multimodal items
ending exactly at block start are correctly excluded.
5. Extract config fields to KVCacheBase: model_config, cache_config,
quant_config, parallel_config are now set in the base class __init__ to
avoid duplication in CacheController and CacheManager subclasses.
6. Translate metadata.py docstrings from Chinese to English for broader
contributor accessibility.
7. Add test_cache_utils.py: comprehensive unit tests for
get_block_hash_extra_keys covering all boundary and overlap scenarios.
8. Expand test suite: test_request.py cache fields tests, test_radix_tree.py
backup candidate tests, test_transfer_manager.py and test_cache_manager.py
multi-GPU and concurrent operation tests.
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [BugFix][KVCache] fix List import and move write_policy normalization to CacheManager
## Motivation
修复两处问题:
1. `fastdeploy/engine/request.py` 中 `List` 未导入导致 pre-commit F821 报错
2. `write_policy` 归一化逻辑(`write_through` → `write_through_selective`)不应放在 `FDConfig`,移至 `CacheManager.__init__` 中,使其只影响 Cache Manager V1 的内部逻辑
## Modifications
- `fastdeploy/engine/request.py`: 在 `typing` 导入中补充 `List`,删除重复的 `CacheSwapMetadata` TYPE_CHECKING 导入,修复 F821/F811
- `fastdeploy/config.py`: 删除 `write_policy` 归一化逻辑
- `fastdeploy/cache_manager/v1/cache_manager.py`: 将归一化逻辑移入 `CacheManager.__init__`
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [BugFix][KVCache] fix pre-commit code style issues
## Motivation
修复 CI pre-commit 代码风格检查失败问题。
## Modifications
- `fastdeploy/engine/common_engine.py`: black 格式化
- `fastdeploy/worker/worker_process.py`: black 格式化 + isort 修复
- `fastdeploy/cache_manager/v1/storage/__init__.py`: isort 修复
- `fastdeploy/worker/gpu_worker.py`: isort 修复
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [Feature][KVCache] update cache_manager_v1 modules
## Motivation
更新 Cache Manager V1 相关模块,完善版权信息、改进模块结构与可维护性。
## Modifications
- `fastdeploy/cache_manager/v1/` 系列模块:补充版权 header,优化代码结构
- `fastdeploy/config.py`:配置项更新
- `fastdeploy/engine/sched/resource_manager_v1.py`:调度相关更新
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [Feature][KVCache] add BatchRequest.from_tasks and refactor worker task parsing
## Motivation
将 worker_process 中重复的 task 解析逻辑收敛到 BatchRequest,减少代码冗余,提升可维护性。
## Modifications
- `fastdeploy/engine/request.py`:新增 `BatchRequest.from_tasks()` 类方法,统一将 task_queue 任务分类为推理请求和控制请求
- `fastdeploy/worker/worker_process.py`:使用 `BatchRequest.from_tasks()` 替代内联解析逻辑,并修复重复的 control_reqs 处理块
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [Feature][KVCache] add NUMA affinity for host cache and skip swap cache tests
## Motivation
优化 Host cache 内存分配的 NUMA 亲和性,减少跨 NUMA 访问延迟;
同时跳过 swap cache ops 测试(当前环境不支持)。
## Modifications
- `fastdeploy/cache_manager/v1/cache_controller.py`:
- 新增 `_get_numa_node_for_gpu()` 方法,通过 nvidia-smi 或 sysfs 获取 GPU 对应的 NUMA 节点
- 新增 `_bind_to_closest_numa_node()` 方法,绑定当前线程到 GPU 最近的 NUMA 节点
- 在 `initialize_host_cache()` 中调用 NUMA 绑定,优化 H2D 传输性能
- `tests/cache_manager/v1/test_swap_cache_ops.py`:跳过所有测试类(`TestSwapCacheAllLayersCorrectness`、`TestSwapCacheAllLayersPerformance`、`TestSwapCacheRandomBlockIndices`)
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [BugFix][KVCache] fix unittest failures for cache_manager_v1
三个单测因接口变更或 Mock 方式问题导致失败,需修复。
- tests/distributed/chunked_moe.py:`setup_model_runner` 使用 `__new__` 跳过 `__init__`,补加 `enable_cache_manager_v1 = False`,修复 `AttributeError`
- tests/engine/test_resource_manager.py:`PrefixCacheManager` 为局部导入,`patch` 路径改为定义位置 `fastdeploy.cache_manager.prefix_cache_manager.PrefixCacheManager`
- tests/v1/test_resource_manager_v1.py:`_trigger_preempt` 第四参数已由 `list` 改为 `BatchRequest`,更新测试传参和断言
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [BugFix][KVCache] remove debug logging code
## Modifications
- fastdeploy/engine/request.py:删除调试用 logger 及 prompt_hashes 中的 debug 日志
- fastdeploy/worker/worker_process.py:删除 __main__ 中的调试 import 和 print 语句
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [BugFix][KVCache] fix cupy device id caching and pickle for _match_result
## Motivation
修复两个 bug:
1. `transfer_manager.py` 中每次调用 `cp.cuda.runtime.getDevice()` 存在隐患,应在初始化时缓存为实例变量,保证后续操作使用一致的设备 ID。
2. `request.py` 的 `__getstate__` 未跳过 `_match_result`,该字段包含 BlockNode 树的父子循环引用,pickle 时会触发 `RecursionError`;同时补充 `__setstate__` 确保 unpickle 后字段恢复为安全默认值。
## Modifications
- `transfer_manager.py`:初始化时调用 `cp.cuda.runtime.getDevice()` 并缓存到 `self._cupy_device_id`,后续 `with cp.cuda.Device(...)` 和日志均使用该缓存值。
- `request.py`:
- `__getstate__` 中将 `_match_result` 加入跳过集合 `_SKIP_KEYS`,避免循环引用导致 pickle 失败。
- 新增 `__setstate__`,unpickle 后将 `_block_hasher` 和 `_match_result` 恢复为 `None`。
## Usage or Command
* fix(test): fix unit test errors for _trigger_preempt and wakeup with MTP
- Use BatchRequest instead of list in test_trigger_preempt_records_tasks
- Add missing enable_cache_manager_v1 attr in TestSleepWakeupBehavior._make_runner
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [BugFix][KVCache] fix gpu_free_block_list returning wrong block IDs
## Motivation
`gpu_free_block_list` 的兼容 property 中误用了 `list(range(N))`,
将 `available_blocks()` 的返回值当作整数传给 `range()`,
导致返回 `[0, 1, ..., N-1]` 的假列表,而非真实的空闲 block ID。
## Modifications
- `cache_manager/v1/cache_manager.py`:将 `list(range(self._device_pool.available_blocks()))` 改为 `list(self._device_pool.available_blocks())`
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [BugFix][KVCache] 修复 gpu_free_block_list 返回 int 导致 TypeError
## Motivation
gpu_free_block_list 属性中调用 BlockPool.available_blocks(),
该方法返回 int(空闲块数量),用 list() 包装 int 会触发
TypeError: 'int' object is not iterable。
## Modifications
将 list(self._device_pool.available_blocks()) 改为
list(self._device_pool._free_blocks),直接返回空闲块索引列表。
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [KVCache][CacheManager] 适配 V1 CacheManager 的 pause/sleep/free_cache 操作
## Motivation
V1 CacheManager 引入了新的 reset_cache() 接口,pause 和 sleep 操作需要适配,
同时 free_cache 需要支持可选的 clear_storage 参数。
## Modifications
- cache_controller.py: free_cache 新增 clear_storage 参数(默认 False),
仅当 clear_storage=True 时才调用 _clear_storage(),避免不必要的 storage 清空
- common_engine.py: pause 和 sleep 操作中,当 ENABLE_V1_KVCACHE_MANAGER 时
使用 cache_manager.reset_cache() 替代旧的 reset() 和 pause_transfer 逻辑
- gpu_model_runner.py: sleep 时仅在非 V1 cache manager 下执行 MTP cache 清除
## Usage or Command
# 启动服务(V1 CacheManager)
python -m fastdeploy.entrypoints.openai.api_server \
--enable-v1-kvcache-manager \
...
* [BugFix][KVCache] fix missing enable_cache_manager_v1 in test mocks and remove unused select_blocks_for_backup
- Remove unused `select_blocks_for_backup` method from radix_tree.py
- Fix `match_prefix` default param `skip_storage=True` and log order in cache_manager.py
- Sync test_gpu_model_runner.py with upstream/develop (add TestInsertTasksV1SplitwiseSuffix)
- Add `enable_cache_manager_v1=False` to all mock runners to fix AttributeError in CI
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [BugFix][KVCache] simplify _free_blocks in ResourceManagerV1 for non-v1 path
Remove redundant prefix_caching branch in else path; always call
recycle_gpu_blocks with full block_tables for non-cache-manager-v1 case.
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com >
* [KVCache][Optimization][BugFix] fix and optimize block_pool, cache_manager, transfer_manager, request
## Motivation
修复 cache_manager v1 中若干代码质量问题,提升性能并消除潜在的类型不一致 Bug。
## Modifications
1. **block_pool.py**:`BlockPool.allocate` 将逐个 pop 循环替换为切片 + 批量 set.update,消除 Python 循环开销,O(n) → O(k)(C 层批量操作)
2. **cache_manager.py**:`match_prefix` 在 prefix caching 关闭时提前 return 前写入空 `MatchResult()`,避免调用方解引用 `_match_result=None` 崩溃
3. **transfer_manager.py**:`_build_device_layer_indices` 在 `_cache_kvs_map` 为空时也重置四个层索引列表,防止残留旧 tensor 被 swap 算子使用
4. **request.py**:`BatchRequest.append_swap_metadata` / `append_evict_metadata` 构造 `CacheSwapMetadata` 时将 `src_type`/`dst_type` 从字符串改为 `CacheLevel` 枚举,与字段类型声明一致;补充 `CacheLevel` 导入;`match_result` 属性返回类型标注修正为 `Optional[MatchResult]`
5. **resource_manager_v1.py**:`_allocate_gpu_blocks` 日志从 `INFO` 降级为 `DEBUG`,消除高频调度路径的日志噪音
6. **tests/engine/test_request.py**:同步更新 `src_type`/`dst_type` 断言为 `CacheLevel` 枚举值,补充 `CacheLevel` 导入
## Usage or Command
单元测试:
```bash
source .venv/py310/bin/activate
cd baidu/FastDeploy
python -m pytest tests/cache_manager/v1/test_cache_manager.py -v
python -m pytest tests/cache_manager/v1/test_transfer_manager.py -v
python -m pytest tests/engine/test_request.py -v
```
* [BugFix][KVCache] Fix BlockPool.allocate returns all blocks when num_blocks=0
## Motivation
当 `allocate(num_blocks=0)` 被调用时,Python 负索引陷阱导致严重错误:
`-0 == 0`,所以 `self._free_blocks[-0:]` 等价于 `self._free_blocks[0:]`,
会返回并清空整个空闲块列表,而非返回空列表。
## Modifications
在 `BlockPool.allocate` 中增加对 `num_blocks == 0` 的提前判断,直接返回 `[]`,
避免触发 Python 负索引陷阱。
## Usage or Command
```bash
# 运行相关单元测试验证修复
python -m pytest tests/cache_manager/v1/test_cache_manager.py -vv -s
```
* [KVCache][Test] add unit tests for cache_manager v1 modules
## Motivation
补全 cache_manager/v1 各模块的单测覆盖,确保核心方法有完整的测试保障。
## Modifications
新增/补充以下测试文件,全部 326 个用例通过:
- tests/cache_manager/v1/test_block_pool.py(新建)
覆盖 BlockPool.get_metadata/set_metadata/resize、DeviceBlockPool/HostBlockPool
- tests/cache_manager/v1/test_metadata.py(新建)
覆盖 BlockNode、RadixTreeStats、MatchResult、CacheSwapMetadata、AsyncTaskHandler
- tests/cache_manager/v1/test_cache_utils.py(补充)
新增 hash_block_tokens、get_request_block_hasher、LayerDoneCounter 时间追踪及内部辅助方法
- tests/cache_manager/v1/test_radix_tree.py(补充)
新增 TestCompleteSwapToDevice 专项测试类(6 个用例)
- tests/cache_manager/v1/test_cache_manager.py(补充)
新增 offload_to_host、load_from_host、pending backup 系列、prepare_prefetch_metadata
- tests/cache_manager/v1/test_transfer_manager.py(补充)
新增 _swap_single_layer 校验路径、sync_input/output_stream、record_input_stream_event
## Usage or Command
```bash
# 运行所有新增单测
source .venv/py310/bin/activate
python -m pytest tests/cache_manager/v1/test_block_pool.py \
tests/cache_manager/v1/test_metadata.py \
tests/cache_manager/v1/test_cache_utils.py \
tests/cache_manager/v1/test_radix_tree.py \
tests/cache_manager/v1/test_cache_manager.py \
tests/cache_manager/v1/test_transfer_manager.py -v
# 期望结果:326 passed
```
---------
Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com >
Co-authored-by: Jiang-Jia-Jun <163579578+Jiang-Jia-Jun@users.noreply.github.com >
2026-04-21 14:39:00 +08:00
yzwu
e4a4573080
[Iluvatar] Fix cannot import name mtp_save_first_token ( #7495 )
...
Co-authored-by: YuBaoku <49938469+EmmonsCurse@users.noreply.github.com >
2026-04-21 14:09:08 +08:00
RuohengMa
9d3551cfbb
[XPU] add support for rope3d ( #7518 )
...
* [XPU] add support for rope3d
* support decoder
---------
Co-authored-by: yinwei <yinwei_hust@163.com >
2026-04-21 13:39:00 +08:00
周周周
609f649dd7
[OP] Add flashmla baseline implementation and precision test ( #7477 )
2026-04-21 13:37:52 +08:00
YuBaoku
3c8c82d5d4
[CI] Remove flashinfer cache cleanup to reduce unit test runtime ( #7476 )
2026-04-21 11:38:30 +08:00
YuBaoku
5e866e3e21
[CI] Add --workers=1 to keep test behavior consistent with default change
2026-04-20 22:31:42 +08:00
Zhang Yulong
30db3e9d8f
[benchmark] update tools ( #7512 )
2026-04-20 19:40:17 +08:00
YuBaoku
c9783a84a6
[CI] Temporarily pin paddlepaddle-gpu to 3.5.0.dev20260417 ( #7486 )
2026-04-20 19:35:34 +08:00
K11OntheBoat
b79b094dcc
Change default workers and max-concurrency when launch api-server ( #7457 )
...
Co-authored-by: zhangxiao35 <zhangxiao35@baidu.com >
2026-04-20 15:55:06 +08:00
ZhijunLStudio
a0c39cc9af
[Typo] Fix parameter name typo in slice_fn: paramter -> parameter ( #7462 )
...
Fix the typo in the internal parameter name of slice_fn():
weight_or_paramter -> weight_or_parameter.
No functional changes.
Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com >
2026-04-20 10:06:02 +08:00
RuohengMa
cf5bc5e510
[XPU] fix bug and teporary fix for rope 3d ( #7465 )
2026-04-20 09:51:27 +08:00
YuBaoku
b2aca6c550
[CI] Improve logging check accuracy and unify error log cleanup ( #7473 )
2026-04-18 19:41:21 +08:00
freeliuzc
22a4f6019d
[Speculative Decoding][BugFix] Fix apply repeat times penalty kernel and change spec default verify strategy ( #7467 )
...
* fix repeat_time kernel and change default spec verify strategy
* fix unit_test
2026-04-18 00:38:01 +08:00
GoldPancake
df3b4e12f4
[Speculative Decoding] Add MTP logprob support for PD disaggregation ( #7442 )
...
* support mtp logprob in pd
* fix
* fix
* fix
* fix xpu bugs
2026-04-17 21:37:38 +08:00
yzwu
3b9d6c60d3
[Iiluvatar] fix ci error and update readme ( #7453 )
2026-04-17 20:42:56 +08:00
jackyYang6
a729e0f729
[Bugfix][RL] fix control request timeout in async update weights pipeline ( #7430 )
2026-04-17 16:45:33 +08:00
freeliuzc
43685a98a7
[BugFix] Fix real token exceeding max_batched_tokens limit ( #7438 )
...
* fix max_num_batched_tokens error compute
* add temperatory solution
* fix bug
2026-04-17 16:18:07 +08:00
jc
6847891241
Mooncake storage register local buffer by chunk ( #7416 )
2026-04-17 10:39:34 +08:00
YuBaoku
91b8bf20f0
[CI] Add pytest failure log collection and persistence ( #7405 )
2026-04-16 22:56:17 +08:00
AIbin
6ce4854714
[Feature] Support MOE Cutlass backend for latent MOE ( #7428 )
...
* support moe cutlass backend latent moe
2026-04-16 22:11:49 +08:00
ShaneGZhu
2d8338f9e4
[Optimization][DeepSeekV3.2]Reducing slot_mapping compute frequency from twice per layer to a single pre-processing step. ( #7367 )
2026-04-16 19:54:12 +08:00
RichardWooSJTU
d2d633b05c
allow parallel dp starting ( #7426 )
2026-04-16 18:43:09 +08:00
RichardWooSJTU
420a8c1af5
fix deep gemm import ( #7425 )
2026-04-16 17:56:56 +08:00
ddchenhao66
e9527208d9
[BugFix][XPU] Fix kv_cache management bug ( #7420 )
2026-04-16 15:45:45 +08:00
zhouchong
6e16438a57
[Feature] implement log channel separation and request log level system ( #7190 )
...
* feat: implement log channel separation and request log level system
* fix: log system improvements based on review
* add request_id to error logs, use RequestLogLevel enum, and unify logger implementation from utils to logger module
2026-04-16 15:13:05 +08:00
Jiajun Ji
29495b2cf1
[XPU] Unify Spec and non-spec branch.( #6947 ) ( #7180 )
...
* [XPU] cherry-pick PR-6947
* [XPU] use unified_update_model_status.
* refactor xpu_model_runner.
* refactor sampler.
* fix codestyle.
* Fix XPU speculative decoding: rename output tensors to cu_seqlens_q_output/batch_id_per_token_output, correct
WRAPPER_CHECK_PTR types, and fix dynamic gather shape in verify_draft_tokens path.
* fix codestyle.
* replace output_padding_offset with is_speculative flag in gather_next_token.
* rename hiddden_states.
* unify cu_seqlens_q_output and batch_id_per_token_output init.
---------
Co-authored-by: cmcamdy <1027740945@qq.com >
2026-04-16 14:58:38 +08:00
YuBaoku
17002edc47
[CI] Add approval check for logging-related modifications ( #7429 )
2026-04-16 14:50:22 +08:00
RuohengMa
de0c5e68fb
[XPU] Split the block_attn operator into smaller operators ( #6798 )
...
* spliced block_attn
* adapt to latest vllm
* fix unit tests
* delete mtp+cudagraph 4 cards test
* fix vl model
* fix mtp
* fix slot mapping
2026-04-16 14:28:40 +08:00
Bingoo
6b891da02b
[Optimization] enable trtllm_all_reduce fusion kernel in glm model ( #6660 )
...
* enable trtllm_all_reduce fusion kernel in glm model
* fix conflict
* format update
* fix a bug
* modify test
* modify test
* support empty tensor and modify test
* fix test_linear config issues
* modify test name
* add edge test case
* modify format
* fix conflict
* modify default max token num in trtllm_allreduce_fusion
* add max token num branch for trtllm_allreduce_fusion
* fix format
* fix rmsnorm config issue
* modify 2025 to 2026
* using compat grard
* Lazily import flashinfer.comm and fix test config issue
* fix test issues
* add flashinfer cache dir clean machine
* fix some issues
2026-04-16 14:10:19 +08:00
jc
e53f5184ac
PD deployment support without router ( #7412 )
2026-04-15 20:13:07 +08:00
GoldPancake
a498720a75
[RL] Add clear_graph_opt_backend for glm4_mtp ( #7378 )
...
* add clear_grpah func
* fix spell
2026-04-15 19:44:15 +08:00
RichardWooSJTU
dec0b060fc
[Optimization] Auto set num_max_dispatch_tokens_per_rank ( #7237 )
...
* auto set num_max_dispatch_tokens_per_rank
* fix ci
* fix ci
* fix ci
2026-04-15 19:13:38 +08:00
luukunn
3f84d8d893
[DataProcessor] Refactor multimodal processor: extract encoding strategies and unify MM processing pipeline ( #7298 )
...
* merge mm processor
2026-04-15 19:01:06 +08:00
Bingoo
a218d29488
modify flash_mask version ( #7413 )
2026-04-15 18:16:58 +08:00
luukunn
14d556692b
[BugFix] fix tool call parser ( #7369 )
...
* fix tool call parser
* add unit test
* fix unit test
* add unit test
2026-04-15 16:21:46 +08:00
AIbin
8eebbcaf15
[BugFix][Scheduler]Fix FD_DISABLE_CHUNKED_PREFILL max_num_batched_tokens limit ( #7407 )
...
* fix FD_DISABLE_CHUNKED_PREFILL max_num_batched_tokens=max_model_len
* fix FD_DISABLE_CHUNKED_PREFILL max_num_batched_tokens=max_model_len
2026-04-15 15:55:11 +08:00
周周周
5e54770b2e
[Feature] 添加 MoE 层 latent mode 支持 ( #7382 )
2026-04-15 13:57:07 +08:00
lonelygsh
f7a2418ce2
[Speculate Decoding] Fix reasoning_phase_token_constraint call args in SpeculativeSampler ( #7402 )
2026-04-15 12:45:23 +08:00