X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/d26136521a20387b12a3a632dac18a210fe88430..bde488e7eff0e9a94cbf9709d28de13603857a3d:/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 f793805a8b..3c4f281912 100644 --- a/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go +++ b/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go @@ -79,9 +79,9 @@ func doMain() error { // propagated to crunch-run via SLURM. os.Setenv("ARVADOS_API_HOST", theConfig.Client.APIHost) os.Setenv("ARVADOS_API_TOKEN", theConfig.Client.AuthToken) - os.Setenv("ARVADOS_API_INSECURE", "") + os.Setenv("ARVADOS_API_HOST_INSECURE", "") if theConfig.Client.Insecure { - os.Setenv("ARVADOS_API_INSECURE", "1") + os.Setenv("ARVADOS_API_HOST_INSECURE", "1") } os.Setenv("ARVADOS_KEEP_SERVICES", strings.Join(theConfig.Client.KeepServiceURIs, " ")) os.Setenv("ARVADOS_EXTERNAL_CLIENT", "") @@ -105,7 +105,7 @@ func doMain() error { PollInterval: time.Duration(theConfig.PollPeriod), DoneProcessing: make(chan struct{})} - if _, err := daemon.SdNotify("READY=1"); err != nil { + if _, err := daemon.SdNotify(false, "READY=1"); err != nil { log.Printf("Error notifying init daemon: %v", err) } @@ -127,8 +127,8 @@ func sbatchFunc(container arvados.Container) *exec.Cmd { sbatchArgs = append(sbatchArgs, fmt.Sprintf("--job-name=%s", container.UUID)) sbatchArgs = append(sbatchArgs, fmt.Sprintf("--mem-per-cpu=%d", int(memPerCPU))) sbatchArgs = append(sbatchArgs, fmt.Sprintf("--cpus-per-task=%d", container.RuntimeConstraints.VCPUs)) - if container.RuntimeConstraints.Partition != nil { - sbatchArgs = append(sbatchArgs, fmt.Sprintf("--partition=%s", strings.Join(container.RuntimeConstraints.Partition, ","))) + if container.SchedulingParameters.Partitions != nil { + sbatchArgs = append(sbatchArgs, fmt.Sprintf("--partition=%s", strings.Join(container.SchedulingParameters.Partitions, ","))) } return exec.Command("sbatch", sbatchArgs...)