Handle db api exceptions

jdavcs · Apr 4, 2024 · 72e9374 · 72e9374
1 parent e970ae5
commit 72e9374
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/lib/galaxy/jobs/handler.py b/lib/galaxy/jobs/handler.py
@@ -18,7 +18,10 @@
     Union,
 )
 
-from sqlalchemy.exc import OperationalError
+from sqlalchemy.exc import (
+    DBAPIError,
+    OperationalError,
+)
 from sqlalchemy.sql.expression import (
     and_,
     func,
@@ -395,6 +398,10 @@ def __monitor_step(self):
             self.__handle_waiting_jobs()
         except StopSignalException:
             pass
+        except DBAPIError as e:
+            log.exception(f"Execution of a database operation failed due to the following exception: {e}")
+            self.sa_session.remove()
+
         log.trace(monitor_step_timer.to_str())
 
     def __handle_waiting_jobs(self):