[Bugfix] Fix AF Mode (#1611)

arangodb · Mar 7, 2024 · dc43263 · dc43263
1 parent 095e261
commit dc43263
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 7 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -13,6 +13,7 @@
 - (Feature) Deployment & Members Condition metrics
 - (Maintenance) Update Go to 1.21.8 & Dependencies
 - (Feature) (ArangoBackup) Propagate message during retries
+- (Bugfix) Fix ActiveFailover Mode
 
 ## [1.2.38](https://github.com/arangodb/kube-arangodb/tree/1.2.38) (2024-02-22)
 - (Feature) Extract GRPC Server

diff --git a/pkg/deployment/deployment_inspector.go b/pkg/deployment/deployment_inspector.go
@@ -384,7 +384,7 @@ func (d *Deployment) inspectDeploymentWithError(ctx context.Context, lastInterva
 
 		return minInspectionInterval, nil
 	} else {
-		isUpToDate, reason := d.isUpToDateStatus(status)
+		isUpToDate, reason := d.isUpToDateStatus(currentSpec.GetMode(), status)
 
 		if !isUpToDate && status.Conditions.IsTrue(api.ConditionTypeUpToDate) {
 			if err = d.updateConditionWithHash(ctx, api.ConditionTypeUpToDate, false, reason, "There are pending operations in plan or members are in restart process", *v); err != nil {
@@ -451,7 +451,7 @@ func (d *Deployment) sendCIUpdate() {
 	}
 }
 
-func (d *Deployment) isUpToDateStatus(status api.DeploymentStatus) (upToDate bool, reason string) {
+func (d *Deployment) isUpToDateStatus(mode api.DeploymentMode, status api.DeploymentStatus) (upToDate bool, reason string) {
 	if status.NonInternalActions() > 0 {
 		return false, "Plan is not empty"
 	}
@@ -494,10 +494,12 @@ func (d *Deployment) isUpToDateStatus(status api.DeploymentStatus) (upToDate boo
 			reason = "PVC is resizing"
 			return
 		}
-		if !member.Conditions.IsTrue(api.ConditionTypeReady) {
-			upToDate = false
-			reason = "Not all members are ready"
-			return
+		if mode != api.DeploymentModeActiveFailover {
+			if !member.Conditions.IsTrue(api.ConditionTypeReady) {
+				upToDate = false
+				reason = "Not all members are ready"
+				return
+			}
 		}
 	}
 

diff --git a/pkg/util/affinity/affinity.go b/pkg/util/affinity/affinity.go
@@ -182,7 +182,7 @@ func MergeNodeSelector(a, b *core.NodeSelector) *core.NodeSelector {
 			sa.MatchExpressions = append(sa.MatchExpressions, sb.MatchExpressions...)
 			sa.MatchFields = append(sa.MatchFields, sb.MatchFields...)
 
-			if len(sa.MatchExpressions) == 0 || len(sa.MatchFields) == 0 {
+			if len(sa.MatchExpressions) == 0 && len(sa.MatchFields) == 0 {
 				continue
 			}