Skip to content

Commit 2a1bcc2

Browse files
committed
Revert "feat: add some delays when detecting new resource changes"
This reverts commit 136267c. Signed-off-by: Zhiying Lin <[email protected]>
1 parent 15b71c5 commit 2a1bcc2

File tree

1 file changed

+2
-10
lines changed

1 file changed

+2
-10
lines changed

pkg/controllers/resourcechange/resourcechange_controller.go

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -187,11 +187,7 @@ func (r *Reconciler) findPlacementsSelectedDeletedResV1Beta1(res keys.ClusterWid
187187

188188
for _, crp := range matchedCrps {
189189
klog.V(2).InfoS("change in deleted object triggered v1beta1 placement reconcile", "obj", res, "crp", crp)
190-
// schedule enqueue after 1 minute
191-
crpName := crp
192-
time.AfterFunc(time.Minute, func() {
193-
r.PlacementControllerV1Beta1.Enqueue(crpName)
194-
})
190+
r.PlacementControllerV1Beta1.Enqueue(crp)
195191
}
196192
}
197193

@@ -259,11 +255,7 @@ func (r *Reconciler) triggerAffectedPlacementsForUpdatedClusterRes(key keys.Clus
259255
// Enqueue the CRPs for reconciliation.
260256
for crp := range matchedCRPs {
261257
klog.V(2).InfoS("Change in object triggered v1beta1 placement reconcile", "obj", key, "crp", crp)
262-
// schedule enqueue after 1 minute
263-
crpName := crp
264-
time.AfterFunc(time.Minute, func() {
265-
r.PlacementControllerV1Beta1.Enqueue(crpName)
266-
})
258+
r.PlacementControllerV1Beta1.Enqueue(crp)
267259
}
268260
}
269261

0 commit comments

Comments
 (0)