8953: shutdown_eligible() returns a tuple. Report reason for shutdown decision.

[arvados.git] / 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 bc1b0a5228264cfbade661d97e1785fb5f05baa7..8fbc0fa8b63810bd6a06fadab097836dfd06b113 100644 (file)
--- 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