Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 12 additions & 1 deletion examples/dllm_sft/diffusion_gemma_lora.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,18 @@ model:
linear: torch
rms_norm: torch_fp32
experts: torch_mm
dispatcher: torch
# DeepEP token dispatch. ep_size=8 is intra-node here, so the single-node
# DeepEP path applies. The "torch" fallback all-gathers every token to every
# rank (a token-count all_gather, an `.item()` host sync and four varlen
# all_gathers per MoE layer per forward pass): on 8xH100 that put 97% of GPU
# kernel time in NCCL, 99.9% of it not overlapped with compute, and ran 1.47x
# slower. "hybridep" is NOT a drop-in replacement here -- it fails this recipe
# with CheckpointError (the tokens routed to a rank differ between forward and
# activation-checkpoint recompute, e.g. 481 vs 1087 rows) even though
# ignore_router_for_ac already defaults to True. Scaling this recipe past one
# node needs that resolved first, since DeepEP's own internode path faults
# separately (internode.cu:346).
dispatcher: deepep
enable_hf_state_dict_adapter: true
enable_fsdp_optimizations: true

Expand Down
13 changes: 12 additions & 1 deletion examples/dllm_sft/diffusion_gemma_sft.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,18 @@ model:
linear: torch
rms_norm: torch_fp32
experts: torch_mm
dispatcher: torch
# DeepEP token dispatch. ep_size=8 is intra-node here, so the single-node
# DeepEP path applies. The "torch" fallback all-gathers every token to every
# rank (a token-count all_gather, an `.item()` host sync and four varlen
# all_gathers per MoE layer per forward pass): on 8xH100 that put 97% of GPU
# kernel time in NCCL, 99.9% of it not overlapped with compute, and ran 1.47x
# slower. "hybridep" is NOT a drop-in replacement here -- it fails this recipe
# with CheckpointError (the tokens routed to a rank differ between forward and
# activation-checkpoint recompute, e.g. 481 vs 1087 rows) even though
# ignore_router_for_ac already defaults to True. Scaling this recipe past one
# node needs that resolved first, since DeepEP's own internode path faults
# separately (internode.cu:346).
dispatcher: deepep
enable_hf_state_dict_adapter: true
enable_fsdp_optimizations: true

Expand Down
Loading