WaitForMember invalidates sync status at end.

Author: lamai93

pkg/deployment/reconcile/action_context.go

@@ -84,6 +84,8 @@ type ActionContext interface {
 	// SetCurrentImage changes the CurrentImage field in the deployment
 	// status to the given image.
 	SetCurrentImage(imageInfo api.ImageInfo) error
+	// InvalidateSyncStatus resets the sync state to false and triggers an inspection
+	InvalidateSyncStatus()
 }
 
 // newActionContext creates a new ActionContext implementation.
@@ -284,3 +286,8 @@ func (ac *actionContext) SetCurrentImage(imageInfo api.ImageInfo) error {
 	}
 	return nil
 }
+
+// InvalidateSyncStatus resets the sync state to false and triggers an inspection
+func (ac *actionContext) InvalidateSyncStatus() {
+	ac.context.InvalidateSyncStatus()
+}

pkg/deployment/reconcile/action_wait_for_member_up.go

@@ -167,26 +167,7 @@ func (a *actionWaitForMemberUp) checkProgressCluster(ctx context.Context) (bool,
 		log.Debug().Str("status", string(sh.Status)).Msg("Member set status not yet good")
 		return false, false, nil
 	}
-	if a.action.Group == api.ServerGroupDBServers {
-		dbs, err := c.Databases(ctx)
-		if err != nil {
-			return false, false, err
-		}
-		for _, db := range dbs {
-			inv, err := cluster.DatabaseInventory(ctx, db)
-			if err != nil {
-				return false, false, err
-			}
-
-			for _, col := range inv.Collections {
-				if !col.AllInSync {
-					log.Debug().Str("col", col.Parameters.Name).Msg("Not in sync")
-					return false, false, nil
-				}
-			}
-		}
 
-	}
 	// Wait for the member to become ready from a kubernetes point of view
 	// otherwise the coordinators may be rotated to fast and thus none of them
 	// is ready resulting in a short downtime
@@ -197,6 +178,10 @@ func (a *actionWaitForMemberUp) checkProgressCluster(ctx context.Context) (bool,
 		log.Debug().Msg("Member not yet ready")
 		return false, false, nil
 	}
+
+	if a.action.Group == api.ServerGroupDBServers {
+		a.actionCtx.InvalidateSyncStatus()
+	}
 	return true, false, nil
 }