X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/b50ea3465244e66ecf2a852f598f5b576e705017..9ea9735d7569f23a89fbcfaa69710f209eea6466:/services/crunch-dispatch-slurm/squeue.go diff --git a/services/crunch-dispatch-slurm/squeue.go b/services/crunch-dispatch-slurm/squeue.go index 5ecfe8ff2f..adb620ea8d 100644 --- a/services/crunch-dispatch-slurm/squeue.go +++ b/services/crunch-dispatch-slurm/squeue.go @@ -22,6 +22,7 @@ type jobPriority struct { // command 'squeue'. type SqueueChecker struct { Period time.Duration + Slurm Slurm uuids map[string]jobPriority startOnce sync.Once done chan struct{} @@ -77,7 +78,7 @@ func (sqc *SqueueChecker) check() { sqc.L.Lock() defer sqc.L.Unlock() - cmd := theConfig.slurm.QueueCommand([]string{"--all", "--format=%j %y %Q"}) + cmd := sqc.Slurm.QueueCommand([]string{"--all", "--format=%j %y %Q"}) stdout, stderr := &bytes.Buffer{}, &bytes.Buffer{} cmd.Stdout, cmd.Stderr = stdout, stderr if err := cmd.Run(); err != nil {