@@ -207,10 +207,10 @@ func (r *RecoverStaleVolumeReconciler) Reconcile(ctx context.Context, req ctrl.R
207
207
reqLogger .Info ("node-names maped with volumes and deployment pods" , "nodeVolumeMap" , nodeVolumePodMapping )
208
208
209
209
// Get Pods in ibm-object-csi-driver-operator ns
210
- k8sOps .Namespace = req . Namespace
210
+ k8sOps .Namespace = constants . CSIOperatorNamespace
211
211
podsInOpNs , err := k8sOps .ListPod ()
212
212
if err != nil {
213
- reqLogger .Error (err , "failed to fetch pods in namespace: " + req . Namespace )
213
+ reqLogger .Error (err , "failed to fetch pods in namespace: " + constants . CSIOperatorNamespace )
214
214
return ctrl.Result {}, err
215
215
}
216
216
reqLogger .Info ("Successfully fetched pods in namespace" , "number-of-pods" , len (podsInOpNs .Items ))
@@ -231,7 +231,7 @@ func (r *RecoverStaleVolumeReconciler) Reconcile(ctx context.Context, req ctrl.R
231
231
for nodeName , volumesData := range nodeVolumePodMapping {
232
232
// Fetch volume stats from Logs of the Node Server Pod
233
233
getVolStatsFromLogs , err := fetchVolumeStatsFromNodeServerPodLogs (ctx , csiNodeServerPods [nodeName ],
234
- req . Namespace , logTailLines , r .IsTest )
234
+ constants . CSIOperatorNamespace , logTailLines , r .IsTest )
235
235
if err != nil {
236
236
return ctrl.Result {}, err
237
237
}
0 commit comments