diff --git a/beater/youtubebeat.go b/beater/youtubebeat.go index 06d7461..6d42a47 100644 --- a/beater/youtubebeat.go +++ b/beater/youtubebeat.go @@ -93,6 +93,7 @@ func scrapeVideos(b *beat.Beat, bt *Youtubebeat, done chan bool) { videoCollector.Visit(BaseUrl + BaseSuffix + bt.config.StartId) videoCollector.Wait() + logp.Info("Done parsing all videos") done <- true } @@ -111,8 +112,10 @@ func (bt *Youtubebeat) Run(b *beat.Beat) error { select { case <-done: + logp.Info("Exiting on done parsing") return nil case <-bt.done: + logp.Info("Exiting on beat stop signal") return nil } }