aboutsummaryrefslogtreecommitdiffhomepage
path: root/sec_certs/parallel_processing.py
diff options
context:
space:
mode:
authorAdam Janovsky2022-02-11 16:39:23 +0100
committerAdam Janovsky2022-02-11 16:39:23 +0100
commit2100a11ffeca76dc96a644c44de0b509c6665faa (patch)
treec81148bd73f781ee5d25e858e53bf32ce6edccc8 /sec_certs/parallel_processing.py
parentca32a675ddf50bb1df3045cc37d89c72cb0b9fee (diff)
downloadsec-certs-2100a11ffeca76dc96a644c44de0b509c6665faa.tar.gz
sec-certs-2100a11ffeca76dc96a644c44de0b509c6665faa.tar.zst
sec-certs-2100a11ffeca76dc96a644c44de0b509c6665faa.zip
finalize type hints in helpers
Diffstat (limited to 'sec_certs/parallel_processing.py')
-rw-r--r--sec_certs/parallel_processing.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/sec_certs/parallel_processing.py b/sec_certs/parallel_processing.py
index 7a150070..6e1c28a6 100644
--- a/sec_certs/parallel_processing.py
+++ b/sec_certs/parallel_processing.py
@@ -1,6 +1,6 @@
import time
from multiprocessing.pool import ThreadPool
-from typing import Callable, Iterable, Optional, Union
+from typing import Any, Callable, Iterable, List, Optional, Union
from billiard.pool import Pool
@@ -16,7 +16,7 @@ def process_parallel(
progress_bar: bool = True,
unpack: bool = False,
progress_bar_desc: Optional[str] = None,
-):
+) -> List[Any]:
pool: Union[Pool, ThreadPool] = ThreadPool(max_workers) if use_threading else Pool(max_workers)
results = (