Expire all currently open connections. Cause all currently open connections to get replaced on the next :meth:`~asyncpg.pool.Pool.acquire()` call. .. versionadded:: 0.16.0
(self)
| 997 | self._closed = True |
| 998 | |
| 999 | async def expire_connections(self): |
| 1000 | """Expire all currently open connections. |
| 1001 | |
| 1002 | Cause all currently open connections to get replaced on the |
| 1003 | next :meth:`~asyncpg.pool.Pool.acquire()` call. |
| 1004 | |
| 1005 | .. versionadded:: 0.16.0 |
| 1006 | """ |
| 1007 | self._generation += 1 |
| 1008 | |
| 1009 | def _check_init(self): |
| 1010 | if not self._initialized: |
no outgoing calls