Close the server.
(self)
| 99 | self.__start_rank_pairing() |
| 100 | |
| 101 | def close(self) -> None: |
| 102 | """Close the server.""" |
| 103 | self.sock.close() |
| 104 | |
| 105 | def aggregate(self, weights: Dict[str, List[tensor.Tensor]]) -> Dict[str, tensor.Tensor]: |
| 106 | """Aggregate collected weights to update server weight. |