X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/e231fef37079916d0dc6babf93d669d474598ced..15c688d1c4b41232536d0a275dd5c0fdb8879a00:/lib/dispatchcloud/cmd.go diff --git a/lib/dispatchcloud/cmd.go b/lib/dispatchcloud/cmd.go index 7231e83947..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,8 +15,17 @@ import ( var Command cmd.Handler = service.Command(arvados.ServiceNameDispatchCloud, newHandler) -func newHandler(ctx context.Context, cluster *arvados.Cluster, _ *arvados.NodeProfile) service.Handler { - d := &dispatcher{Cluster: cluster, Context: ctx} +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, + ArvClient: ac, + AuthToken: token, + } go d.Start() return d }