X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/2e437823d2d19edf5c6be392f3604a499308cd6e..da6e931b990c7edde55213196fc8a47f4dc4998d:/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go diff --git a/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go b/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go index bc1b0a5228..8fbc0fa8b6 100644 --- a/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go +++ b/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go @@ -137,16 +137,20 @@ func dispatchSlurm(priorityPollInterval int, crunchRunCommand, finishCommand str } // sbatchCmd -var sbatchCmd = func(uuid string) *exec.Cmd { +func sbatchFunc(uuid string) *exec.Cmd { return exec.Command("sbatch", "--job-name="+uuid, "--share", "--parsable") } +var sbatchCmd = sbatchFunc + // striggerCmd -var striggerCmd = func(jobid, containerUUID, finishCommand, apiHost, apiToken, apiInsecure string) *exec.Cmd { +func striggerFunc(jobid, containerUUID, finishCommand, apiHost, apiToken, apiInsecure string) *exec.Cmd { return exec.Command("strigger", "--set", "--jobid="+jobid, "--fini", fmt.Sprintf("--program=%s %s %s %s %s", finishCommand, apiHost, apiToken, apiInsecure, containerUUID)) } +var striggerCmd = striggerFunc + // Submit job to slurm using sbatch. func submit(container Container, crunchRunCommand string) (jobid string, submitErr error) { submitErr = nil