Remove speedup of observer deletion (#142)

* fix(observer): remove speedup of observer deletion
oceanbase · Dec 18, 2023 · 39a218f · 39a218f
1 parent c8b94f9
commit 39a218f
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/internal/resource/observer/observer_task.go b/internal/resource/observer/observer_task.go
@@ -646,15 +646,6 @@ func (m *OBServerManager) WaitOBServerDeletedInCluster() tasktypes.TaskError {
 		} else if err != nil {
 			m.Logger.Error(err, "Query observer info failed")
 		}
-		obunits, err := operationManager.ListUnitsWithServerIP(observerInfo.Ip)
-		if err != nil {
-			return errors.Wrapf(err, "List units on server "+observerInfo.Ip)
-		}
-		if len(obunits) == 0 {
-			m.Logger.Info("none of units left on observer, deleted")
-			deleted = true
-			break
-		}
 		time.Sleep(time.Second)
 	}
 	if !deleted {