X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/cc1c83c261d289c7fa049637f8ae1fabe352059c..60542dcecbffe14a43098d9e68ee6ae05868df1e:/lib/dispatchcloud/dispatcher.go diff --git a/lib/dispatchcloud/dispatcher.go b/lib/dispatchcloud/dispatcher.go index e3b4b251de..49be9e68a2 100644 --- a/lib/dispatchcloud/dispatcher.go +++ b/lib/dispatchcloud/dispatcher.go @@ -198,11 +198,10 @@ func (disp *dispatcher) run() { if pollInterval <= 0 { pollInterval = defaultPollInterval } - maxSupervisors := int(float64(disp.Cluster.Containers.CloudVMs.MaxInstances) * disp.Cluster.Containers.CloudVMs.SupervisorFraction) - if maxSupervisors == 0 && disp.Cluster.Containers.CloudVMs.SupervisorFraction > 0 { - maxSupervisors = 1 - } - sched := scheduler.New(disp.Context, disp.ArvClient, disp.queue, disp.pool, disp.Registry, staleLockTimeout, pollInterval, maxSupervisors) + 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()