fix rewrite error handing

2025-05-03 14:51:27 +08:00
parent 6a869574fc
commit 14a4f2b8d4
1 changed files with 6 additions and 4 deletions
--- a/pkg/storage/feed/feed.go
+++ b/pkg/storage/feed/feed.go
@@ -613,10 +613,12 @@ func (s *storage) rewrite(ctx context.Context, feeds []*model.Feed) ([]*model.Fe
 		}(item)
 	}
 	wg.Wait()
-	if allFailed := len(errs) == len(feeds)-int(dropped.Load()); allFailed {
-		return nil, errs[0]
-	}
-	if len(errs) > 0 {
+
+	switch len(errs) {
+	case 0:
+	case len(feeds) - int(dropped.Load()):
+		return nil, errs[0] // All failed.
+	default:
 		log.Error(ctx, errors.Wrap(errs[0], "rewrite feeds"), "error_count", len(errs))
 	}