X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/17f4a03d71d8d6130f796d61fa49b8480bf555b6..e99f026d040c6020dfcc51c6d988cf18d325a530:/sdk/go/dispatch/dispatch_test.go diff --git a/sdk/go/dispatch/dispatch_test.go b/sdk/go/dispatch/dispatch_test.go index 08ce512dea..4b115229b4 100644 --- a/sdk/go/dispatch/dispatch_test.go +++ b/sdk/go/dispatch/dispatch_test.go @@ -1,11 +1,15 @@ +// Copyright (C) The Arvados Authors. All rights reserved. +// +// SPDX-License-Identifier: Apache-2.0 + package dispatch import ( "time" - "git.curoverse.com/arvados.git/sdk/go/arvados" - "git.curoverse.com/arvados.git/sdk/go/arvadosclient" - "git.curoverse.com/arvados.git/sdk/go/arvadostest" + "git.arvados.org/arvados.git/sdk/go/arvados" + "git.arvados.org/arvados.git/sdk/go/arvadosclient" + "git.arvados.org/arvados.git/sdk/go/arvadostest" . "gopkg.in/check.v1" ) @@ -31,11 +35,12 @@ func (s *suite) TestTrackContainer(c *C) { 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 + return nil }, } d.TrackContainer(arvadostest.QueuedContainerUUID)