|
|
@@ -53,7 +53,7 @@ def run_with_executor(executor: Executor, func, tasks: List, timeout: int):
|
|
|
results.append(future.result())
|
|
|
return results
|
|
|
"""
|
|
|
-
|
|
|
+ """
|
|
|
results = []
|
|
|
# Iterate over tasks and execute them sequentially
|
|
|
for task in tasks:
|
|
|
@@ -74,9 +74,8 @@ def run_with_executor(executor: Executor, func, tasks: List, timeout: int):
|
|
|
for future in concurrent.futures.as_completed(futures, timeout=timeout):
|
|
|
if future.exception():
|
|
|
raise future.exception()
|
|
|
-
|
|
|
+
|
|
|
if future.done():
|
|
|
results.append(future.result())
|
|
|
|
|
|
return results
|
|
|
- """
|
