X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/f6e8d7c2cada1570bac3e98f0712ad8651b8d9fd..b5c15775caf865d8fed5d4839d4a082f6518bba4:/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