10979: fix failing test
authorradhika <radhika@curoverse.com>
Fri, 24 Feb 2017 18:16:31 +0000 (13:16 -0500)
committerradhika <radhika@curoverse.com>
Fri, 24 Feb 2017 18:16:31 +0000 (13:16 -0500)
sdk/go/dispatch/dispatch.go
sdk/go/dispatch/dispatch_test.go

index 94134950d2b7b5d81eb659226bf01c560e751463..49c756e892f232e26c9fffa74feeffed46400309 100644 (file)
@@ -224,7 +224,7 @@ func (d *Dispatcher) TrackContainer(uuid string) {
                return
        }
 
-       d.trackers[uuid] = d.start(c)
+       d.trackers[uuid] = d.start(cntr)
 }
 
 type runTracker struct {
index fb827fcee2a8061720434a8c834f38eaa6962aba..57b6126738c15dc96b72dde225ca4d6ae3d51f51 100644 (file)
@@ -1,8 +1,10 @@
 package dispatch
 
 import (
+       "git.curoverse.com/arvados.git/sdk/go/arvados"
        "git.curoverse.com/arvados.git/sdk/go/arvadosclient"
        "git.curoverse.com/arvados.git/sdk/go/arvadostest"
+       "os/exec"
 
        . "gopkg.in/check.v1"
 )
@@ -24,7 +26,10 @@ func (s *DispatchTestSuite) TestTrackContainer(c *C) {
        arv, err := arvadosclient.MakeArvadosClient()
        c.Assert(err, Equals, nil)
 
-       d := &Dispatcher{Arv: arv}
+       runContainer := func(d *Dispatcher, ctr arvados.Container) *exec.Cmd { return exec.Command("echo") }
+       d := &Dispatcher{Arv: arv, RunContainer: func(dsp *Dispatcher, ctr arvados.Container, status <-chan arvados.Container) {
+               go runContainer(dsp, ctr)
+       }}
        d.trackers = make(map[string]*runTracker)
 
        d.TrackContainer(arvadostest.QueuedContainerUuid)