X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/f608029e1aec903bc35a4748ef51e6f076dae0aa..8881d33b836850edbb8c874782d1243e952632bb:/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