diff options
| author | Adam Janovsky | 2022-02-11 16:39:23 +0100 |
|---|---|---|
| committer | Adam Janovsky | 2022-02-11 16:39:23 +0100 |
| commit | 2100a11ffeca76dc96a644c44de0b509c6665faa (patch) | |
| tree | c81148bd73f781ee5d25e858e53bf32ce6edccc8 /sec_certs/parallel_processing.py | |
| parent | ca32a675ddf50bb1df3045cc37d89c72cb0b9fee (diff) | |
| download | sec-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.py | 4 |
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 = ( |
