From 1dccc61a711920097aedcd16e24a2cb0c3da6cac Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Radek=20Ma=C5=88=C3=A1k?= Date: Fri, 17 Jul 2026 16:26:34 +0200 Subject: [PATCH] Add max-concurrent-reconciles flag to machine actuator Allow the machine-controller to raise MaxConcurrentReconciles via flag, matching Azure and GCP providers. --- cmd/manager/main.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/cmd/manager/main.go b/cmd/manager/main.go index 83e6cc6d9..94b1cecc9 100644 --- a/cmd/manager/main.go +++ b/cmd/manager/main.go @@ -110,6 +110,12 @@ func main() { "The address for serving pprof profiling endpoints (requires --enable-pprof).", ) + maxConcurrentReconciles := flag.Int( + "max-concurrent-reconciles", + 1, + "Maximum number of concurrent reconciles per controller instance.", + ) + // Sets up feature gates (version from build time, default 4 for unknown) // Default should be changed to 5 once we branch for 5 majorVersion := version.Version.Major @@ -216,7 +222,9 @@ func main() { RegionCache: describeRegionsCache, }) - if err := machine.AddWithActuator(mgr, machineActuator, defaultMutableGate); err != nil { + if err := machine.AddWithActuatorOpts(mgr, machineActuator, controller.Options{ + MaxConcurrentReconciles: *maxConcurrentReconciles, + }, defaultMutableGate); err != nil { klog.Fatalf("Error adding actuator: %v", err) }