smart_future_by_real_future[x.wrapped_future] = x
while len(completed_futures) != len(real_futures):
- print("TOP...")
try:
newly_completed_futures = concurrent.futures.as_completed(real_futures, timeout=timeout)
for f in newly_completed_futures:
raise exception
yield smart_future_by_real_future[f]
except TimeoutError:
- print(f"HERE!!! {len(completed_futures)} / {len(real_futures)}.")
if callback is not None:
callback()
if callback is not None: