(self)
| 199 | return await self.begin() |
| 200 | |
| 201 | async def commit(self) -> None: |
| 202 | if not self.transaction: |
| 203 | raise TransactionManagementError("Transaction is in invalid state") |
| 204 | if self._finalized: |
| 205 | raise TransactionManagementError("Transaction already finalised") |
| 206 | await self.transaction.commit() |
| 207 | self._finalized = True |
| 208 | |
| 209 | async def release_savepoint(self) -> None: |
| 210 | return await self.commit() |
no test coverage detected