github/nzbToMedia
1
0
Fork 0
mirror of https://github.com/clinton-hall/nzbToMedia.git synced 2025-08-24 06:55:21 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Move queue_item_identifier closer to point of use.

Browse source
This commit is contained in:
Labrys of Knossos 2022-12-03 13:03:26 -05:00
commit 2b049f6b20
1 changed files with 15 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

20
core/auto_process/managers/pymedusa.py
View file

@ -37,9 +37,19 @@ class PyMedusaApiV1(SickBeard):
def api_call(self) -> ProcessResult: def api_call(self) -> ProcessResult:
self._process_fork_prarams() self._process_fork_prarams()
logger.debug(f'Opening URL: {self.url} with params: {self.sb_init.fork_params}', self.sb_init.section) logger.debug(
f'Opening URL: {self.url} with params: {self.sb_init.fork_params}',
self.sb_init.section,
)
try: try:
response = self.session.get(self.url, auth=(self.sb_init.username, self.sb_init.password), params=self.sb_init.fork_params, stream=True, verify=False, timeout=(30, 1800)) response = self.session.get(
self.url,
auth=(self.sb_init.username, self.sb_init.password),
params=self.sb_init.fork_params,
stream=True,
verify=False,
timeout=(30, 1800),
)
except requests.ConnectionError: except requests.ConnectionError:
logger.error(f'Unable to open URL: {self.url}', self.sb_init.section) logger.error(f'Unable to open URL: {self.url}', self.sb_init.section)
return ProcessResult( return ProcessResult(
@ -167,12 +177,12 @@ class PyMedusaApiV2(SickBeard):
if status != 'success': if status != 'success':
return False return False
queueitem_identifier = jdata['queueItem']['identifier']
wait_for = int(self.sb_init.config.get('wait_for', 2)) wait_for = int(self.sb_init.config.get('wait_for', 2))
n = 0 n = 0
response = {} response = {}
url = f'{self.url}/{queueitem_identifier}'
queue_item_identifier = jdata['queueItem']['identifier']
url = f'{self.url}/{queue_item_identifier}'
while n < 12: # set up wait_for minutes to see if command completes.. while n < 12: # set up wait_for minutes to see if command completes..
time.sleep(5 * wait_for) time.sleep(5 * wait_for)
response = self._get_identifier_status(url) response = self._get_identifier_status(url)