diff --git a/backend/src/module/rss/engine.py b/backend/src/module/rss/engine.py index 244a6ab55..66feb42be 100644 --- a/backend/src/module/rss/engine.py +++ b/backend/src/module/rss/engine.py @@ -122,14 +122,16 @@ def refresh_rss(self, client: DownloadClient, rss_id: Optional[int] = None): for rss_item in rss_items: new_torrents = self.pull_rss(rss_item) # Get all enabled bangumi data + add_torrents = [] for torrent in new_torrents: matched_data = self.match_torrent(torrent) if matched_data: if client.add_torrent(torrent, matched_data): logger.debug(f"[Engine] Add torrent {torrent.name} to client") - torrent.downloaded = True + torrent.downloaded = True + add_torrents.append(torrent) # Add all torrents to database - self.torrent.add_all(new_torrents) + self.torrent.add_all(add_torrents) def download_bangumi(self, bangumi: Bangumi): with RequestContent() as req: