opensource/galaxy
3
0
Fork 0
mirror of https://github.com/galaxyproject/galaxy.git synced 2026-09-24 16:30:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #22063 from mvdbeek/fix_22042_check_db_connection_workflow_scheduling

Browse Source 
[26.0] Add check_database_connection to workflow scheduling path
This commit is contained in:
Marius van den Beek
2026-03-12 14:40:48 +01:00
committed by GitHub
parent 985f916061 d75fca2877
commit 1df6b8b4e2
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/galaxy/workflow/scheduling_manager.py
+2
View File
@@ -16,6 +16,7 @@ import galaxy.workflow.schedulers
from galaxy import model
from galaxy.exceptions import HandlerAssignmentError
from galaxy.jobs.handler import InvocationGrabber
from galaxy.model.base import check_database_connection
from galaxy.schema.invocation import (
FailureReason,
InvocationFailureDatasetFailed,
@@ -431,6 +432,7 @@ class WorkflowRequestMonitor(Monitors):
def __attempt_schedule(self, invocation_id, workflow_scheduler):
with self.app.model.context() as session:
check_database_connection(session)
workflow_invocation = session.get(model.WorkflowInvocation, invocation_id)
if workflow_invocation.state == workflow_invocation.states.REQUIRES_MATERIALIZATION:
if not self.__attempt_materialize(workflow_invocation, session):