diff options
Diffstat (limited to 'internal/cli/refresh_feeds.go')
| -rw-r--r-- | internal/cli/refresh_feeds.go | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/internal/cli/refresh_feeds.go b/internal/cli/refresh_feeds.go index 3af4ecdb..e10600f3 100644 --- a/internal/cli/refresh_feeds.go +++ b/internal/cli/refresh_feeds.go @@ -18,7 +18,15 @@ func refreshFeeds(store *storage.Storage) { var wg sync.WaitGroup startTime := time.Now() - jobs, err := store.NewBatch(config.Opts.BatchSize()) + + // Generate a batch of feeds for any user that has feeds to refresh. + batchBuilder := store.NewBatchBuilder() + batchBuilder.WithBatchSize(config.Opts.BatchSize()) + batchBuilder.WithErrorLimit(config.Opts.PollingParsingErrorLimit()) + batchBuilder.WithoutDisabledFeeds() + batchBuilder.WithNextCheckExpired() + + jobs, err := batchBuilder.FetchJobs() if err != nil { slog.Error("Unable to fetch jobs from database", slog.Any("error", err)) return |