diff --git a/aiter/dist/device_communicators/communicator_cuda.py b/aiter/dist/device_communicators/communicator_cuda.py index aa72ca81db..8505a67d72 100644 --- a/aiter/dist/device_communicators/communicator_cuda.py +++ b/aiter/dist/device_communicators/communicator_cuda.py @@ -279,7 +279,7 @@ def fused_allreduce_rmsnorm( use_1stage = ( self._ar_1stage_override if self._ar_1stage_override is not None - else (total_bytes <= 128 * 1024) + else (total_bytes <= self.world_size * 32 * 1024) ) if ( not use_general_path