diff options
| author | mike bayer <mike_mp@zzzcomputing.com> | 2019-11-11 22:04:48 +0000 |
|---|---|---|
| committer | Gerrit Code Review <gerrit@bbpush.zzzcomputing.com> | 2019-11-11 22:04:48 +0000 |
| commit | 9cf22b4d67c3e71612d20ad9497c9007da83b5f8 (patch) | |
| tree | bc2d7c6ad1e3b037e1465efcff9a75de9f1aeb7a /lib/sqlalchemy/dialects | |
| parent | 081384c56dbaa88971c8433c7152ad73d4860747 (diff) | |
| parent | 31a66b5add39b9193975f9995ce5cd9235179f00 (diff) | |
| download | sqlalchemy-9cf22b4d67c3e71612d20ad9497c9007da83b5f8.tar.gz | |
Merge "Detect PyMySQL connection was killed"
Diffstat (limited to 'lib/sqlalchemy/dialects')
| -rw-r--r-- | lib/sqlalchemy/dialects/mysql/pymysql.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/lib/sqlalchemy/dialects/mysql/pymysql.py b/lib/sqlalchemy/dialects/mysql/pymysql.py index 0b812cbb0..62de1529f 100644 --- a/lib/sqlalchemy/dialects/mysql/pymysql.py +++ b/lib/sqlalchemy/dialects/mysql/pymysql.py @@ -67,7 +67,10 @@ class MySQLDialect_pymysql(MySQLDialect_mysqldb): ): return True elif isinstance(e, self.dbapi.Error): - return "Already closed" in str(e) + str_e = str(e).lower() + return ( + "already closed" in str_e or "connection was killed" in str_e + ) else: return False |