projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
13561: Move versioning code inside locking block.
[arvados.git]
/
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 719ec98d27aa19d65eceb7d3db3a46f506aed2f0..b76ece314d47806afcfb328ba12970b9171b58d5 100644
(file)
--- a/
services/crunch-dispatch-slurm/crunch-dispatch-slurm_test.go
+++ b/
services/crunch-dispatch-slurm/crunch-dispatch-slurm_test.go
@@
-11,7
+11,6
@@
import (
"fmt"
"io"
"io/ioutil"
"fmt"
"io"
"io/ioutil"
- "log"
"net/http"
"net/http/httptest"
"os"
"net/http"
"net/http/httptest"
"os"
@@
-25,6
+24,7
@@
import (
"git.curoverse.com/arvados.git/sdk/go/arvadosclient"
"git.curoverse.com/arvados.git/sdk/go/arvadostest"
"git.curoverse.com/arvados.git/sdk/go/dispatch"
"git.curoverse.com/arvados.git/sdk/go/arvadosclient"
"git.curoverse.com/arvados.git/sdk/go/arvadostest"
"git.curoverse.com/arvados.git/sdk/go/dispatch"
+ "github.com/Sirupsen/logrus"
. "gopkg.in/check.v1"
)
. "gopkg.in/check.v1"
)
@@
-116,7
+116,7
@@
func (s *IntegrationSuite) integrationTest(c *C,
var containers arvados.ContainerList
err = arv.List("containers", params, &containers)
c.Check(err, IsNil)
var containers arvados.ContainerList
err = arv.List("containers", params, &containers)
c.Check(err, IsNil)
- c.
Check
(len(containers.Items), Equals, 1)
+ c.
Assert
(len(containers.Items), Equals, 1)
s.disp.CrunchRunCommand = []string{"echo"}
s.disp.CrunchRunCommand = []string{"echo"}
@@
-138,7
+138,11
@@
func (s *IntegrationSuite) integrationTest(c *C,
}
s.disp.slurm = &s.slurm
}
s.disp.slurm = &s.slurm
- s.disp.sqCheck = &SqueueChecker{Period: 500 * time.Millisecond, Slurm: s.disp.slurm}
+ s.disp.sqCheck = &SqueueChecker{
+ Logger: logrus.StandardLogger(),
+ Period: 500 * time.Millisecond,
+ Slurm: s.disp.slurm,
+ }
err = s.disp.Dispatcher.Run(ctx)
<-doneRun
err = s.disp.Dispatcher.Run(ctx)
<-doneRun
@@
-246,7
+250,7
@@
func (s *StubbedSuite) TestAPIErrorGettingContainers(c *C) {
apiStubResponses["/arvados/v1/api_client_authorizations/current"] = arvadostest.StubResponse{200, `{"uuid":"` + arvadostest.Dispatch1AuthUUID + `"}`}
apiStubResponses["/arvados/v1/containers"] = arvadostest.StubResponse{500, string(`{}`)}
apiStubResponses["/arvados/v1/api_client_authorizations/current"] = arvadostest.StubResponse{200, `{"uuid":"` + arvadostest.Dispatch1AuthUUID + `"}`}
apiStubResponses["/arvados/v1/containers"] = arvadostest.StubResponse{500, string(`{}`)}
- s.testWithServerStub(c, apiStubResponses, "echo", "
Error getting lis
t of containers")
+ s.testWithServerStub(c, apiStubResponses, "echo", "
error getting coun
t of containers")
}
func (s *StubbedSuite) testWithServerStub(c *C, apiStubResponses map[string]arvadostest.StubResponse, crunchCmd string, expected string) {
}
func (s *StubbedSuite) testWithServerStub(c *C, apiStubResponses map[string]arvadostest.StubResponse, crunchCmd string, expected string) {
@@
-264,8
+268,8
@@
func (s *StubbedSuite) testWithServerStub(c *C, apiStubResponses map[string]arva
}
buf := bytes.NewBuffer(nil)
}
buf := bytes.NewBuffer(nil)
- log.SetOutput(io.MultiWriter(buf, os.Stderr))
- defer log.SetOutput(os.Stderr)
+ log
rus
.SetOutput(io.MultiWriter(buf, os.Stderr))
+ defer log
rus
.SetOutput(os.Stderr)
s.disp.CrunchRunCommand = []string{crunchCmd}
s.disp.CrunchRunCommand = []string{crunchCmd}