Merge pull request #437 from ungarj/release_2022.3.0

Release 2022.3.0
ungarj · Mar 9, 2022 · 1f41354 · 1f41354
2 parents 95bffc6 + b2a6363
commit 1f41354
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 2 deletions.
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -3,6 +3,15 @@ Changelog
 #########
 
 
+---------------------
+2022.3.0 - 2022-03-09
+---------------------
+
+* core
+  * use batches when yielding completed futures from dask
+  * fix ``KeyError`` when removing futures from threads executor
+
+
 ---------------------
 2022.2.2 - 2022-02-25
 ---------------------

diff --git a/mapchete/__init__.py b/mapchete/__init__.py
@@ -9,7 +9,7 @@
 
 
 __all__ = ["open", "count_tiles", "Mapchete", "MapcheteProcess", "ProcessInfo", "Timer"]
-__version__ = "2022.2.2"
+__version__ = "2022.3.0"
 
 
 logger = logging.getLogger(__name__)

diff --git a/mapchete/_executor.py b/mapchete/_executor.py
@@ -180,7 +180,10 @@ def _finished_future(self, future, result=None, _dask=False):
         Release future from cluster explicitly and wrap result around FinishedFuture object.
         """
         if not _dask:
-            self.running_futures.remove(future)
+            try:
+                self.running_futures.remove(future)
+            except KeyError:  # pragma: no cover
+                pass
         self.finished_futures.discard(future)
         fut_exception = future.exception(timeout=FUTURE_TIMEOUT)
         if fut_exception:  # pragma: no cover