@@ -1261,27 +1261,11 @@ func removeDropMetadataForNamespace(namespace string) {
12611261 delete (DropMetadataStore , namespace )
12621262}
12631263
1264- // getDropMetadataForResource retrieves DropMetadata for a specific resource in a namespace
1265- func getDropMetadataForResource (namespace , resource string ) * DropMetadata {
1266- if metadataList , exists := DropMetadataStore [namespace ]; exists {
1267- for _ , metadata := range metadataList {
1268- if metadata .Resource == resource {
1269- return & metadata
1270- }
1271- }
1272- }
1273- return nil
1274- }
1275-
12761264// processDropMetadataForCleanup processes the DropMetadata store and cleans up removed labels from resources
1277- func (r * ReconcileArgoCD ) processDropMetadataForCleanup (argocd * argoproj.ArgoCD ) error {
1265+ func (r * ReconcileArgoCD ) processDropMetadataForCleanup (argocd * argoproj.ArgoCD ) {
12781266 namespace := argocd .GetNamespace ()
12791267 dropMetadataList := getDropMetadataForNamespace (namespace )
12801268
1281- if len (dropMetadataList ) == 0 {
1282- return nil
1283- }
1284-
12851269 log .Info ("Processing DropMetadata for cleanup" ,
12861270 "argocd" , fmt .Sprintf ("%s/%s" , argocd .Namespace , argocd .Name ),
12871271 "namespace" , namespace ,
@@ -1298,7 +1282,6 @@ func (r *ReconcileArgoCD) processDropMetadataForCleanup(argocd *argoproj.ArgoCD)
12981282
12991283 // Clear the DropMetadata for this namespace after cleanup
13001284 removeDropMetadataForNamespace (namespace )
1301- return nil
13021285}
13031286
13041287// cleanupLabelsFromResourceType removes labels from specific resource types
@@ -1363,15 +1346,11 @@ func (r *ReconcileArgoCD) cleanupLabelsFromDeployment(argocd *argoproj.ArgoCD, d
13631346 return fmt .Errorf ("failed to get deployment %s: %w" , deploymentName , err )
13641347 }
13651348
1366- if currentLabels , err := r .removeLabelsFromObject (deployment , labelsToRemove ); err != nil {
1367- log .Error (err , "failed to remove labels from deployment" , "name" , deploymentName )
1349+ currentLabels := r .removeLabelsFromObject (deployment , labelsToRemove )
1350+ deployment .Spec .Template .Labels = currentLabels
1351+ if err := r .Update (context .TODO (), deployment ); err != nil {
1352+ log .Error (err , "failed to update deployment after removing labels" , "name" , deploymentName )
13681353 return err
1369- } else {
1370- deployment .Spec .Template .Labels = currentLabels
1371- if err := r .Update (context .TODO (), deployment ); err != nil {
1372- log .Error (err , "failed to update deployment after removing labels" , "name" , deploymentName )
1373- return err
1374- }
13751354 }
13761355 return nil
13771356}
@@ -1390,16 +1369,13 @@ func (r *ReconcileArgoCD) cleanupLabelsFromStatefulSet(argocd *argoproj.ArgoCD,
13901369 return fmt .Errorf ("failed to get statefulset %s: %w" , statefulSetName , err )
13911370 }
13921371
1393- if currentLabels , err := r .removeLabelsFromObject (statefulSet , labelsToRemove ); err != nil {
1394- log .Error (err , "failed to remove labels from statefulset" , "name" , statefulSetName )
1372+ currentLabels := r .removeLabelsFromObject (statefulSet , labelsToRemove )
1373+ statefulSet .SetLabels (currentLabels )
1374+ if err := r .Update (context .TODO (), statefulSet ); err != nil {
1375+ log .Error (err , "failed to update statefulset after removing labels" , "name" , statefulSetName )
13951376 return err
1396- } else {
1397- statefulSet .SetLabels (currentLabels )
1398- if err := r .Update (context .TODO (), statefulSet ); err != nil {
1399- log .Error (err , "failed to update statefulset after removing labels" , "name" , statefulSetName )
1400- return err
1401- }
14021377 }
1378+
14031379 return nil
14041380}
14051381
@@ -1471,10 +1447,10 @@ func (r *ReconcileArgoCD) calculateRemovedSpecLabels(oldCR, newCR *argoproj.Argo
14711447
14721448}
14731449
1474- func (r * ReconcileArgoCD ) removeLabelsFromObject (obj client.Object , labelsToRemove []string ) ( map [string ]string , error ) {
1450+ func (r * ReconcileArgoCD ) removeLabelsFromObject (obj client.Object , labelsToRemove []string ) map [string ]string {
14751451 currentLabels := obj .GetLabels ()
14761452 if currentLabels == nil {
1477- return nil , nil
1453+ return nil
14781454 }
14791455
14801456 modified := false
@@ -1485,9 +1461,9 @@ func (r *ReconcileArgoCD) removeLabelsFromObject(obj client.Object, labelsToRemo
14851461 }
14861462 }
14871463 if modified {
1488- return currentLabels , nil
1464+ return currentLabels
14891465 }
1490- return currentLabels , nil
1466+ return currentLabels
14911467}
14921468
14931469// deleteRBACsForNamespace deletes the RBACs when the label from the namespace is removed.
0 commit comments