Skip to content

Commit

Permalink
updated timeout to seconds instead of milliseconds
Browse files Browse the repository at this point in the history
  • Loading branch information
mostafakalhor committed Oct 28, 2024
1 parent 3c795ce commit 3a7e44e
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions oktoberfest/utils/multiprocessing_pool.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 3a7e44e

Please sign in to comment.