projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
18858: Adds sync-users package building.
[arvados.git]
/
sdk
/
go
/
dispatch
/
dispatch_test.go
diff --git
a/sdk/go/dispatch/dispatch_test.go
b/sdk/go/dispatch/dispatch_test.go
index 25a4d2b87902531b913cc2203c8439a748469753..2a9d84639ef8ce1e4d9a987acdafdb947cafa961 100644
(file)
--- a/
sdk/go/dispatch/dispatch_test.go
+++ b/
sdk/go/dispatch/dispatch_test.go
@@
-18,14
+18,6
@@
var _ = Suite(&suite{})
type suite struct{}
type suite struct{}
-func (s *suite) SetUpSuite(c *C) {
- arvadostest.StartAPI()
-}
-
-func (s *suite) TearDownSuite(c *C) {
- arvadostest.StopAPI()
-}
-
func (s *suite) TestTrackContainer(c *C) {
arv, err := arvadosclient.MakeArvadosClient()
c.Assert(err, Equals, nil)
func (s *suite) TestTrackContainer(c *C) {
arv, err := arvadosclient.MakeArvadosClient()
c.Assert(err, Equals, nil)
@@
-35,11
+27,12
@@
func (s *suite) TestTrackContainer(c *C) {
time.AfterFunc(10*time.Second, func() { done <- false })
d := &Dispatcher{
Arv: arv,
time.AfterFunc(10*time.Second, func() { done <- false })
d := &Dispatcher{
Arv: arv,
- RunContainer: func(dsp *Dispatcher, ctr arvados.Container, status <-chan arvados.Container) {
+ RunContainer: func(dsp *Dispatcher, ctr arvados.Container, status <-chan arvados.Container)
error
{
for ctr := range status {
c.Logf("%#v", ctr)
}
done <- true
for ctr := range status {
c.Logf("%#v", ctr)
}
done <- true
+ return nil
},
}
d.TrackContainer(arvadostest.QueuedContainerUUID)
},
}
d.TrackContainer(arvadostest.QueuedContainerUUID)