modified internal/feed/fetcher.go +1 -1
| @@ -115,7 +115,7 @@ func (s *Scheduler) Run(ctx context.Context) error { |
| 115 | 115 | } |
| 116 | 116 | |
| 117 | 117 | func (s *Scheduler) fetchAll(ctx context.Context) { |
| 118 | | - feeds, err := s.store.GetFeedsToFetch(ctx, s.staleInterval, 500) |
| 118 | + feeds, err := s.store.GetFeedsToFetch(ctx, s.staleInterval, 10_000) |
| 119 | 119 | if err != nil { |
| 120 | 120 | s.logger.Error("failed to get feeds", "error", err) |
| 121 | 121 | return |
| @@ -115,7 +115,7 @@ func (s *Scheduler) Run(ctx context.Context) error { |
| 115 | } | 115 | } |
| 116 | | 116 | |
| 117 | func (s *Scheduler) fetchAll(ctx context.Context) { | 117 | func (s *Scheduler) fetchAll(ctx context.Context) { |
| 118 | - feeds, err := s.store.GetFeedsToFetch(ctx, s.staleInterval, 500) | 118 | + feeds, err := s.store.GetFeedsToFetch(ctx, s.staleInterval, 10_000) |
| 119 | if err != nil { | 119 | if err != nil { |
| 120 | s.logger.Error("failed to get feeds", "error", err) | 120 | s.logger.Error("failed to get feeds", "error", err) |
| 121 | return | 121 | return |
modified internal/server/server.go +0 -2
| @@ -525,8 +525,6 @@ func (s *Server) BackfillFromCollectionDir(ctx context.Context, collectionDirURL |
| 525 | 525 | if err := sync.Run(ctx, did); err != nil { |
| 526 | 526 | s.logger.Error("backfill sync failed", "error", err, "did", did) |
| 527 | 527 | } |
| 528 | | - |
| 529 | | - s.refreshUserFeeds(ctx, did) |
| 530 | 528 | }(did) |
| 531 | 529 | } |
| 532 | 530 | |
| @@ -525,8 +525,6 @@ func (s *Server) BackfillFromCollectionDir(ctx context.Context, collectionDirURL |
| 525 | if err := sync.Run(ctx, did); err != nil { | 525 | if err := sync.Run(ctx, did); err != nil { |
| 526 | s.logger.Error("backfill sync failed", "error", err, "did", did) | 526 | s.logger.Error("backfill sync failed", "error", err, "did", did) |
| 527 | } | 527 | } |
| 528 | - | | |
| 529 | - s.refreshUserFeeds(ctx, did) | | |
| 530 | }(did) | 528 | }(did) |
| 531 | } | 529 | } |
| 532 | | 530 | |