diff --git a/.bumpversion.cfg b/.bumpversion.cfg index 579736dd..891b8c0a 100644 --- a/.bumpversion.cfg +++ b/.bumpversion.cfg @@ -1,5 +1,5 @@ [bumpversion] -current_version = 12.1.06 +current_version = 12.1.07 commit = True tag = False diff --git a/TorrentToMedia.py b/TorrentToMedia.py index 28f09d76..56a9b5a7 100755 --- a/TorrentToMedia.py +++ b/TorrentToMedia.py @@ -333,9 +333,9 @@ def main(args): (os.path.basename(dir_name))) core.DOWNLOAD_INFO = core.get_download_info(os.path.basename(dir_name), 0) if core.DOWNLOAD_INFO: - client_agent = text_type(core.DOWNLOAD_INFO[0].get('client_agent', 'manual')) - input_hash = text_type(core.DOWNLOAD_INFO[0].get('input_hash', '')) - input_id = text_type(core.DOWNLOAD_INFO[0].get('input_id', '')) + client_agent = text_type(core.DOWNLOAD_INFO[0]['client_agent']) or 'manual' + input_hash = text_type(core.DOWNLOAD_INFO[0]['input_hash']) or '' + input_id = text_type(core.DOWNLOAD_INFO[0]['input_id']) or '' logger.info('Found download info for {0}, ' 'setting variables now ...'.format(os.path.basename(dir_name))) else: diff --git a/core/__init__.py b/core/__init__.py index 04c9dbf5..aa644bca 100644 --- a/core/__init__.py +++ b/core/__init__.py @@ -83,7 +83,7 @@ from core.utils import ( wake_up, ) -__version__ = '12.1.06' +__version__ = '12.1.07' # Client Agents NZB_CLIENTS = ['sabnzbd', 'nzbget', 'manual'] @@ -118,7 +118,7 @@ FORKS = { FORK_MEDUSA: {'proc_dir': None, 'failed': None, 'process_method': None, 'force': None, 'delete_on': None, 'ignore_subs': None}, FORK_MEDUSA_API: {'path': None, 'failed': None, 'process_method': None, 'force_replace': None, 'return_data': None, 'type': None, 'delete_files': None, 'is_priority': None, 'cmd': 'postprocess'}, FORK_SICKGEAR: {'dir': None, 'failed': None, 'process_method': None, 'force': None}, - FORK_SICKGEAR_API: {'path': None, 'process_method': None, 'force_replace': None, 'return_data': None, 'type': None, 'is priority': None, 'cmd': 'sg.postprocess'}, + FORK_SICKGEAR_API: {'path': None, 'process_method': None, 'force_replace': None, 'return_data': None, 'type': None, 'is priority': None, 'failed': None, 'cmd': 'sg.postprocess'}, FORK_STHENO: {'proc_dir': None, 'failed': None, 'process_method': None, 'force': None, 'delete_on': None, 'ignore_subs': None}, } ALL_FORKS = {k: None for k in set(list(itertools.chain.from_iterable([FORKS[x].keys() for x in FORKS.keys()])))} diff --git a/core/auto_process/tv.py b/core/auto_process/tv.py index a06a1985..8d4d5654 100644 --- a/core/auto_process/tv.py +++ b/core/auto_process/tv.py @@ -188,6 +188,8 @@ def process(section, dir_name, input_name=None, failed=False, client_agent='manu for param in copy.copy(fork_params): if param == 'failed': + if failed > 1: + failed = 1 fork_params[param] = failed if 'proc_type' in fork_params: del fork_params['proc_type'] diff --git a/libs/custom/syno/auth.py b/libs/custom/syno/auth.py index ef8d2f8e..fb3a4927 100644 --- a/libs/custom/syno/auth.py +++ b/libs/custom/syno/auth.py @@ -97,7 +97,7 @@ class Authentication: req_param['_sid'] = self._sid - if method is 'get': + if method == 'get': url = ('%s%s' % (self._base_url, api_path)) + '?api=' + api_name response = requests.get(url, req_param) @@ -106,7 +106,7 @@ class Authentication: else: return response - elif method is 'post': + elif method == 'post': url = ('%s%s' % (self._base_url, api_path)) + '?api=' + api_name response = requests.post(url, req_param) @@ -121,4 +121,4 @@ class Authentication: @property def base_url(self): - return self._base_url \ No newline at end of file + return self._base_url diff --git a/nzbToMedia.py b/nzbToMedia.py index 485b2279..0cc0b796 100755 --- a/nzbToMedia.py +++ b/nzbToMedia.py @@ -1016,8 +1016,8 @@ def main(args, section=None): logger.info('Found download info for {0}, ' 'setting variables now ...'.format (os.path.basename(dir_name))) - client_agent = text_type(core.DOWNLOAD_INFO[0].get('client_agent', 'manual')) - download_id = text_type(core.DOWNLOAD_INFO[0].get('input_id', '')) + client_agent = text_type(core.DOWNLOAD_INFO[0]['client_agent']) or 'manual' + download_id = text_type(core.DOWNLOAD_INFO[0]['input_id']) or '' else: logger.info('Unable to locate download info for {0}, ' 'continuing to try and process this release ...'.format diff --git a/nzbToWatcher3.py b/nzbToWatcher3.py old mode 100644 new mode 100755 diff --git a/setup.py b/setup.py index 3de2a100..0ac63738 100644 --- a/setup.py +++ b/setup.py @@ -23,7 +23,7 @@ def read(*names, **kwargs): setup( name='nzbToMedia', - version='12.1.06', + version='12.1.07', license='GPLv3', description='Efficient on demand post processing', long_description="""