(self, proc_ranks)
| 47 | self.reset(proc_ranks) |
| 48 | |
| 49 | def reset(self, proc_ranks): |
| 50 | self.check(proc_ranks) |
| 51 | self.proc_ranks = proc_ranks |
| 52 | self.is_single_machine_cache = None |
| 53 | self.stream = _sh.get_next() |
| 54 | |
| 55 | def check(self, proc_ranks): |
| 56 | assert _sd is not None, "please call init_process_group first" |
no test coverage detected