Skip to content

Commit

Permalink
[release] Added more error handling and updated queue functionality
Browse files Browse the repository at this point in the history
  • Loading branch information
Feramance committed Sep 27, 2023
1 parent 93472cd commit ffeecb0
Showing 1 changed file with 0 additions and 20 deletions.
20 changes: 0 additions & 20 deletions qBitrr/arss.py
Original file line number Diff line number Diff line change
Expand Up @@ -3420,33 +3420,13 @@ def refresh_download_queue(self):
self.queue_file_ids = {
entry["episodeId"] for entry in self.queue if entry.get("episodeId")
}
# if self.model_queue:
# queue = []
# for entry in self.queue:
# if r := entry.get("movieId"):
# queue.append(r)
# self.model_queue.insert(
# Completed=False,
# EntryId=r,
# ).on_conflict_replace().execute()
# self.model_queue.delete().where(self.model_queue.EntryId.not_in(queue)).execute()
elif self.type == "radarr":
self.requeue_cache = {
entry["id"]: entry["movieId"] for entry in self.queue if entry.get("movieId")
}
self.queue_file_ids = {
entry["movieId"] for entry in self.queue if entry.get("movieId")
}
# if self.model_queue:
# queue = []
# for entry in self.queue:
# if r := entry.get("movieId"):
# queue.append(r)
# self.model_queue.insert(
# Completed=False,
# EntryId=r,
# ).on_conflict_replace().execute()
# self.model_queue.delete().where(self.model_queue.EntryId.not_in(queue)).execute()

self._update_bad_queue_items()

Expand Down

0 comments on commit ffeecb0

Please sign in to comment.