try:
newly_completed_futures = concurrent.futures.as_completed(real_futures, timeout=timeout)
for f in newly_completed_futures:
try:
newly_completed_futures = concurrent.futures.as_completed(real_futures, timeout=timeout)
for f in newly_completed_futures: