(self)
| 243 | await self.commit() |
| 244 | |
| 245 | async def rollback(self) -> None: |
| 246 | if not self._transaction: |
| 247 | raise exceptions.TransactionManagementError("Transaction is in invalid state") |
| 248 | if self._finalized: |
| 249 | raise exceptions.TransactionManagementError("Transaction already finalised") |
| 250 | |
| 251 | await self._transaction.__aexit__(psycopg.Rollback, psycopg.Rollback(), None) |
| 252 | self._finalized = True |
| 253 | |
| 254 | async def savepoint_rollback(self) -> None: |
| 255 | await self.rollback() |
no test coverage detected