X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/139200027a3192260b5ea7c2d0c93a8eb5f8eb7e..36288f952d89249e7b52c714b0df0e4d0a4b0305:/services/crunch-dispatch-local/crunch-dispatch-local.go diff --git a/services/crunch-dispatch-local/crunch-dispatch-local.go b/services/crunch-dispatch-local/crunch-dispatch-local.go index 73a3895336..936a9088ed 100644 --- a/services/crunch-dispatch-local/crunch-dispatch-local.go +++ b/services/crunch-dispatch-local/crunch-dispatch-local.go @@ -4,6 +4,7 @@ package main import ( "flag" + "git.curoverse.com/arvados.git/sdk/go/arvados" "git.curoverse.com/arvados.git/sdk/go/arvadosclient" "git.curoverse.com/arvados.git/sdk/go/dispatch" "log" @@ -76,7 +77,7 @@ func doMain() error { return nil } -func startFunc(container dispatch.Container, cmd *exec.Cmd) error { +func startFunc(container arvados.Container, cmd *exec.Cmd) error { return cmd.Start() } @@ -91,8 +92,8 @@ var startCmd = startFunc // If the container is in any other state, or is not Complete/Cancelled after // crunch-run terminates, mark the container as Cancelled. func run(dispatcher *dispatch.Dispatcher, - container dispatch.Container, - status chan dispatch.Container) { + container arvados.Container, + status chan arvados.Container) { uuid := container.UUID