Closes the split (and the shard if it is still open).
(self)
| 128 | self.current_shard = None |
| 129 | |
| 130 | def close(self) -> None: |
| 131 | """Closes the split (and the shard if it is still open).""" |
| 132 | if not self.closed and self.current_shard: |
| 133 | self.close_shard() |
| 134 | self.closed = True |
| 135 | |
| 136 | |
| 137 | def _split_dict(splits: Dict[str, Split]) -> splits_lib.SplitDict: |