changelog and DaskExecutor.from_kwargs

cluster_tools/Changelog.md

@@ -10,8 +10,10 @@ For upgrade instructions, please check the respective *Breaking Changes* section
 [Commits](https://github.com/scalableminds/webknossos-libs/compare/v0.13.6...HEAD)
 
 ### Breaking Changes
+- Dropped support for Python 3.7. [#943](https://github.com/scalableminds/webknossos-libs/pull/943)
 
 ### Added
+- Added `DaskScheduler` (only Python >= 3.9). [#943](https://github.com/scalableminds/webknossos-libs/pull/943)
 
 ### Changed
 

cluster_tools/cluster_tools/__init__.py

@@ -110,7 +110,10 @@ def get_executor(environment: str, **kwargs: Any) -> "Executor":
     elif environment == "kubernetes":
         return KubernetesExecutor(**kwargs)
     elif environment == "dask":
-        return DaskExecutor(**kwargs)
+        if "client" in kwargs:
+            return DaskExecutor(kwargs["client"])
+        else:
+            return DaskExecutor.from_kwargs(**kwargs)
     elif environment == "multiprocessing":
         global did_start_test_multiprocessing
         if not did_start_test_multiprocessing:

cluster_tools/cluster_tools/executors/dask.py

@@ -32,11 +32,18 @@ class DaskExecutor(futures.Executor):
 
     def __init__(
         self,
-        **kwargs: Any,
+        client: "Client",
     ) -> None:
+        self.client = client
+
+    @classmethod
+    def from_kwargs(
+        cls,
+        **kwargs: Any,
+    ) -> "DaskExecutor":
         from distributed import Client
 
-        self.client = Client(**kwargs)
+        return cls(Client(**kwargs))
 
     @classmethod
     def as_completed(cls, futures: List["Future[_T]"]) -> Iterator["Future[_T]"]:

webknossos/Changelog.md

@@ -17,6 +17,7 @@ For upgrade instructions, please check the respective _Breaking Changes_ section
 ### Added
 
 ### Changed
+- Updates various dependencies. [#943](https://github.com/scalableminds/webknossos-libs/pull/943)
 
 ### Fixed
 - Fixed a bug in writing compressed data. [#942](https://github.com/scalableminds/webknossos-libs/pull/942)