Merge pull request kubernetes-sigs#2503 from k8s-infra-cherrypick-robot/cherry-pick-2502-to-release-0.12

k8s-ci-robot · web-flow · commit c1bce8928dfa · 2025-03-28T06:30:40.000-07:00
[release-0.12] 🐛 fix openstackserver controller concurrency
diff --git a/controllers/openstackserver_controller.go b/controllers/openstackserver_controller.go
@@ -170,7 +170,7 @@ func patchServer(ctx context.Context, patchHelper *patch.Helper, openStackServer
 	return patchHelper.Patch(ctx, openStackServer, options...)
 }
 
-func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, _ controller.Options) error {
+func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error {
 	const imageRefPath = "spec.image.imageRef.name"
 
 	log := ctrl.LoggerFrom(ctx)
@@ -190,6 +190,7 @@ func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ct
 	}
 
 	return ctrl.NewControllerManagedBy(mgr).
+		WithOptions(options).
 		For(&infrav1alpha1.OpenStackServer{}).
 		Watches(&orcv1alpha1.Image{},
 			handler.EnqueueRequestsFromMapFunc(func(ctx context.Context, obj client.Object) []reconcile.Request {

Original file line number	Diff line number	Diff line change
`@@ -170,7 +170,7 @@ func patchServer(ctx context.Context, patchHelper *patch.Helper, openStackServer`
`170`	`170`	`return patchHelper.Patch(ctx, openStackServer, options...)`
`171`	`171`	`}`
`172`	`172`
`173`		`-func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, _ controller.Options) error {`
	`173`	`+func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error {`
`174`	`174`	`const imageRefPath = "spec.image.imageRef.name"`
`175`	`175`
`176`	`176`	`log := ctrl.LoggerFrom(ctx)`
`@@ -190,6 +190,7 @@ func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ct`
`190`	`190`	`}`
`191`	`191`
`192`	`192`	`return ctrl.NewControllerManagedBy(mgr).`
	`193`	`+ WithOptions(options).`
`193`	`194`	`For(&infrav1alpha1.OpenStackServer{}).`
`194`	`195`	`Watches(&orcv1alpha1.Image{},`
`195`	`196`	`handler.EnqueueRequestsFromMapFunc(func(ctx context.Context, obj client.Object) []reconcile.Request {`