Ask Solem преди 11 години
родител
ревизия
59fa886071
променени са 1 файла, в които са добавени 2 реда и са изтрити 5 реда
  1. 2 5
      celery/backends/database/__init__.py

+ 2 - 5
celery/backends/database/__init__.py

@@ -37,7 +37,7 @@ def _sqlalchemy_installed():
     return sqlalchemy
     return sqlalchemy
 _sqlalchemy_installed()
 _sqlalchemy_installed()
 
 
-from sqlalchemy.exc import DatabaseError, OperationalError, ResourceClosedError, InvalidRequestError, IntegrityError
+from sqlalchemy.exc import DatabaseError, InvalidRequestError
 from sqlalchemy.orm.exc import StaleDataError
 from sqlalchemy.orm.exc import StaleDataError
 
 
 
 
@@ -61,10 +61,7 @@ def retry(fun):
         for retries in range(max_retries):
         for retries in range(max_retries):
             try:
             try:
                 return fun(*args, **kwargs)
                 return fun(*args, **kwargs)
-            except (
-                DatabaseError, OperationalError, ResourceClosedError, StaleDataError, InvalidRequestError,
-                IntegrityError
-            ):
+            except (DatabaseError, InvalidRequestError, StaleDataError):
                 logger.warning(
                 logger.warning(
                     "Failed operation %s. Retrying %s more times.",
                     "Failed operation %s. Retrying %s more times.",
                     fun.__name__, max_retries - retries - 1,
                     fun.__name__, max_retries - retries - 1,