d_mcknight/Varken
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(sonarr): ensure invalid sonarr queue items are just skipped over - fixes #239 (#243)

Browse source
This commit is contained in:
Nathan Adams 2022-07-18 17:10:29 +02:00 committed by GitHub
parent a197cb63f8
commit b077508a3e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
varken/sonarr.py
View file

@ -105,7 +105,8 @@ class SonarrAPI(object):
endpoint = '/api/v3/queue' endpoint = '/api/v3/queue'
now = datetime.now(timezone.utc).astimezone().isoformat() now = datetime.now(timezone.utc).astimezone().isoformat()
pageSize = 250 pageSize = 250
params = {'pageSize': pageSize, 'includeSeries': True, 'includeEpisode': True} params = {'pageSize': pageSize, 'includeSeries': True, 'includeEpisode': True,
'includeUnknownSeriesItems': False}
queueResponse = [] queueResponse = []
queue = [] queue = []
@ -119,7 +120,8 @@ class SonarrAPI(object):
while response.totalRecords > response.page * response.pageSize: while response.totalRecords > response.page * response.pageSize:
page = response.page + 1 page = response.page + 1
params = {'pageSize': pageSize, 'page': page, 'includeSeries': True, 'includeEpisode': True} params = {'pageSize': pageSize, 'page': page, 'includeSeries': True, 'includeEpisode': True,
'includeUnknownSeriesItems': False}
req = self.session.prepare_request(Request('GET', self.server.url + endpoint, params=params)) req = self.session.prepare_request(Request('GET', self.server.url + endpoint, params=params))
get = connection_handler(self.session, req, self.server.verify_ssl) get = connection_handler(self.session, req, self.server.verify_ssl)
if not get: if not get:
@ -140,8 +142,8 @@ class SonarrAPI(object):
for queueItem in download_queue: for queueItem in download_queue:
tvShow = SonarrTVShow(**queueItem.series) tvShow = SonarrTVShow(**queueItem.series)
episode = SonarrEpisode(**queueItem.episode)
try: try:
episode = SonarrEpisode(**queueItem.episode)
sxe = f"S{episode.seasonNumber:0>2}E{episode.episodeNumber:0>2}" sxe = f"S{episode.seasonNumber:0>2}E{episode.episodeNumber:0>2}"
except TypeError as e: except TypeError as e:
self.logger.error('TypeError has occurred : %s while processing the sonarr queue. \ self.logger.error('TypeError has occurred : %s while processing the sonarr queue. \