X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/115cbd6482632c47fdcbbbe4abc9543e7e8e30ec..1d5727fcdd6e524898d7507417456b9fedcb79dd:/lib/dispatchcloud/cmd.go diff --git a/lib/dispatchcloud/cmd.go b/lib/dispatchcloud/cmd.go index 82205c7426..ae6ac70e96 100644 --- a/lib/dispatchcloud/cmd.go +++ b/lib/dispatchcloud/cmd.go @@ -6,6 +6,7 @@ package dispatchcloud import ( "context" + "fmt" "git.curoverse.com/arvados.git/lib/cmd" "git.curoverse.com/arvados.git/lib/service" @@ -14,11 +15,16 @@ import ( var Command cmd.Handler = service.Command(arvados.ServiceNameDispatchCloud, newHandler) -func newHandler(ctx context.Context, cluster *arvados.Cluster, _ *arvados.NodeProfile) service.Handler { +func newHandler(ctx context.Context, cluster *arvados.Cluster, token string) service.Handler { + ac, err := arvados.NewClientFromConfig(cluster) + if err != nil { + return service.ErrorHandler(ctx, cluster, fmt.Errorf("error initializing client from cluster config: %s", err)) + } d := &dispatcher{ Cluster: cluster, Context: ctx, - AuthToken: service.Token(ctx), + ArvClient: ac, + AuthToken: token, } go d.Start() return d