Remove useless workqueue.Done

Signed-off-by: Vitor Savian <vitor.savian@suse.com>
vitorsavian · Nov 26, 2024 · df13c2f · df13c2f
1 parent d016f6f
commit df13c2f
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/pkg/agent/containerd/watcher.go b/pkg/agent/containerd/watcher.go
@@ -155,12 +155,10 @@ func (w *Watcher) processImageEvent(ctx context.Context, key string, cfg *config
 
 		// we do not want to handle directorys, only files
 		if newStateFile.IsDir() {
-			w.workqueue.Done(key)
 			return nil
 		}
 
 		if !isFileSupported(event.Name) {
-			w.workqueue.Done(key)
 			return nil
 		}
 
@@ -175,8 +173,6 @@ func (w *Watcher) processImageEvent(ctx context.Context, key string, cfg *config
 			}
 			logrus.Infof("Imported images from %s in %s", event.Name, time.Since(start))
 		}
-
-		w.workqueue.Done(key)
 	}
 
 	if event.Has(fsnotify.Create) {
@@ -222,12 +218,10 @@ func (w *Watcher) processImageEvent(ctx context.Context, key string, cfg *config
 				}
 			}
 
-			w.workqueue.Done(key)
 			return nil
 		}
 
 		if !isFileSupported(event.Name) {
-			w.workqueue.Done(key)
 			return nil
 		}
 
@@ -239,7 +233,6 @@ func (w *Watcher) processImageEvent(ctx context.Context, key string, cfg *config
 			return err
 		}
 		logrus.Infof("Imported images from %s in %s", event.Name, time.Since(start))
-		w.workqueue.Done(key)
 	}
 
 	if event.Has(fsnotify.Remove) {
@@ -251,7 +244,6 @@ func (w *Watcher) processImageEvent(ctx context.Context, key string, cfg *config
 		}
 
 		if !isFileSupported(event.Name) {
-			w.workqueue.Done(key)
 			return nil
 		}
 
@@ -269,7 +261,6 @@ func (w *Watcher) processImageEvent(ctx context.Context, key string, cfg *config
 		}
 
 		if !isFileSupported(event.Name) {
-			w.workqueue.Done(key)
 			return nil
 		}