Skip to content

Commit c799a51

Browse files
author
Jeff Peeler
committed
fix(clusteroperator): update status after initial creation
1 parent ba9049b commit c799a51

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

pkg/lib/operatorstatus/status.go

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ import (
1414
k8serrors "k8s.io/apimachinery/pkg/api/errors"
1515
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1616
"k8s.io/apimachinery/pkg/runtime/schema"
17+
"k8s.io/apimachinery/pkg/util/diff"
1718
"k8s.io/apimachinery/pkg/util/wait"
1819
"k8s.io/client-go/discovery"
1920

@@ -202,6 +203,16 @@ func MonitorClusterStatus(name string, syncCh <-chan error, stopCh <-chan struct
202203
// TODO: use % errors within a window to report available
203204
}
204205

206+
// always update the related objects in case changes have occurred
207+
existing.Status.RelatedObjects, err = relatedObjects(name, opClient, crClient)
208+
if err != nil {
209+
log.Errorf("Failed to get related objects: %v", err)
210+
}
211+
if !reflect.DeepEqual(previousStatus.RelatedObjects, existing.Status.RelatedObjects) {
212+
diffString := diff.ObjectDiff(previousStatus.RelatedObjects, existing.Status.RelatedObjects)
213+
log.Debugf("Update required for related objects: %v", diffString)
214+
}
215+
205216
// update the status
206217
if !reflect.DeepEqual(previousStatus, &existing.Status) {
207218
if _, err := configClient.ClusterOperators().UpdateStatus(existing); err != nil {

0 commit comments

Comments
 (0)