Skip to content

Commit 67701bb

Browse files
committed
Removing degraded status for tests purpose
1 parent 4ba5bd1 commit 67701bb

File tree

2 files changed

+15
-10
lines changed

2 files changed

+15
-10
lines changed

manifests/07-observability-operator.yaml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,8 @@
1+
apiVersion: v1
2+
kind: Namespace
3+
metadata:
4+
name: openshift-netobserv-operator
5+
---
16
apiVersion: operators.coreos.com/v1
27
kind: OperatorGroup
38
metadata:

pkg/controller/observability/observability_controller.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -109,32 +109,32 @@ func (r *ReconcileObservability) Reconcile(ctx context.Context, req ctrl.Request
109109
// Check if Network Observability should be enabled
110110
shouldInstall, err := r.shouldInstallNetworkObservability(ctx, &network)
111111
if err != nil {
112-
r.status.SetDegraded(statusmanager.ObservabilityConfig, "CheckInstallError", fmt.Sprintf("Failed to determine if Network Observability should be installed: %v", err))
112+
// r.status.SetDegraded(statusmanager.ObservabilityConfig, "CheckInstallError", fmt.Sprintf("Failed to determine if Network Observability should be installed: %v", err))
113113
return ctrl.Result{}, err
114114
}
115115
if !shouldInstall {
116-
r.status.SetNotDegraded(statusmanager.ObservabilityConfig)
116+
// r.status.SetNotDegraded(statusmanager.ObservabilityConfig)
117117
return ctrl.Result{}, nil
118118
}
119119

120120
// Check if Network Observability was previously deployed
121121
// If so, we're done - no need to check or manage anything
122122
if r.wasNetworkObservabilityDeployed(&network) {
123123
klog.Info("Network Observability was previously deployed, skipping reconciliation.")
124-
r.status.SetNotDegraded(statusmanager.ObservabilityConfig)
124+
// r.status.SetNotDegraded(statusmanager.ObservabilityConfig)
125125
return ctrl.Result{}, nil
126126
}
127127

128128
// First time installation - proceed with operator installation
129129
installed, err := r.isNetObservOperatorInstalled(ctx)
130130
if err != nil {
131-
r.status.SetDegraded(statusmanager.ObservabilityConfig, "CheckOperatorError", fmt.Sprintf("Failed to check if Network Observability Operator is installed: %v", err))
131+
// r.status.SetDegraded(statusmanager.ObservabilityConfig, "CheckOperatorError", fmt.Sprintf("Failed to check if Network Observability Operator is installed: %v", err))
132132
return ctrl.Result{}, err
133133
}
134134
if !installed {
135135
// Install Network Observability Operator
136136
if err := r.installNetObservOperator(ctx); err != nil {
137-
r.status.SetDegraded(statusmanager.ObservabilityConfig, "InstallOperatorError", fmt.Sprintf("Failed to install Network Observability Operator: %v", err))
137+
// r.status.SetDegraded(statusmanager.ObservabilityConfig, "InstallOperatorError", fmt.Sprintf("Failed to install Network Observability Operator: %v", err))
138138
return ctrl.Result{}, err
139139
}
140140
}
@@ -144,31 +144,31 @@ func (r *ReconcileObservability) Reconcile(ctx context.Context, req ctrl.Request
144144
if err := r.waitForNetObservOperator(ctx); err != nil {
145145
if err == context.DeadlineExceeded {
146146
klog.Errorf("Timed out waiting for Network Observability Operator to be ready after %v. Will retry in %v.", checkTimeout, requeueAfter)
147-
r.status.SetDegraded(statusmanager.ObservabilityConfig, "OperatorNotReady", fmt.Sprintf("Timed out waiting for Network Observability Operator to be ready after %v", checkTimeout))
147+
// r.status.SetDegraded(statusmanager.ObservabilityConfig, "OperatorNotReady", fmt.Sprintf("Timed out waiting for Network Observability Operator to be ready after %v", checkTimeout))
148148
return ctrl.Result{RequeueAfter: requeueAfter}, nil
149149
}
150-
r.status.SetDegraded(statusmanager.ObservabilityConfig, "WaitOperatorError", fmt.Sprintf("Failed waiting for Network Observability Operator: %v", err))
150+
// r.status.SetDegraded(statusmanager.ObservabilityConfig, "WaitOperatorError", fmt.Sprintf("Failed waiting for Network Observability Operator: %v", err))
151151
return ctrl.Result{}, err
152152
}
153153

154154
// Check if FlowCollector already exists
155155
flowCollectorExists, err := r.isFlowCollectorExists(ctx)
156156
if err != nil {
157-
r.status.SetDegraded(statusmanager.ObservabilityConfig, "CheckFlowCollectorError", fmt.Sprintf("Failed to check if FlowCollector exists: %v", err))
157+
// r.status.SetDegraded(statusmanager.ObservabilityConfig, "CheckFlowCollectorError", fmt.Sprintf("Failed to check if FlowCollector exists: %v", err))
158158
return ctrl.Result{}, err
159159
}
160160

161161
if !flowCollectorExists {
162162
// Create FlowCollector (first time deployment)
163163
if err := r.createFlowCollector(ctx); err != nil {
164-
r.status.SetDegraded(statusmanager.ObservabilityConfig, "CreateFlowCollectorError", fmt.Sprintf("Failed to create FlowCollector: %v", err))
164+
// r.status.SetDegraded(statusmanager.ObservabilityConfig, "CreateFlowCollectorError", fmt.Sprintf("Failed to create FlowCollector: %v", err))
165165
return ctrl.Result{}, err
166166
}
167167
}
168168

169169
// Mark as deployed in Network CR status
170170
if err := r.markNetworkObservabilityDeployed(ctx, &network); err != nil {
171-
r.status.SetDegraded(statusmanager.ObservabilityConfig, "UpdateStatusError", fmt.Sprintf("Failed to update Network Observability deployment status: %v", err))
171+
// r.status.SetDegraded(statusmanager.ObservabilityConfig, "UpdateStatusError", fmt.Sprintf("Failed to update Network Observability deployment status: %v", err))
172172
return ctrl.Result{}, err
173173
}
174174

0 commit comments

Comments
 (0)