X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/6346a7c4c0cb5d7e8c5f01392b6cc64d329b68ec..672ecbf2d4ca909514c5f609ed76b020200cdf45:/services/crunch-dispatch-slurm/slurm.go?ds=sidebyside diff --git a/services/crunch-dispatch-slurm/slurm.go b/services/crunch-dispatch-slurm/slurm.go index 735e057e25..9e9f45270f 100644 --- a/services/crunch-dispatch-slurm/slurm.go +++ b/services/crunch-dispatch-slurm/slurm.go @@ -13,10 +13,11 @@ import ( ) type Slurm interface { + Batch(script io.Reader, args []string) error Cancel(name string) error - Renice(name string, nice int64) error QueueCommand(args []string) *exec.Cmd - Batch(script io.Reader, args []string) error + Release(name string) error + Renice(name string, nice int64) error } type slurmCLI struct{} @@ -54,6 +55,10 @@ func (scli *slurmCLI) QueueCommand(args []string) *exec.Cmd { return exec.Command("squeue", args...) } +func (scli *slurmCLI) Release(name string) error { + return scli.run(nil, "scontrol", []string{"release", "Name=" + name}) +} + func (scli *slurmCLI) Renice(name string, nice int64) error { return scli.run(nil, "scontrol", []string{"update", "JobName=" + name, fmt.Sprintf("Nice=%d", nice)}) }