(self)
| 24 | self.communicator = None |
| 25 | |
| 26 | def init(self): |
| 27 | from verl.utils.rendezvous.ray_backend import create_nccl_communicator_in_ray |
| 28 | |
| 29 | self.communicator = create_nccl_communicator_in_ray(self.rank, self.world_size, self.group_name) |
| 30 | |
| 31 | def test(self): |
| 32 | if self.communicator is None: |
no test coverage detected