fix Cron

mxpv · Apr 9, 2020 · 861eef5 · 861eef5
1 parent d08d09b
commit 861eef5
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/cmd/podsync/main.go b/cmd/podsync/main.go
@@ -130,21 +130,22 @@ func main() {
 		c := cron.New(cron.WithChain(cron.SkipIfStillRunning(nil)))
 
 		for _, feed := range cfg.Feeds {
+			_feed := feed
 			if feed.CronSchedule == "" {
 				feed.CronSchedule = fmt.Sprintf("@every %s", feed.UpdatePeriod.String())
 			}
 
-			if _, err = c.AddFunc(feed.CronSchedule, func() {
-				log.Debugf("adding %q to update queue", feed.URL)
-				updates <- feed
+			if _, err = c.AddFunc(_feed.CronSchedule, func() {
+				log.Debugf("adding %q to update queue", _feed.URL)
+				updates <- _feed
 			}); err != nil {
-				log.WithError(err).Fatalf("can't create cron task for feed: %s", feed.ID)
+				log.WithError(err).Fatalf("can't create cron task for feed: %s", _feed.ID)
 			}
 
-			log.Debugf("-> %s (update '%s')", feed.URL, feed.CronSchedule)
+			log.Debugf("-> %s (update '%s')", _feed.URL, feed.CronSchedule)
 
 			// Perform initial update after CLI restart
-			updates <- feed
+			updates <- _feed
 		}
 
 		c.Start()