c.Check(err, IsNil)
c.Check(len(containers.Items), Equals, 1)
- config.CrunchRunCommand = []string{"echo"}
+ theConfig.CrunchRunCommand = []string{"echo"}
doneProcessing := make(chan struct{})
dispatcher := dispatch.Dispatcher{
api := httptest.NewServer(&apiStub)
defer api.Close()
- arv := arvadosclient.ArvadosClient{
+ arv := &arvadosclient.ArvadosClient{
Scheme: "http",
ApiServer: api.URL[7:],
ApiToken: "abc123",
log.SetOutput(io.MultiWriter(buf, os.Stderr))
defer log.SetOutput(os.Stderr)
- config.CrunchRunCommand = []string{crunchCmd}
+ theConfig.CrunchRunCommand = []string{crunchCmd}
doneProcessing := make(chan struct{})
dispatcher := dispatch.Dispatcher{
}
func testSbatchFuncWithArgs(c *C, args []string) {
- config.SbatchArguments = append(config.SbatchArguments, args...)
+ theConfig.SbatchArguments = append(theConfig.SbatchArguments, args...)
container := arvados.Container{UUID: "123", RuntimeConstraints: arvados.RuntimeConstraints{RAM: 1000000, VCPUs: 2}}
sbatchCmd := sbatchFunc(container)
var expected []string
expected = append(expected, "sbatch", "--share")
- expected = append(expected, config.SbatchArguments...)
+ expected = append(expected, theConfig.SbatchArguments...)
expected = append(expected, "--job-name=123", "--mem-per-cpu=1", "--cpus-per-task=2")
c.Check(sbatchCmd.Args, DeepEquals, expected)