18842: Fix test for default disk cache

[arvados.git] / lib / lsf / lsfqueue.go

diff --git a/lib/lsf/lsfqueue.go b/lib/lsf/lsfqueue.go
index 3ed4d0c1820cfaad1340c1304902a7deabd0fcb7..60f01640a0fcab807f3f1a487558179f090de7e2 100644 (file)
--- 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