Check db connection for invalid transactions in runner's monitor loop

jdavcs · Jan 16, 2024 · e24ed35 · e24ed35
1 parent a2cb914
commit e24ed35
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/galaxy/jobs/runners/__init__.py b/lib/galaxy/jobs/runners/__init__.py
@@ -33,7 +33,10 @@
     job_script,
     write_script,
 )
-from galaxy.model.base import transaction
+from galaxy.model.base import (
+    check_database_connection,
+    transaction,
+)
 from galaxy.tool_util.deps.dependencies import (
     JobInfo,
     ToolInfo,
@@ -829,6 +832,7 @@ def monitor(self):
                 pass
             # Iterate over the list of watched jobs and check state
             try:
+                check_database_connection(self.sa_session)
                 self.check_watched_items()
             except Exception:
                 log.exception("Unhandled exception checking active jobs")