X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/4eb591b3d541cc5ac035fb0eed7c39dc8e81dd02..03c01a2340c42fbd9098f248c609f611f361c3a6:/lib/dispatchcloud/dispatcher.go diff --git a/lib/dispatchcloud/dispatcher.go b/lib/dispatchcloud/dispatcher.go index 06a558d5fe..e982736ff0 100644 --- a/lib/dispatchcloud/dispatcher.go +++ b/lib/dispatchcloud/dispatcher.go @@ -142,6 +142,10 @@ func (disp *dispatcher) initialize() { } else { disp.sshKey = key } + installPublicKey := disp.sshKey.PublicKey() + if !disp.Cluster.Containers.CloudVMs.DeployPublicKey { + installPublicKey = nil + } instanceSet, err := newInstanceSet(disp.Cluster, disp.InstanceSetID, disp.logger, disp.Registry) if err != nil { @@ -149,7 +153,7 @@ func (disp *dispatcher) initialize() { } dblock.Dispatch.Lock(disp.Context, disp.dbConnector.GetDB) disp.instanceSet = instanceSet - disp.pool = worker.NewPool(disp.logger, disp.ArvClient, disp.Registry, disp.InstanceSetID, disp.instanceSet, disp.newExecutor, disp.sshKey.PublicKey(), disp.Cluster) + disp.pool = worker.NewPool(disp.logger, disp.ArvClient, disp.Registry, disp.InstanceSetID, disp.instanceSet, disp.newExecutor, installPublicKey, disp.Cluster) disp.queue = container.NewQueue(disp.logger, disp.Registry, disp.typeChooser, disp.ArvClient) if disp.Cluster.ManagementToken == "" {