diff --git a/task/manager.go b/task/manager.go index 4f6398fcc..cf2fcd354 100644 --- a/task/manager.go +++ b/task/manager.go @@ -105,6 +105,10 @@ func (m *Manager) Run(ctx context.Context) { &Validator{ Client: m.Client, }) + err := m.cluster.Refresh() + if err != nil { + Log.Error(err, "unable to refresh cluster") + } go func() { Log.Info("Started.") defer Log.Info("Done.") @@ -113,16 +117,14 @@ func (m *Manager) Run(ctx context.Context) { case <-ctx.Done(): return default: - err := m.cluster.Refresh() - if err == nil { - m.runActions() - m.updateRunning() - m.startReady() - m.pause() - } else { - Log.Error(err, "") - m.pause() - } + m.runActions() + m.updateRunning() + m.startReady() + m.pause() + // } else { + // Log.Error(err, "") + // m.pause() + // } } } }()