minor fixes

Signed-off-by: Arvind Thirumurugan <arvindth@microsoft.com>

Author: Arvind Thirumurugan

pkg/controllers/updaterun/execution.go

@@ -235,13 +235,12 @@ func (r *Reconciler) executeUpdatingStage(
 				stuckClusterNames = append(stuckClusterNames, clusterStatus.ClusterName)
 			}
 		}
-		// Need to continue as we need to process at most maxConcurrency number of clusters in parallel.
 	}
 
 	// After processing maxConcurrency number of cluster, check if we need to mark the update run as stuck or progressing.
 	aggregateUpdateRunStatus(updateRun, updatingStageStatus.StageName, stuckClusterNames, finishedClusterCount)
 
-	// After processing all clusters, aggregate and return errors
+	// After processing all clusters, aggregate and return errors.
 	if len(clusterUpdateErrors) > 0 {
 		return 0, utilerrors.NewAggregate(clusterUpdateErrors)
 	}

test/e2e/cluster_staged_updaterun_test.go

@@ -1314,7 +1314,7 @@ var _ = Describe("test CRP rollout with staged update run", func() {
 					},
 				},
 			}
-			Expect(hubClient.Create(ctx, strategy)).To(Succeed(), "Failed to create ClusterStagedUpdateStrategy with maxConcurrency=3")
+			Expect(hubClient.Create(ctx, strategy)).To(Succeed(), "Failed to create ClusterStagedUpdateStrategy")
 		})
 
 		AfterAll(func() {

test/e2e/staged_updaterun_test.go

@@ -1143,7 +1143,7 @@ var _ = Describe("test RP rollout with staged update run", Label("resourceplacem
 					},
 				},
 			}
-			Expect(hubClient.Create(ctx, strategy)).To(Succeed(), "Failed to create StagedUpdateStrategy with maxConcurrency=3")
+			Expect(hubClient.Create(ctx, strategy)).To(Succeed(), "Failed to create StagedUpdateStrategy")
 		})
 
 		AfterAll(func() {