Skip to content
Prev Previous commit
Next Next commit
enqueue machine when machineclass is updated
  • Loading branch information
elankath committed Aug 21, 2025
commit ca4130b72a413cf8e54dea6d143c7325d208babc
10 changes: 7 additions & 3 deletions pkg/util/provider/machinecontroller/machineclass.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,7 @@ func (c *controller) reconcileClusterMachineClass(ctx context.Context, class *v1
if class.DeletionTimestamp == nil && len(machines) > 0 {
// If deletionTimestamp is not set and at least one machine is referring this machineClass

var reason string
if finalizers := sets.NewString(class.Finalizers...); !finalizers.Has(MCMFinalizerName) {
// Add machineClassFinalizer as if doesn't exist
err = c.addMCMFinalizerToMachineClass(ctx, class)
Expand All @@ -124,11 +125,14 @@ func (c *controller) reconcileClusterMachineClass(ctx context.Context, class *v1

// Enqueue all machines once finalizer is added to machineClass
// This is to allow processing of such machines
for _, machine := range machines {
c.enqueueMachine(machine, "finalizer placed on machineClass")
}
reason = "finalizer placed on machineClass"
} else {
reason = fmt.Sprintf("machine class %q was updated", class.Name)
}

for _, m := range machines {
c.enqueueMachine(m, reason)
}
return nil
}

Expand Down