X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/ae5eb12d3d9ab298a4c36412b4a4d83272574d25..1bba7f8fb361186ad040b521d168a73abd8fdd65:/sdk/go/dispatch/dispatch.go diff --git a/sdk/go/dispatch/dispatch.go b/sdk/go/dispatch/dispatch.go index 171ce60d38..ce960c0772 100644 --- a/sdk/go/dispatch/dispatch.go +++ b/sdk/go/dispatch/dispatch.go @@ -39,7 +39,7 @@ type Dispatcher struct { RunContainer func(*Dispatcher, arvados.Container, chan arvados.Container) // Amount of time to wait between polling for updates. - PollInterval time.Duration + PollPeriod time.Duration // Minimum time between two attempts to run the same container MinRetryPeriod time.Duration @@ -115,7 +115,7 @@ func (dispatcher *Dispatcher) getContainers(params arvadosclient.Dict, touched m } func (dispatcher *Dispatcher) pollContainers(stop chan struct{}) { - ticker := time.NewTicker(dispatcher.PollInterval) + ticker := time.NewTicker(dispatcher.PollPeriod) defer ticker.Stop() paramsQ := arvadosclient.Dict{