call self._process_futures on canceled futures when BlockingRunner is done

basnijholt · basnijholt · commit 039680d2eb7c · 2021-05-26T21:44:48.000+02:00
diff --git a/adaptive/runner.py b/adaptive/runner.py
@@ -412,6 +412,7 @@ def _run(self):
             remaining = self._remove_unfinished()
             if remaining:
                 concurrent.wait(remaining)
+                self._process_futures(remaining)
             self._cleanup()
 
     def elapsed_time(self):
