X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/4447b5a61f79edf2411ba94f4ad5d90e1ca7e220..d33c63515b46bd5d9ad4dc07efc734743b7d530b:/lib/dispatchcloud/dispatcher.go diff --git a/lib/dispatchcloud/dispatcher.go b/lib/dispatchcloud/dispatcher.go index 1f8272afd3..06a558d5fe 100644 --- a/lib/dispatchcloud/dispatcher.go +++ b/lib/dispatchcloud/dispatcher.go @@ -193,7 +193,11 @@ func (disp *dispatcher) run() { if pollInterval <= 0 { pollInterval = defaultPollInterval } - sched := scheduler.New(disp.Context, disp.ArvClient, disp.queue, disp.pool, disp.Registry, staleLockTimeout, pollInterval, int(float64(disp.Cluster.Containers.CloudVMs.MaxInstances)*disp.Cluster.Containers.SupervisorFraction)) + 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.Start() defer sched.Stop()