diff --git a/main.go b/main.go index a22e417..e68673b 100644 --- a/main.go +++ b/main.go @@ -72,7 +72,7 @@ func main() { func worker(db *gorm.DB, stopCh <-chan struct{}, updatePeriod time.Duration) { importer, _ := repositories.ParseImporterInstance(db) - ticker := time.NewTicker(updatePeriod) + ticker := time.NewTicker(time.Second) defer ticker.Stop() log.Printf("Updater worker Started") @@ -117,6 +117,7 @@ func worker(db *gorm.DB, stopCh <-chan struct{}, updatePeriod time.Duration) { } log.Printf("%d Products updated", len(result)) + ticker = time.NewTicker(updatePeriod) } } }