modified internal/feed/fetcher.go +1 -1
| @@ -161,7 +161,7 @@ func (s *Scheduler) fetchAll(ctx context.Context, olderThan time.Duration) { |
| 161 | 161 | s.logger.Info("fetching feeds", "count", len(feeds), "older_than", olderThan) |
| 162 | 162 | |
| 163 | 163 | g, gCtx := errgroup.WithContext(ctx) |
| 164 | | - g.SetLimit(50) |
| 164 | + g.SetLimit(10) |
| 165 | 165 | for _, f := range feeds { |
| 166 | 166 | g.Go(func() error { |
| 167 | 167 | s.FetchFeed(gCtx, f) |
| @@ -161,7 +161,7 @@ func (s *Scheduler) fetchAll(ctx context.Context, olderThan time.Duration) { |
| 161 | s.logger.Info("fetching feeds", "count", len(feeds), "older_than", olderThan) | 161 | s.logger.Info("fetching feeds", "count", len(feeds), "older_than", olderThan) |
| 162 | | 162 | |
| 163 | g, gCtx := errgroup.WithContext(ctx) | 163 | g, gCtx := errgroup.WithContext(ctx) |
| 164 | - g.SetLimit(50) | 164 | + g.SetLimit(10) |
| 165 | for _, f := range feeds { | 165 | for _, f := range feeds { |
| 166 | g.Go(func() error { | 166 | g.Go(func() error { |
| 167 | s.FetchFeed(gCtx, f) | 167 | s.FetchFeed(gCtx, f) |