github/ColossalAI
1
0
Fork 0
mirror of https://github.com/hpcaitech/ColossalAI.git synced 2025-08-23 10:11:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix tp bug

Browse Source
This commit is contained in:
Tong Li 2025-03-13 14:52:09 +08:00 committed by YeAnbang
parent 69a1a325ee
commit b19355f8f0
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
colossalai/shardformer/policies/qwen2.py
View File

@ -20,6 +20,7 @@ from colossalai.shardformer.layer import (
PaddingEmbedding,
RMSNorm,
VocabParallelEmbedding1D,
VocabParallelLMHead1D,
)
from ..modeling.qwen2 import (
@ -428,7 +429,16 @@ class Qwen2ForCausalLMPolicy(Qwen2Policy):
suffix="lm_head",
target_module=LinearWithGradAccum,
kwargs=dict(fp8_communication=self.shard_config.fp8_communication, use_zbv=use_zbv),
)
),
SubModuleReplacementDescription(
suffix="lm_head",
target_module=VocabParallelLMHead1D,
kwargs={
"gather_output": not self.shard_config.parallel_output,
"make_vocab_size_divisible_by": self.shard_config.make_vocab_size_divisible_by,
"fp8_communication": self.shard_config.fp8_communication,
},
),
],
method_replacement={"forward": get_lm_forward_with_dist_cross_entropy(self.shard_config)},
)