mirror/mxpv-podsync
1
0
Fork 0
mirror of https://github.com/mxpv/podsync.git synced 2024-05-11 05:55:04 +00:00
Code Issues Releases Activity

fix Cron

Browse Source
This commit is contained in:
delaosa
2020-04-09 17:10:32 +02:00
parent d08d09bcce
commit 861eef5a2b
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cmd/podsync/main.go
View File

@ -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()