-
- d := &Dispatcher{Arv: arv}
- d.trackers = make(map[string]*runTracker)
-
- d.TrackContainer(arvadostest.QueuedContainerUuid)
- _, tracking := d.trackers[arvadostest.QueuedContainerUuid]
- c.Assert(tracking, Equals, true)
+ arv.ApiToken = arvadostest.Dispatch1Token
+
+ done := make(chan bool, 1)
+ time.AfterFunc(10*time.Second, func() { done <- false })
+ d := &Dispatcher{
+ Arv: arv,
+ RunContainer: func(dsp *Dispatcher, ctr arvados.Container, status <-chan arvados.Container) {
+ for ctr := range status {
+ c.Logf("%#v", ctr)
+ }
+ done <- true
+ },
+ }
+ d.TrackContainer(arvadostest.QueuedContainerUUID)
+ c.Assert(<-done, Equals, true)