diff options
| author | Scott <[email protected]> | 2022-02-02 09:14:12 -0800 |
|---|---|---|
| committer | Scott <[email protected]> | 2022-02-02 09:14:12 -0800 |
| commit | a4bf4d05230474ad14243d67ac7f8c938f670e58 (patch) | |
| tree | 673fb8bea628ce51b942d93ba5df433732c7384e /smart_future.py | |
| parent | 971d4ba141459f78d10d5770b9459d1ead7d49a0 (diff) | |
More type annotations.
Diffstat (limited to 'smart_future.py')
| -rw-r--r-- | smart_future.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/smart_future.py b/smart_future.py index 604c149..1f6e6f0 100644 --- a/smart_future.py +++ b/smart_future.py @@ -5,7 +5,7 @@ import concurrent import concurrent.futures as fut import logging import traceback -from typing import Callable, List, TypeVar +from typing import Callable, List, Set, TypeVar from overrides import overrides @@ -27,11 +27,11 @@ def wait_any( ): real_futures = [] smart_future_by_real_future = {} - completed_futures = set() - for f in futures: - assert type(f) == SmartFuture - real_futures.append(f.wrapped_future) - smart_future_by_real_future[f.wrapped_future] = f + completed_futures: Set[fut.Future] = set() + for x in futures: + assert type(x) == SmartFuture + real_futures.append(x.wrapped_future) + smart_future_by_real_future[x.wrapped_future] = x while len(completed_futures) != len(real_futures): newly_completed_futures = concurrent.futures.as_completed(real_futures) @@ -59,9 +59,9 @@ def wait_all( log_exceptions: bool = True, ) -> None: real_futures = [] - for f in futures: - assert type(f) == SmartFuture - real_futures.append(f.wrapped_future) + for x in futures: + assert type(x) == SmartFuture + real_futures.append(x.wrapped_future) (done, not_done) = concurrent.futures.wait( real_futures, timeout=None, return_when=concurrent.futures.ALL_COMPLETED |
