(self, a, b, conflict_resolution, partial_sync)
| 163 | raise NotImplementedError() |
| 164 | |
| 165 | def run(self, a, b, conflict_resolution, partial_sync): |
| 166 | with self.auto_rollback(a, b): |
| 167 | if self.dest.storage.read_only: |
| 168 | if partial_sync == 'error': |
| 169 | raise PartialSync(self.dest.storage) |
| 170 | elif partial_sync == 'ignore': |
| 171 | self.rollback(a, b) |
| 172 | return |
| 173 | else: |
| 174 | assert partial_sync == 'revert' |
| 175 | |
| 176 | self._run_impl(a, b) |
| 177 | |
| 178 | @contextlib.contextmanager |
| 179 | def auto_rollback(self, a, b): |
no test coverage detected