(self)
| 1189 | ) |
| 1190 | |
| 1191 | async def _ensure_indexes(self) -> None: |
| 1192 | if not object.__getattribute__(self, "_ensured_index"): |
| 1193 | _disallow_transactions(self._session) |
| 1194 | await self._create_index(self._coll.files, _F_INDEX, False) |
| 1195 | await self._create_index(self._coll.chunks, _C_INDEX, True) |
| 1196 | object.__setattr__(self, "_ensured_index", True) |
| 1197 | |
| 1198 | async def abort(self) -> None: |
| 1199 | """Remove all chunks/files that may have been uploaded and close.""" |
no test coverage detected