Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 0 additions & 4 deletions pkg/cvo/reconciliation_issues.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,10 +10,6 @@ import (
"github.com/openshift/cluster-version-operator/pkg/payload"
)

const (
reconciliationIssuesConditionType configv1.ClusterStatusConditionType = "ReconciliationIssues"
)

// errorWalkCallback processes an error. It returns an error to fail the walk.
type errorWalkCallback func(err error, depth int) error

Expand Down
6 changes: 0 additions & 6 deletions pkg/cvo/status.go
Original file line number Diff line number Diff line change
Expand Up @@ -411,12 +411,6 @@ func updateClusterVersionStatus(cvStatus *configv1.ClusterVersionStatus, status
}
}

// Pre-GA 4.20 TechPreview clusters may have this condition and we need to remove it if it exists when updated to this version
// TODO: Remove this code in 4.21
if oldRiCondition := resourcemerge.FindOperatorStatusCondition(cvStatus.Conditions, reconciliationIssuesConditionType); oldRiCondition != nil {
resourcemerge.RemoveOperatorStatusCondition(&cvStatus.Conditions, reconciliationIssuesConditionType)
}

// default retrieved updates if it is not set
if resourcemerge.FindOperatorStatusCondition(cvStatus.Conditions, configv1.RetrievedUpdates) == nil {
resourcemerge.SetOperatorStatusCondition(&cvStatus.Conditions, configv1.ClusterOperatorStatusCondition{
Expand Down
59 changes: 0 additions & 59 deletions pkg/cvo/status_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -217,65 +217,6 @@ func (f fakeRiFlags) CVOConfiguration() bool {
return f.cvoConfiguration
}

// TODO: Can be removed in 4.21
func TestUpdateClusterVersionStatus_AlwaysRemove_ReconciliationIssues(t *testing.T) {
testCases := []struct {
name string

unknownVersion bool
oldCondition *configv1.ClusterOperatorStatusCondition
failure error
}{
{
name: "version known, no failure => condition not present",
unknownVersion: false,
},
{
name: "version known, failure => condition not present",
unknownVersion: false,
failure: fmt.Errorf("something happened"),
},
{
name: "version unknown, failure, existing condition => condition present",
oldCondition: &configv1.ClusterOperatorStatusCondition{
Type: reconciliationIssuesConditionType,
Status: configv1.ConditionFalse,
Reason: "noReconciliationIssuesReason",
Message: "Happy condition is happy",
},
unknownVersion: true,
failure: fmt.Errorf("something happened"),
},
{
name: "version unknown, failure, no existing condition => condition not present",
unknownVersion: true,
failure: fmt.Errorf("something happened"),
},
}
for _, tc := range testCases {
tc := tc
t.Run(tc.name, func(t *testing.T) {
gates := fakeRiFlags{
unknownVersion: tc.unknownVersion,
}
release := configv1.Release{}
getAvailableUpdates := func() *availableUpdates { return nil }
var noErrors field.ErrorList
cvStatus := configv1.ClusterVersionStatus{}
if tc.oldCondition != nil {
cvStatus.Conditions = append(cvStatus.Conditions, *tc.oldCondition)
}
updateClusterVersionStatus(&cvStatus, &SyncWorkerStatus{Failure: tc.failure}, release, getAvailableUpdates, gates, noErrors)
condition := resourcemerge.FindOperatorStatusCondition(cvStatus.Conditions, reconciliationIssuesConditionType)
if condition != nil {
t.Errorf("expected condition %s to not be present, but it was: %v", reconciliationIssuesConditionType, condition)
}
})

}

}

func TestUpdateClusterVersionStatus_FilteringMultipleErrorsForFailingCondition(t *testing.T) {
ignoreLastTransitionTime := cmpopts.IgnoreFields(configv1.ClusterOperatorStatusCondition{}, "LastTransitionTime")
type args struct {
Expand Down