(self)
| 112 | await self.close() |
| 113 | |
| 114 | async def close(self) -> None: |
| 115 | if self._pool: |
| 116 | self._pool.close() |
| 117 | await self._pool.wait_closed() |
| 118 | self.log.debug("Closed connection %s with params: %s", self._connection, self._template) |
| 119 | self._pool = None |
| 120 | |
| 121 | def acquire_connection(self) -> ConnWrapperType: |
| 122 | return PoolConnectionWrapper(self, self._pool_init_lock) |