Add updatedReplicas to Status

api/leaderworkerset/v1/leaderworkerset_types.go

@@ -185,10 +185,13 @@ type LeaderWorkerSetStatus struct {
 	Conditions []metav1.Condition `json:"conditions,omitempty"`
 
 	// ReadyReplicas track the number of groups that are in ready state.
-	ReadyReplicas int `json:"readyReplicas,omitempty"`
+	ReadyReplicas int32 `json:"readyReplicas,omitempty"`
+
+	// UpdatedReplicas track the number of groups that have been updated.
+	UpdatedReplicas int32 `json:"updatedReplicas,omitempty"`
 
 	// Replicas track the active total number of groups.
-	Replicas int `json:"replicas,omitempty"`
+	Replicas int32 `json:"replicas,omitempty"`
 
 	// HPAPodSelector for pods that belong to the LeaderWorkerSet object, this is
 	// needed for HPA to know what pods belong to the LeaderWorkerSet object. Here

config/crd/bases/leaderworkerset.x-k8s.io_leaderworkersets.yaml

@@ -15403,9 +15403,16 @@ spec:
               readyReplicas:
                 description: ReadyReplicas track the number of groups that are in
                   ready state.
+                format: int32
                 type: integer
               replicas:
                 description: Replicas track the active total number of groups.
+                format: int32
+                type: integer
+              updatedReplicas:
+                description: UpdatedReplicas track the number of groups that have
+                  been updated.
+                format: int32
                 type: integer
             type: object
         type: object

pkg/controllers/leaderworkerset_controller.go

@@ -346,6 +346,7 @@ func (r *LeaderWorkerSetReconciler) updateConditions(ctx context.Context, lws *l
 
 	updateStatus := false
 	readyCount := 0
+	updatedCount := 0
 	templateHash := utils.LeaderWorkerTemplateHash(lws)
 
 	// Iterate through all statefulsets.
@@ -355,27 +356,36 @@ func (r *LeaderWorkerSetReconciler) updateConditions(ctx context.Context, lws *l
 		}
 
 		// this is the worker statefulset.
-		if sts.Labels[leaderworkerset.TemplateRevisionHashKey] == templateHash && statefulsetutils.StatefulsetReady(sts) {
+		if statefulsetutils.StatefulsetReady(sts) {
+
 			// the worker pods are OK.
 			// need to check leader pod for this group.
 			var leaderPod corev1.Pod
 			if err := r.Get(ctx, client.ObjectKey{Namespace: lws.Namespace, Name: sts.Name}, &leaderPod); err != nil {
 				log.Error(err, "Fetching leader pod")
 				return false, err
 			}
-			if leaderPod.Labels[leaderworkerset.TemplateRevisionHashKey] == templateHash && podutils.PodRunningAndReady(leaderPod) {
-				// set to progressing.
+			if podutils.PodRunningAndReady(leaderPod) {
 				readyCount++
+
+				if sts.Labels[leaderworkerset.TemplateRevisionHashKey] == templateHash && leaderPod.Labels[leaderworkerset.TemplateRevisionHashKey] == templateHash {
+					updatedCount++
+				}
 			}
 		}
 	}
 
-	if lws.Status.ReadyReplicas != readyCount {
-		lws.Status.ReadyReplicas = readyCount
+	if lws.Status.ReadyReplicas != int32(readyCount) {
+		lws.Status.ReadyReplicas = int32(readyCount)
+		updateStatus = true
+	}
+
+	if lws.Status.UpdatedReplicas != int32(updatedCount) {
+		lws.Status.UpdatedReplicas = int32(updatedCount)
 		updateStatus = true
 	}
 
-	condition := makeCondition(readyCount == int(*lws.Spec.Replicas))
+	condition := makeCondition(updatedCount == int(*lws.Spec.Replicas))
 	updateCondition := setCondition(lws, condition)
 	// if condition changed, record events
 	if updateCondition {
@@ -398,8 +408,8 @@ func (r *LeaderWorkerSetReconciler) updateStatus(ctx context.Context, lws *leade
 
 	// retrieve the current number of replicas -- the number of leaders
 	replicas := int(*sts.Spec.Replicas)
-	if lws.Status.Replicas != replicas {
-		lws.Status.Replicas = replicas
+	if lws.Status.Replicas != int32(replicas) {
+		lws.Status.Replicas = int32(replicas)
 		updateStatus = true
 	}
 

test/e2e/suite_test.go

@@ -40,7 +40,7 @@ import (
 )
 
 const (
-	timeout  = 1 * time.Minute
+	timeout  = 30 * time.Second
 	interval = time.Millisecond * 250
 )