Skip to content

Commit

Permalink
Fix ValueError for persistent pools on multithreaded setups
Browse files Browse the repository at this point in the history
  • Loading branch information
vitiko98 committed Apr 1, 2022
1 parent 4f42cd9 commit 86d6c21
Showing 1 changed file with 11 additions and 1 deletion.
12 changes: 11 additions & 1 deletion libs/subliminal_patch/core.py
Expand Up @@ -548,9 +548,19 @@ def __init__(self, max_workers=None, *args, **kwargs):
super(SZAsyncProviderPool, self).__init__(*args, **kwargs)

#: Maximum number of threads to use
self.max_workers = max_workers or len(self.providers)
self._max_workers_set = max_workers is not None
self.max_workers = (max_workers or len(self.providers)) or 1
logger.info("Using %d threads for %d providers (%s)", self.max_workers, len(self.providers), self.providers)

def update(self, *args, **kwargs):
updated = super().update(*args, **kwargs)

if (len(self.providers) and not self._max_workers_set) and len(self.providers) != self.max_workers:
logger.debug("This pool will use %d threads from now on", len(self.providers))
self.max_workers = len(self.providers)

return updated

def list_subtitles_provider(self, provider, video, languages):
# list subtitles
provider_subtitles = None
Expand Down

0 comments on commit 86d6c21

Please sign in to comment.