Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
hanwen-sun committed Oct 18, 2024
1 parent 33f0007 commit 77fda58
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions torchacc/dist/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -89,8 +89,9 @@ def init_nccl_context(config) -> None:

_NCCL_CONTEXT_INITED = True


def rendezvous(tag, payload=b'', replicas=[]):
"""Waits for all the mesh clients to reach the named rendezvous.
"""Waits for all the mesh clients to reach the named rendezvous.
We use the rendezvous api of xla directly.
Args:
Expand All @@ -104,4 +105,4 @@ def rendezvous(tag, payload=b'', replicas=[]):
The payloads exchanged by all the other cores, with the payload of core
ordinal `i` at position `i` in the returned tuple.
"""
return xm.rendezvous(payload, replicas or None, tag=tag)
return xm.rendezvous(payload, replicas or None, tag=tag)

0 comments on commit 77fda58

Please sign in to comment.