X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/927524f1be454de021180b74999d682780b8cb6b..89573e33f317da0633acce7b4160435e20318ca7:/lib/lsf/lsfqueue.go diff --git a/lib/lsf/lsfqueue.go b/lib/lsf/lsfqueue.go index 3ed4d0c182..60f01640a0 100644 --- a/lib/lsf/lsfqueue.go +++ b/lib/lsf/lsfqueue.go @@ -58,7 +58,7 @@ func (q *lsfqueue) getNext() map[string]bjobsEntry { func (q *lsfqueue) init() { q.updated = sync.NewCond(&q.mutex) q.nextReady = make(chan (<-chan struct{})) - ticker := time.NewTicker(time.Second) + ticker := time.NewTicker(q.period) go func() { for range ticker.C { // Send a new "next update ready" channel to