Requeue work item on syncHandler error

Kubernetes-commit: 8f86654b8e23bbf960a286712df35c003f7389f8
This commit is contained in:
nrfox 2018-10-19 13:54:31 -04:00 committed by Kubernetes Publisher
parent 7ee81ff4ae
commit 94e9a85e76

View File

@ -219,7 +219,9 @@ func (c *Controller) processNextWorkItem() bool {
// Run the syncHandler, passing it the namespace/name string of the
// Foo resource to be synced.
if err := c.syncHandler(key); err != nil {
return fmt.Errorf("error syncing '%s': %s", key, err.Error())
// Put the item back on the workqueue to handle any transient errors.
c.workqueue.AddRateLimited(key)
return fmt.Errorf("error syncing '%s': %s, requeuing", key, err.Error())
}
// Finally, if no error occurs we Forget this item so it does not
// get queued again until another change happens.