trainer_dev

文件	最后提交记录	最后更新时间
__init__.py	feat(context_parallel): add async DSA context parallel support	5 个月前
async_context_parallel.py	fix: clean master static analysis warnings	1 个月前
async_dsa_context_parallel.py	refactor(context_parallel): remove platform backend dependency	1 个月前
context_parallel.py	refactor: consolidate core collectives and helpers into core/utils 本 PR 对 hyper_parallel/core 做去重整理,把原先散落在 dtensor 与 distributed 两处的集体通信函数和小工具收敛到单一归属模块,消除重复 实现与重导出链。 - core/utils/communication.py:新增 get_group_local_rank、get_device_handle、 get_world_size、ensure_contiguous、create_group、split_group、 init_process_group 等设备/进程组工具,以及 differentiable_* 系列集体通信 函数与 p2p_exchange、wait_async_tensor。 - core/utils/__init__.py:补充对外导出,使 core.utils 成为这些公共工具的 唯一入口。 - hyper_parallel/distributed/_collectives.py:删除,其内容已并入 core/utils/communication.py。 - core/dtensor/_utils.py:移除已迁至 core.utils 的重复实现,仅保留调试 tracer 需要在本模块上打补丁的绑定。 - core/context_parallel/utils.py、core/fully_shard/utils.py、 core/shard/utils.py、core/activation_memory/_backend.py:统一以 __all__ 声明对外可见符号,替代 from x import y as y 的显式重导出写法,并清除 无消费者的冗余导入。 - core/shard/utils.py:删除 get_world_size 封装(torch 原生接口已可直接 调用),调用点 shard/api.py 与 fully_shard/api.py 改用 dist.get_world_size()。 - distributed/{_builder,context_parallel}:同步适配新的导入路径。 不再有同名的重复实现,调用方从 core.utils 取用;tracer 依赖的模块级绑定 保持不变。行为无变化。	1 个月前
dsa_context_parallel.py	refactor: consolidate core collectives and helpers into core/utils 本 PR 对 hyper_parallel/core 做去重整理,把原先散落在 dtensor 与 distributed 两处的集体通信函数和小工具收敛到单一归属模块,消除重复 实现与重导出链。 - core/utils/communication.py:新增 get_group_local_rank、get_device_handle、 get_world_size、ensure_contiguous、create_group、split_group、 init_process_group 等设备/进程组工具,以及 differentiable_* 系列集体通信 函数与 p2p_exchange、wait_async_tensor。 - core/utils/__init__.py:补充对外导出,使 core.utils 成为这些公共工具的 唯一入口。 - hyper_parallel/distributed/_collectives.py:删除,其内容已并入 core/utils/communication.py。 - core/dtensor/_utils.py:移除已迁至 core.utils 的重复实现,仅保留调试 tracer 需要在本模块上打补丁的绑定。 - core/context_parallel/utils.py、core/fully_shard/utils.py、 core/shard/utils.py、core/activation_memory/_backend.py:统一以 __all__ 声明对外可见符号,替代 from x import y as y 的显式重导出写法,并清除 无消费者的冗余导入。 - core/shard/utils.py:删除 get_world_size 封装(torch 原生接口已可直接 调用),调用点 shard/api.py 与 fully_shard/api.py 改用 dist.get_world_size()。 - distributed/{_builder,context_parallel}:同步适配新的导入路径。 不再有同名的重复实现,调用方从 core.utils 取用;tracer 依赖的模块级绑定 保持不变。行为无变化。	1 个月前
utils.py	refactor: consolidate core collectives and helpers into core/utils 本 PR 对 hyper_parallel/core 做去重整理,把原先散落在 dtensor 与 distributed 两处的集体通信函数和小工具收敛到单一归属模块,消除重复 实现与重导出链。 - core/utils/communication.py:新增 get_group_local_rank、get_device_handle、 get_world_size、ensure_contiguous、create_group、split_group、 init_process_group 等设备/进程组工具,以及 differentiable_* 系列集体通信 函数与 p2p_exchange、wait_async_tensor。 - core/utils/__init__.py:补充对外导出,使 core.utils 成为这些公共工具的 唯一入口。 - hyper_parallel/distributed/_collectives.py:删除,其内容已并入 core/utils/communication.py。 - core/dtensor/_utils.py:移除已迁至 core.utils 的重复实现,仅保留调试 tracer 需要在本模块上打补丁的绑定。 - core/context_parallel/utils.py、core/fully_shard/utils.py、 core/shard/utils.py、core/activation_memory/_backend.py:统一以 __all__ 声明对外可见符号,替代 from x import y as y 的显式重导出写法,并清除 无消费者的冗余导入。 - core/shard/utils.py:删除 get_world_size 封装(torch 原生接口已可直接 调用),调用点 shard/api.py 与 fully_shard/api.py 改用 dist.get_world_size()。 - distributed/{_builder,context_parallel}:同步适配新的导入路径。 不再有同名的重复实现,调用方从 core.utils 取用;tracer 依赖的模块级绑定 保持不变。行为无变化。	1 个月前