(self)
| 96 | raise TransactionManagementError(exc) |
| 97 | |
| 98 | async def db_delete(self) -> None: |
| 99 | try: |
| 100 | return await super().db_delete() |
| 101 | except asyncpg.InvalidCatalogNameError: # pragma: nocoverage |
| 102 | pass |
| 103 | await self.close() |
| 104 | |
| 105 | def _in_transaction(self) -> TransactionContext: |
| 106 | return TransactionContextPooled(TransactionWrapper(self), self._pool_init_lock) |