mirror of
https://github.com/microsoft/mscclpp.git
synced 2026-05-25 15:24:43 +00:00
@@ -97,7 +97,7 @@ class CommGroup:
|
||||
else:
|
||||
endpoint = endpoints
|
||||
if endpoint.transport == Transport.Nvls:
|
||||
connections[rank] = self.communicator.connct_nvls_collective(all_ranks, endpoint)
|
||||
return self.communicator.connct_nvls_collective(all_ranks, endpoint)
|
||||
else:
|
||||
connections[rank] = self.communicator.connect_on_setup(rank, 0, endpoint)
|
||||
self.communicator.setup()
|
||||
|
||||
Reference in New Issue
Block a user