Skip to content

Commit 54843b4

Browse files
committed
fix(backend): commit tx for every feed for better fault tolerance
1 parent dd5211c commit 54843b4

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

backend/lfreader_server/storage.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -409,8 +409,9 @@ async def fetch_feeds(self, feeds: list[FeedInfo], archive: bool, force_archive:
409409
None
410410
)
411411
)
412-
# insert will create a tx. Must commit to save data
413-
self.db.commit()
412+
# insert will create a tx. Must commit to save data
413+
# Commit tx for every feed
414+
self.db.commit()
414415

415416
def get_feeds_cursor(
416417
self,
@@ -518,7 +519,7 @@ def clean_feeds(self, feed_urls: list[str] | None):
518519
if (e_published and e_published < after_date) or (e_updated and e_updated < after_date):
519520
self.archiver.delete_resources(f_url, e_id)
520521
self.db.execute("DELETE FROM entries WHERE feed_url = ? AND id = ?", (f_url, e_id))
521-
self.db.commit()
522+
self.db.commit()
522523

523524
# archive feeds in database
524525
async def archive_feeds(self, feed_urls: Iterable[str] | None = None):
@@ -565,4 +566,4 @@ async def archive_feeds(self, feed_urls: Iterable[str] | None = None):
565566
e_id
566567
)
567568
)
568-
self.db.commit()
569+
self.db.commit()

0 commit comments

Comments
 (0)