newExecutor := func(cloud.Instance) Executor {
return &stubExecutor{
response: map[string]stubResp{
- "crunch-run --list": {},
- "true": {},
+ "crunch-run-custom --list": {},
+ "true": {},
},
}
}
SyncInterval: arvados.Duration(time.Millisecond * 10),
TagKeyPrefix: "testprefix:",
},
+ CrunchRunCommand: "crunch-run-custom",
},
InstanceTypes: arvados.InstanceTypeMap{
type1.Name: type1,
c.Check(pool.Unallocated()[type1], check.Equals, 1)
c.Check(res, check.Equals, false)
- pool.instanceSet.throttleCreate.ResetError()
+ pool.instanceSet.throttleCreate.err = nil
pool.maxConcurrentInstanceCreateOps = 2
res = pool.Create(type1)
c.Check(pool.Unallocated()[type1], check.Equals, 2)
c.Check(res, check.Equals, true)
- pool.instanceSet.throttleCreate.ResetError()
+ pool.instanceSet.throttleCreate.err = nil
pool.maxConcurrentInstanceCreateOps = 0
res = pool.Create(type1)