modified internal/feed/fetcher.go +1 -1
| @@ -181,7 +181,7 @@ func (s *Scheduler) Run(ctx context.Context) error { |
| 181 | 181 | } |
| 182 | 182 | |
| 183 | 183 | func (s *Scheduler) fetchAll(ctx context.Context, olderThan time.Duration) { |
| 184 | | - feeds, err := s.store.GetFeedsToFetch(ctx, olderThan, 1_000) |
| 184 | + feeds, err := s.store.GetFeedsToFetch(ctx, olderThan, 10_000) |
| 185 | 185 | if err != nil { |
| 186 | 186 | s.logger.Error("failed to get feeds", "error", err) |
| 187 | 187 | return |
| @@ -181,7 +181,7 @@ func (s *Scheduler) Run(ctx context.Context) error { |
| 181 | } | 181 | } |
| 182 | | 182 | |
| 183 | func (s *Scheduler) fetchAll(ctx context.Context, olderThan time.Duration) { | 183 | func (s *Scheduler) fetchAll(ctx context.Context, olderThan time.Duration) { |
| 184 | - feeds, err := s.store.GetFeedsToFetch(ctx, olderThan, 1_000) | 184 | + feeds, err := s.store.GetFeedsToFetch(ctx, olderThan, 10_000) |
| 185 | if err != nil { | 185 | if err != nil { |
| 186 | s.logger.Error("failed to get feeds", "error", err) | 186 | s.logger.Error("failed to get feeds", "error", err) |
| 187 | return | 187 | return |