X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=smart_future.py;h=8f23e7756b5417b15d89ba35c43dde971678ee14;hb=36fea7f15ed17150691b5b3ead75450e575229ef;hp=c097d53b7c849867db4dd7f81121097397d0bee3;hpb=ed8fa2b10b0177b15b7423263bdd390efde2f0c8;p=python_utils.git diff --git a/smart_future.py b/smart_future.py index c097d53..8f23e77 100644 --- a/smart_future.py +++ b/smart_future.py @@ -37,9 +37,7 @@ def wait_any(futures: List[SmartFuture], *, callback: Callable = None): def wait_all(futures: List[SmartFuture]) -> None: real_futures = [x.wrapped_future for x in futures] (done, not_done) = concurrent.futures.wait( - real_futures, - timeout=None, - return_when=concurrent.futures.ALL_COMPLETED + real_futures, timeout=None, return_when=concurrent.futures.ALL_COMPLETED ) assert len(done) == len(real_futures) assert len(not_done) == 0