fix annotate observer for deletion (#501)

oceanbase · Aug 2, 2024 · 15a4465 · 15a4465
1 parent 764f0c9
commit 15a4465
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/resource/obclusteroperation/obclusteroperation_task.go b/internal/resource/obclusteroperation/obclusteroperation_task.go
@@ -264,7 +264,9 @@ func AnnotateOBServersForDeletion(m *OBClusterOperationManager) tasktypes.TaskEr
 				}
 				observer.Annotations[oceanbaseconst.AnnotationsDeletionPriority] = strconv.Itoa(oceanbaseconst.DefaultDeletionPriority)
 				err = m.Client.Update(m.Ctx, &observer)
-				return errors.Wrapf(err, "Failed to annotate observer %s", observerName)
+				if err != nil {
+					return errors.Wrapf(err, "Failed to annotate observer %s", observerName)
+				}
 			}
 		}
 	}