diff --git a/oktoberfest/utils/multiprocessing_pool.py b/oktoberfest/utils/multiprocessing_pool.py index 167c03d..6287e6e 100644 --- a/oktoberfest/utils/multiprocessing_pool.py +++ b/oktoberfest/utils/multiprocessing_pool.py @@ -39,9 +39,8 @@ def check_pool(self): res_len = len(self.results) with tqdm(total=res_len, desc="Waiting for tasks to complete", leave=True) as progress: for res in self.results: - outputs.append(res.get(timeout=10000000)) # 10000 seconds = ~3 hours + outputs.append(res.get(timeout=10000)) # 10000 seconds = ~3 hours progress.update(1) - self.pool.close() self.pool.join() return outputs