X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/efc1846a758929bdb57b87bdbb3f757f8907c69b..5d56a1af42f64df57ef7a1bcef6d016ff2310900:/services/crunch-dispatch-local/crunch-dispatch-local_test.go diff --git a/services/crunch-dispatch-local/crunch-dispatch-local_test.go b/services/crunch-dispatch-local/crunch-dispatch-local_test.go index 6ec31b1737..92b8d2adcd 100644 --- a/services/crunch-dispatch-local/crunch-dispatch-local_test.go +++ b/services/crunch-dispatch-local/crunch-dispatch-local_test.go @@ -81,9 +81,11 @@ func (s *TestSuite) TestIntegration(c *C) { return cmd.Start() } + cl := arvados.Cluster{Containers: arvados.ContainersConfig{RuntimeEngine: "docker"}} + dispatcher.RunContainer = func(d *dispatch.Dispatcher, c arvados.Container, s <-chan arvados.Container) error { defer cancel() - return (&LocalRun{startCmd, make(chan bool, 8), ctx}).run(d, c, s) + return (&LocalRun{startCmd, make(chan bool, 8), ctx, &cl}).run(d, c, s) } err = dispatcher.Run(ctx) @@ -184,9 +186,11 @@ func testWithServerStub(c *C, apiStubResponses map[string]arvadostest.StubRespon return cmd.Start() } + cl := arvados.Cluster{Containers: arvados.ContainersConfig{RuntimeEngine: "docker"}} + dispatcher.RunContainer = func(d *dispatch.Dispatcher, c arvados.Container, s <-chan arvados.Container) error { defer cancel() - return (&LocalRun{startCmd, make(chan bool, 8), ctx}).run(d, c, s) + return (&LocalRun{startCmd, make(chan bool, 8), ctx, &cl}).run(d, c, s) } re := regexp.MustCompile(`(?ms).*` + expected + `.*`)