Skip to content

Commit 0422b14

Browse files
committed
feat(catalog): check catalog health and recreate if bad
1 parent 9094cc0 commit 0422b14

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

pkg/controller/operators/catalog/operator.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -435,8 +435,13 @@ func (o *Operator) syncCatalogSources(obj interface{}) (syncError error) {
435435
return fmt.Errorf("no reconciler for source type %s", catsrc.Spec.SourceType)
436436
}
437437

438+
healthy, err := reconciler.CheckRegistryServer(catsrc)
439+
if err != nil {
440+
return err
441+
}
442+
438443
// If registry pod hasn't been created or hasn't been updated since the last configmap update, recreate it
439-
if catsrc.Status.RegistryServiceStatus == nil || catsrc.Status.RegistryServiceStatus.CreatedAt.Before(&catsrc.Status.LastSync) {
444+
if !healthy || catsrc.Status.RegistryServiceStatus == nil || catsrc.Status.RegistryServiceStatus.CreatedAt.Before(&catsrc.Status.LastSync) {
440445
logger.Debug("ensuring registry server")
441446

442447
if err := reconciler.EnsureRegistryServer(out); err != nil {

0 commit comments

Comments
 (0)