Skip to content

Commit bbc4cb8

Browse files
cheina97adamjensenbot
authored andcommitted
VirtualKubelet: replicated code fix
1 parent 2353e4f commit bbc4cb8

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

pkg/virtualKubelet/reflection/generic/reflector.go

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -193,14 +193,6 @@ func (gr *reflector) processNextWorkItem() bool {
193193
// Run the handler, passing it the item to be processed as parameter.
194194
if err := gr.handle(context.Background(), key.(types.NamespacedName)); err != nil {
195195
var eae enqueueAfterError
196-
if errors.As(err, &eae) {
197-
// Put the item back on the workqueue after the given duration elapsed.
198-
gr.workqueue.AddAfter(key, eae.duration)
199-
return true
200-
}
201-
202-
// Put the item back on the workqueue to handle any transient errors.
203-
gr.workqueue.AddRateLimited(key)
204196

205197
// Increase the error counter metric.
206198
metrics.ErrorsCounter.With(prometheus.Labels{"namespace": key.(types.NamespacedName).Namespace,

0 commit comments

Comments
 (0)