Create a new connection. Can be overridden by child classes.
(self)
| 1622 | ) |
| 1623 | |
| 1624 | def make_connection(self): |
| 1625 | """Create a new connection. Can be overridden by child classes.""" |
| 1626 | # Note: We don't record IDLE here because async uses a sync make_connection |
| 1627 | # but async record_connection_count. The recording is handled in get_connection. |
| 1628 | return self.connection_class(**self.connection_kwargs) |
| 1629 | |
| 1630 | async def ensure_connection(self, connection: AbstractConnection): |
| 1631 | """Ensure that the connection object is connected and valid""" |
no outgoing calls
no test coverage detected