diff options
| -rw-r--r-- | lib/sqlalchemy/dialects/postgresql/psycopg2.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/lib/sqlalchemy/dialects/postgresql/psycopg2.py b/lib/sqlalchemy/dialects/postgresql/psycopg2.py index c4f7c032d..5acba8aba 100644 --- a/lib/sqlalchemy/dialects/postgresql/psycopg2.py +++ b/lib/sqlalchemy/dialects/postgresql/psycopg2.py @@ -489,12 +489,16 @@ class PGDialect_psycopg2(PGDialect): def is_disconnect(self, e, connection, cursor): if isinstance(e, self.dbapi.Error): + # Is the connection already marked as closed? + if getattr(connection, 'closed', False): + return True + str_e = str(e).partition("\n")[0] for msg in [ # these error messages from libpq: interfaces/libpq/fe-misc.c # and interfaces/libpq/fe-secure.c. # TODO: these are sent through gettext in libpq and we can't - # check within other locales - consider using connection.closed + # check within other locales 'terminating connection', 'closed the connection', 'connection not open', |