(self)
| 926 | self.connection: Optional[Connection] = None |
| 927 | |
| 928 | async def connect(self): |
| 929 | if self.connection is None: |
| 930 | self.connection = await self.connection_pool.get_connection() |
| 931 | |
| 932 | async def __aenter__(self): |
| 933 | await self.connect() |
no test coverage detected