We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 039680d commit 06dc5d0Copy full SHA for 06dc5d0
adaptive/runner.py
@@ -412,7 +412,10 @@ def _run(self):
412
remaining = self._remove_unfinished()
413
if remaining:
414
concurrent.wait(remaining)
415
- self._process_futures(remaining)
+ # Some futures get their result set
416
+ # see https://github.com/python-adaptive/adaptive/issues/319
417
+ with_result = [f for f in remaining if not f.cancelled() and f.done()]
418
+ self._process_futures(with_result)
419
self._cleanup()
420
421
def elapsed_time(self):
0 commit comments