WIP: Allow jobs to be submitted in paused
status
#104318
@ -486,10 +486,9 @@ func (sm *StateMachine) pauseTasks(
|
|||||||
logger.Info().Msg("pausing tasks of job")
|
logger.Info().Msg("pausing tasks of job")
|
||||||
|
|
||||||
// Any task that might run in the future should get paused.
|
// Any task that might run in the future should get paused.
|
||||||
// Active jobs should remain active until finished
|
// Active tasks should remain active until finished.
|
||||||
taskStatusesToPause := []api.TaskStatus{
|
taskStatusesToPause := []api.TaskStatus{
|
||||||
api.TaskStatusQueued,
|
api.TaskStatusQueued,
|
||||||
api.TaskStatusCanceled,
|
|
||||||
api.TaskStatusSoftFailed,
|
api.TaskStatusSoftFailed,
|
||||||
}
|
}
|
||||||
err := sm.persist.UpdateJobsTaskStatusesConditional(
|
err := sm.persist.UpdateJobsTaskStatusesConditional(
|
||||||
|
Loading…
Reference in New Issue
Block a user