update pg8000 dialect is_disconnect method Fixes: #6099

diff --git a/lib/sqlalchemy/dialects/postgresql/pg8000.py b/lib/sqlalchemy/dialects/postgresql/pg8000.py
index 6e7318272780a5b93478eba15fb389025efcfbb9..33cf1bcbcf38dc314ebf892e9e334a2deb35b77a 100644 (file)
--- a/lib/sqlalchemy/dialects/postgresql/pg8000.py
+++ b/lib/sqlalchemy/dialects/postgresql/pg8000.py
@@ -328,7 +328,12 @@ class PGDialect_pg8000(PGDialect):
         return ([], opts)
 
     def is_disconnect(self, e, connection, cursor):
-        return "connection is closed" in str(e)
+        if isinstance(e, self.dbapi.InterfaceError):
+            # pg8000 returns InterfaceError with message set to
+            # "network error on read", "network error on write", or
+            # "network error on flush" in case of connection issues.
+            return str(e).startswith("network error")
+        return False
 
     def set_isolation_level(self, connection, level):
         level = level.replace("_", " ")