File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed
services/director-v2/src/simcore_service_director_v2/modules/db/repositories/comp_tasks Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -301,12 +301,15 @@ async def mark_project_published_waiting_for_cluster_tasks_as_aborted(
301301 .where (
302302 (comp_run_snapshot_tasks .c .run_id == run_id )
303303 & (comp_run_snapshot_tasks .c .project_id == f"{ project_id } " )
304- & (comp_run_snapshot_tasks .c .node_class == NodeClass .COMPUTATIONAL )
305304 & (
306- (comp_run_snapshot_tasks .c .state == StateType .PUBLISHED )
305+ comp_run_snapshot_tasks .c .node_class
306+ == NodeClass .COMPUTATIONAL .value
307+ )
308+ & (
309+ (comp_run_snapshot_tasks .c .state == StateType .PUBLISHED .value )
307310 | (
308311 comp_run_snapshot_tasks .c .state
309- == StateType .WAITING_FOR_CLUSTER
312+ == StateType .WAITING_FOR_CLUSTER . value
310313 )
311314 )
312315 )
You can’t perform that action at this time.
0 commit comments