zhangyiss/mlx-examples
1
0
Fork 0
mirror of https://github.com/ml-explore/mlx-examples.git synced 2025-08-29 06:54:39 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

reduction moved to CPU in case of distributed training

Browse Source
This commit is contained in:
ivanfioravanti 2025-01-11 00:32:54 +01:00
parent 514502da22
commit ff1719afc3
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
llms/mlx_lm/tuner/trainer.py
View File

@ -160,7 +160,8 @@ def evaluate(
mx.eval(all_losses, ntokens) mx.eval(all_losses, ntokens)
all_losses = mx.distributed.all_sum(all_losses) all_losses = mx.distributed.all_sum(all_losses)
ntokens = mx.distributed.all_sum(ntokens) stream = mx.cpu if mx.distributed.init().size() > 1 else None
ntokens = mx.distributed.all_sum(ntokens, stream=stream)
return (all_losses / ntokens).item() return (all_losses / ntokens).item()