(self)
| 194 | self._connection._conn.autocommit = False |
| 195 | |
| 196 | async def commit(self) -> None: |
| 197 | if self._finalized: |
| 198 | raise TransactionManagementError("Transaction already finalised") |
| 199 | await self._connection.commit() |
| 200 | self._finalized = True |
| 201 | self._connection._conn.autocommit = True |
| 202 | |
| 203 | async def rollback(self) -> None: |
| 204 | if self._finalized: |
no test coverage detected