Clears pool._working_addr if closing connection due to consecutive exceptions

egalpin · egalpin · commit c35680b9f6d0 · 2018-02-07T17:06:24.000-05:00
This change will help alleviate any issues in an HA configuration where
the server IP is cached by the pool initialization.
diff --git a/asyncpg/pool.py b/asyncpg/pool.py
@@ -282,6 +282,7 @@ async def maybe_close_bad_connection(self, exc_type):
 if self._consecutive_exceptions > self._max_consecutive_exceptions:
 await self.close()
 self._consecutive_exceptions = 0
+ self._pool._working_addr = None
 
 
 class Pool:

-Original file line number
+Diff line change
 ifself._consecutive_exceptions>self._max_consecutive_exceptions:
 awaitself.close()
 self._consecutive_exceptions=0
 +self._pool._working_addr=None
 classPool: