opensource/galaxy
3
0
Fork 0
mirror of https://github.com/galaxyproject/galaxy.git synced 2026-10-16 07:19:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

More WIP stuff

Browse Source
This commit is contained in:
mvdbeek
2023-11-13 15:45:27 +01:00
parent d8bc197030
commit ee7160bb97
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/galaxy/managers/workflows.py
+3 -1
View File
@@ -439,6 +439,7 @@ class WorkflowsManager(sharable.SharableModelManager, deletable.DeletableManager
.filter(~model.Job.table.c.state.in_(model.Job.terminal_states))
.with_for_update().scalar_subquery()
)
log.debug("CANCEL STEP JOBS")
trans.sa_session.execute(update(model.Job.table).where(model.Job.id == job_subq).values({"state": model.Job.states.DELETING}))
job_collection_subq = (
@@ -451,7 +452,8 @@ class WorkflowsManager(sharable.SharableModelManager, deletable.DeletableManager
.with_for_update().subquery()
)
trans.sa_session.execute(update(model.Job.table).where(model.Job.table.c.id.in_(job_collection_subq)).values({"state": model.Job.states.DELETING}))
log.debug("CANCEL STEP IMPLICIT JOBS")
trans.sa_session.execute(update(model.Job.table).where(model.Job.table.c.id.in_(job_collection_subq.element)).values({"state": model.Job.states.DELETING}))
with transaction(trans.sa_session):
trans.sa_session.commit()