m.activePods = activePods
	m.sourcesReady = sourcesReady
	go wait.Until(func() { m.reconcileLoop() }, m.reconcilePeriod, wait.NeverStop)
	return nil
}

// reconcileLoop ensures that any stale state in the manager's claimInfoCache gets periodically reconciled.
func (m *ManagerImpl) reconcileLoop() {
	// Only once all sources are ready do we attempt to reconcile.