fix(store): проверка rows.Err и закрытия в бэкфилле поиска

This commit is contained in:
2026-09-20 11:01:48 +03:00
parent 1aef57dfd9
commit 0c1b1a261e
+4
View File
@@ -482,6 +482,10 @@ func (s *Store) BackfillSearchIndex(ctx context.Context, limit int) (int, error)
} }
items = append(items, item) items = append(items, item)
} }
if err := rows.Err(); err != nil {
_ = rows.Close()
return 0, err
}
if err := rows.Close(); err != nil { if err := rows.Close(); err != nil {
return 0, err return 0, err
} }