1 // Copyright (C) The Arvados Authors. All rights reserved.
3 // SPDX-License-Identifier: AGPL-3.0
8 "git.arvados.org/arvados.git/sdk/go/arvados"
9 check "gopkg.in/check.v1"
12 var _ = check.Suite(&NodeSizeSuite{})
14 const GiB = arvados.ByteSize(1 << 30)
16 type NodeSizeSuite struct{}
18 func (*NodeSizeSuite) TestChooseNotConfigured(c *check.C) {
19 _, err := ChooseInstanceType(&arvados.Cluster{}, &arvados.Container{
20 RuntimeConstraints: arvados.RuntimeConstraints{
25 c.Check(err, check.Equals, ErrInstanceTypesNotConfigured)
28 func (*NodeSizeSuite) TestChooseUnsatisfiable(c *check.C) {
29 checkUnsatisfiable := func(ctr *arvados.Container) {
30 _, err := ChooseInstanceType(&arvados.Cluster{InstanceTypes: map[string]arvados.InstanceType{
31 "small1": {Price: 1.1, RAM: 1000000000, VCPUs: 2, Name: "small1"},
32 "small2": {Price: 2.2, RAM: 2000000000, VCPUs: 4, Name: "small2"},
33 "small4": {Price: 4.4, RAM: 4000000000, VCPUs: 8, Name: "small4", Scratch: GiB},
35 c.Check(err, check.FitsTypeOf, ConstraintsNotSatisfiableError{})
38 for _, rc := range []arvados.RuntimeConstraints{
39 {RAM: 9876543210, VCPUs: 2},
40 {RAM: 1234567890, VCPUs: 20},
41 {RAM: 1234567890, VCPUs: 2, KeepCacheRAM: 9876543210},
43 checkUnsatisfiable(&arvados.Container{RuntimeConstraints: rc})
45 checkUnsatisfiable(&arvados.Container{
46 Mounts: map[string]arvados.Mount{"/tmp": {Kind: "tmp", Capacity: int64(2 * GiB)}},
47 RuntimeConstraints: arvados.RuntimeConstraints{RAM: 12345, VCPUs: 1},
51 func (*NodeSizeSuite) TestChoose(c *check.C) {
52 for _, menu := range []map[string]arvados.InstanceType{
54 "costly": {Price: 4.4, RAM: 4000000000, VCPUs: 8, Scratch: 2 * GiB, Name: "costly"},
55 "best": {Price: 2.2, RAM: 2000000000, VCPUs: 4, Scratch: 2 * GiB, Name: "best"},
56 "small": {Price: 1.1, RAM: 1000000000, VCPUs: 2, Scratch: 2 * GiB, Name: "small"},
59 "costly": {Price: 4.4, RAM: 4000000000, VCPUs: 8, Scratch: 2 * GiB, Name: "costly"},
60 "goodenough": {Price: 2.2, RAM: 2000000000, VCPUs: 4, Scratch: 2 * GiB, Name: "goodenough"},
61 "best": {Price: 2.2, RAM: 4000000000, VCPUs: 4, Scratch: 2 * GiB, Name: "best"},
62 "small": {Price: 1.1, RAM: 1000000000, VCPUs: 2, Scratch: 2 * GiB, Name: "small"},
65 "small": {Price: 1.1, RAM: 1000000000, VCPUs: 2, Scratch: 2 * GiB, Name: "small"},
66 "goodenough": {Price: 2.2, RAM: 2000000000, VCPUs: 4, Scratch: 2 * GiB, Name: "goodenough"},
67 "best": {Price: 2.2, RAM: 4000000000, VCPUs: 4, Scratch: 2 * GiB, Name: "best"},
68 "costly": {Price: 4.4, RAM: 4000000000, VCPUs: 8, Scratch: 2 * GiB, Name: "costly"},
71 "small": {Price: 1.1, RAM: 1000000000, VCPUs: 2, Scratch: GiB, Name: "small"},
72 "nearly": {Price: 2.2, RAM: 2000000000, VCPUs: 4, Scratch: GiB, Name: "nearly"},
73 "best": {Price: 3.3, RAM: 4000000000, VCPUs: 4, Scratch: 2 * GiB, Name: "best"},
74 "costly": {Price: 4.4, RAM: 4000000000, VCPUs: 8, Scratch: 2 * GiB, Name: "costly"},
77 "small": {Price: 1.1, RAM: 1000000000, VCPUs: 2, Scratch: GiB, Name: "small"},
78 "nearly": {Price: 2.2, RAM: 1200000000, VCPUs: 4, Scratch: 2 * GiB, Name: "nearly"},
79 "best": {Price: 3.3, RAM: 4000000000, VCPUs: 4, Scratch: 2 * GiB, Name: "best"},
80 "costly": {Price: 4.4, RAM: 4000000000, VCPUs: 8, Scratch: 2 * GiB, Name: "costly"},
83 best, err := ChooseInstanceType(&arvados.Cluster{InstanceTypes: menu, Containers: arvados.ContainersConfig{ReserveExtraRAM: 268435456}}, &arvados.Container{
84 Mounts: map[string]arvados.Mount{
85 "/tmp": {Kind: "tmp", Capacity: 2 * int64(GiB)},
87 RuntimeConstraints: arvados.RuntimeConstraints{
90 KeepCacheRAM: 123456789,
93 c.Check(err, check.IsNil)
94 c.Check(best.Name, check.Equals, "best")
95 c.Check(best.RAM >= 1234567890, check.Equals, true)
96 c.Check(best.VCPUs >= 2, check.Equals, true)
97 c.Check(best.Scratch >= 2*GiB, check.Equals, true)
101 func (*NodeSizeSuite) TestChoosePreemptable(c *check.C) {
102 menu := map[string]arvados.InstanceType{
103 "costly": {Price: 4.4, RAM: 4000000000, VCPUs: 8, Scratch: 2 * GiB, Preemptible: true, Name: "costly"},
104 "almost best": {Price: 2.2, RAM: 2000000000, VCPUs: 4, Scratch: 2 * GiB, Name: "almost best"},
105 "best": {Price: 2.2, RAM: 2000000000, VCPUs: 4, Scratch: 2 * GiB, Preemptible: true, Name: "best"},
106 "small": {Price: 1.1, RAM: 1000000000, VCPUs: 2, Scratch: 2 * GiB, Preemptible: true, Name: "small"},
108 best, err := ChooseInstanceType(&arvados.Cluster{InstanceTypes: menu}, &arvados.Container{
109 Mounts: map[string]arvados.Mount{
110 "/tmp": {Kind: "tmp", Capacity: 2 * int64(GiB)},
112 RuntimeConstraints: arvados.RuntimeConstraints{
115 KeepCacheRAM: 123456789,
117 SchedulingParameters: arvados.SchedulingParameters{
121 c.Check(err, check.IsNil)
122 c.Check(best.Name, check.Equals, "best")
123 c.Check(best.RAM >= 1234567890, check.Equals, true)
124 c.Check(best.VCPUs >= 2, check.Equals, true)
125 c.Check(best.Scratch >= 2*GiB, check.Equals, true)
126 c.Check(best.Preemptible, check.Equals, true)
129 func (*NodeSizeSuite) TestScratchForDockerImage(c *check.C) {
130 n := EstimateScratchSpace(&arvados.Container{
131 ContainerImage: "d5025c0f29f6eef304a7358afa82a822+342",
133 // Actual image is 371.1 MiB (according to workbench)
134 // Estimated size is 384 MiB (402653184 bytes)
135 // Want to reserve 2x the estimated size, so 805306368 bytes
136 c.Check(n, check.Equals, int64(805306368))
138 n = EstimateScratchSpace(&arvados.Container{
139 ContainerImage: "d5025c0f29f6eef304a7358afa82a822+-342",
141 // Parse error will return 0
142 c.Check(n, check.Equals, int64(0))
144 n = EstimateScratchSpace(&arvados.Container{
145 ContainerImage: "d5025c0f29f6eef304a7358afa82a822+34",
147 // Short manifest will return 0
148 c.Check(n, check.Equals, int64(0))