chore: addressing pr comments

k0sproject · May 6, 2024 · 36ce83b · 36ce83b
1 parent 191861a
commit 36ce83b
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/pkg/component/worker/ocibundle.go b/pkg/component/worker/ocibundle.go
@@ -58,7 +58,7 @@ func NewOCIBundleReconciler(vars *config.CfgVars) *OCIBundleReconciler {
 		log:             logrus.WithField("component", "OCIBundleReconciler"),
 		EventEmitter:    prober.NewEventEmitter(),
 		alreadyImported: map[string]time.Time{},
-		end:             make(chan struct{}, 1),
+		end:             make(chan struct{}),
 	}
 }
 
@@ -178,11 +178,13 @@ func (a *OCIBundleReconciler) installWatcher(ctx context.Context) error {
 	}()
 
 	go func() {
+		defer close(a.end)
 		a.log.Infof("Started to watch events on %s", a.k0sVars.OCIBundleDir)
 		_ = debouncer.Run(ctx)
-		watcher.Close()
+		if err := watcher.Close(); err != nil {
+			a.log.Errorf("Failed to close watcher: %s", err)
+		}
 		a.log.Info("OCI bundle watch bouncer ended")
-		a.end <- struct{}{}
 	}()
 
 	return nil