c.Assert(err, check.IsNil)
cluster, err := cfg.GetCluster("")
c.Assert(err, check.IsNil)
+ cluster.Containers.ReserveExtraRAM = 256 << 20
cluster.Containers.CloudVMs.PollInterval = arvados.Duration(time.Second / 4)
cluster.Containers.MinRetryPeriod = arvados.Duration(time.Second / 4)
cluster.InstanceTypes = arvados.InstanceTypeMap{
err = arvados.NewClientFromEnv().RequestAndDecode(&s.crPending, "POST", "arvados/v1/container_requests", nil, map[string]interface{}{
"container_request": map[string]interface{}{
"runtime_constraints": arvados.RuntimeConstraints{
- RAM: 100000000,
- VCPUs: 2,
+ RAM: 100000000,
+ VCPUs: 2,
+ KeepCacheDisk: 8 << 30,
},
"container_image": arvadostest.DockerImage112PDH,
"command": []string{"sleep", "1"},
c.Check(args, check.DeepEquals, []string{
"-J", s.crPending.ContainerUUID,
"-n", "2",
- "-D", "608MB",
- "-R", "rusage[mem=608MB:tmp=256MB] span[hosts=1]",
- "-R", "select[mem>=608MB]",
- "-R", "select[tmp>=256MB]",
+ "-D", "352MB",
+ "-R", "rusage[mem=352MB:tmp=8448MB] span[hosts=1]",
+ "-R", "select[mem>=352MB]",
+ "-R", "select[tmp>=8448MB]",
"-R", "select[ncpus>=2]"})
mtx.Lock()
fakejobq[nextjobid] = args[1]