diff --git a/pkg/monitoring/feed_monitor.go b/pkg/monitoring/feed_monitor.go index a29f07186..106908137 100644 --- a/pkg/monitoring/feed_monitor.go +++ b/pkg/monitoring/feed_monitor.go @@ -47,7 +47,7 @@ func (f *feedMonitor) Run(ctx context.Context) { var subs utils.Subprocesses // Listen for updates - updatesFanIn := make(chan interface{}) + updatesFanIn := make(chan interface{}, 1) for _, poller := range f.pollers { poller := poller subs.Go(func() {