[None][fix] Fix 6522 mpi.pkl5.intracomm.Request has wait not Wait (#6646)

Signed-off-by: Netanel Haber <nhaber@nvidia.com>
This commit is contained in:
Netanel Haber 2025-08-06 09:18:09 +03:00 committed by GitHub
parent 3036d49071
commit 83ee91e17b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -800,7 +800,7 @@ class PyExecutor:
# Second last rank does not need to since last rank has original decoded tokens
if not self.dist.is_second_last_pp_rank:
if self.send_handles[prev_microbatch_id] is not None:
self.send_handles[prev_microbatch_id].Wait()
self.send_handles[prev_microbatch_id].wait()
needs_logits = (
self._need_return_logits(scheduled_batch)
or (self._need_return_log_probs(scheduled_batch)