summaryrefslogtreecommitdiff
path: root/smart_future.py
diff options
context:
space:
mode:
authorScott <[email protected]>2022-02-02 09:14:12 -0800
committerScott <[email protected]>2022-02-02 09:14:12 -0800
commita4bf4d05230474ad14243d67ac7f8c938f670e58 (patch)
tree673fb8bea628ce51b942d93ba5df433732c7384e /smart_future.py
parent971d4ba141459f78d10d5770b9459d1ead7d49a0 (diff)
More type annotations.
Diffstat (limited to 'smart_future.py')
-rw-r--r--smart_future.py18
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