X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/9c983060b6f0fc6dc42310587b9858b7f8b968de..98d6c8c5743e0fd6be85af3b9f30286a358bd1d4:/services/crunch-dispatch-slurm/crunch-dispatch-slurm_test.go diff --git a/services/crunch-dispatch-slurm/crunch-dispatch-slurm_test.go b/services/crunch-dispatch-slurm/crunch-dispatch-slurm_test.go index 6852fc4be8..4211026a67 100644 --- a/services/crunch-dispatch-slurm/crunch-dispatch-slurm_test.go +++ b/services/crunch-dispatch-slurm/crunch-dispatch-slurm_test.go @@ -55,10 +55,11 @@ func (s *IntegrationSuite) TearDownTest(c *C) { } type slurmFake struct { - didBatch [][]string - didCancel []string - didRenice [][]string - queue string + didBatch [][]string + didCancel []string + didRelease []string + didRenice [][]string + queue string // If non-nil, run this func during the 2nd+ call to Cancel() onCancel func() // Error returned by Batch() @@ -74,6 +75,11 @@ func (sf *slurmFake) QueueCommand(args []string) *exec.Cmd { return exec.Command("echo", sf.queue) } +func (sf *slurmFake) Release(name string) error { + sf.didRelease = append(sf.didRelease, name) + return nil +} + func (sf *slurmFake) Renice(name string, nice int64) error { sf.didRenice = append(sf.didRenice, []string{name, fmt.Sprintf("%d", nice)}) return nil @@ -151,7 +157,7 @@ func (s *IntegrationSuite) integrationTest(c *C, } func (s *IntegrationSuite) TestNormal(c *C) { - s.slurm = slurmFake{queue: "zzzzz-dz642-queuedcontainer 10000 100\n"} + s.slurm = slurmFake{queue: "zzzzz-dz642-queuedcontainer 10000 100 PENDING Resources\n"} container := s.integrationTest(c, nil, func(dispatcher *dispatch.Dispatcher, container arvados.Container) { @@ -163,7 +169,7 @@ func (s *IntegrationSuite) TestNormal(c *C) { } func (s *IntegrationSuite) TestCancel(c *C) { - s.slurm = slurmFake{queue: "zzzzz-dz642-queuedcontainer 10000 100\n"} + s.slurm = slurmFake{queue: "zzzzz-dz642-queuedcontainer 10000 100 PENDING Resources\n"} readyToCancel := make(chan bool) s.slurm.onCancel = func() { <-readyToCancel } container := s.integrationTest(c,