(self)
| 274 | self._con.terminate() |
| 275 | |
| 276 | def _setup_inactive_callback(self) -> None: |
| 277 | if self._inactive_callback is not None: |
| 278 | raise exceptions.InternalClientError( |
| 279 | 'pool connection inactivity timer already exists') |
| 280 | |
| 281 | if self._max_inactive_time: |
| 282 | self._inactive_callback = self._pool._loop.call_later( |
| 283 | self._max_inactive_time, self._deactivate_inactive_connection) |
| 284 | |
| 285 | def _maybe_cancel_inactive_callback(self) -> None: |
| 286 | if self._inactive_callback is not None: |