diff --git a/pkg/manager/manager.go b/pkg/manager/manager.go index 28c676c26..f6d8dc68e 100644 --- a/pkg/manager/manager.go +++ b/pkg/manager/manager.go @@ -86,13 +86,13 @@ func (rm *Manager) RunUntil(stopCh <-chan struct{}) { for { select { - case startTime := <-ticker.C: - rm.Collect(startTime) - case <-stopCh: - return + case startTime := <-ticker.C: + rm.Collect(startTime) + case <-stopCh: + return } - } - }() + } + }() } func (rm *Manager) Collect(startTime time.Time) {