X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/4957ed9549811afa3ec4a3010f333e9046189acd..a73295e64f58fe027b995e0cca3d103d4e2289ff:/lib/dispatchcloud/dispatcher.go diff --git a/lib/dispatchcloud/dispatcher.go b/lib/dispatchcloud/dispatcher.go index 97cbd8edc0..47e60abdee 100644 --- a/lib/dispatchcloud/dispatcher.go +++ b/lib/dispatchcloud/dispatcher.go @@ -111,7 +111,7 @@ func (disp *dispatcher) newExecutor(inst cloud.Instance) worker.Executor { return exr } -func (disp *dispatcher) typeChooser(ctr *arvados.Container) (arvados.InstanceType, error) { +func (disp *dispatcher) typeChooser(ctr *arvados.Container) ([]arvados.InstanceType, error) { return ChooseInstanceType(disp.Cluster, ctr) } @@ -198,7 +198,10 @@ func (disp *dispatcher) run() { if pollInterval <= 0 { pollInterval = defaultPollInterval } - sched := scheduler.New(disp.Context, disp.ArvClient, disp.queue, disp.pool, disp.Registry, staleLockTimeout, pollInterval, disp.Cluster.Containers.CloudVMs.MaxInstances, disp.Cluster.Containers.CloudVMs.SupervisorFraction) + sched := scheduler.New(disp.Context, disp.ArvClient, disp.queue, disp.pool, disp.Registry, staleLockTimeout, pollInterval, + disp.Cluster.Containers.CloudVMs.InitialQuotaEstimate, + disp.Cluster.Containers.CloudVMs.MaxInstances, + disp.Cluster.Containers.CloudVMs.SupervisorFraction) sched.Start() defer sched.Stop()