diff options
| author | Felix Schwarz <felix.schwarz@oss.schwarz.eu> | 2014-04-18 15:19:50 +0200 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2014-06-02 16:34:02 +0100 |
| commit | b9c897e96ca085dd0206e59d5a2ec5d08b1957f3 (patch) | |
| tree | 7e901a2189cf1c57ec899c1175072c5a98531804 | |
| parent | 79f59e189736e8f7b72ada34998027f62071f708 (diff) | |
| download | kombu-b9c897e96ca085dd0206e59d5a2ec5d08b1957f3.tar.gz | |
SQLAlchemy Transport treats OperationalError as connection error (e.g. MySQL connection drops due to inactivity or a MySQL server restart)
| -rw-r--r-- | kombu/transport/sqlalchemy/__init__.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kombu/transport/sqlalchemy/__init__.py b/kombu/transport/sqlalchemy/__init__.py index 0dd5a9da..27c6e65d 100644 --- a/kombu/transport/sqlalchemy/__init__.py +++ b/kombu/transport/sqlalchemy/__init__.py @@ -153,6 +153,7 @@ class Transport(virtual.Transport): default_port = 0 driver_type = 'sql' driver_name = 'sqlalchemy' + connection_errors = (OperationalError, ) def driver_version(self): import sqlalchemy |