Revert "Fix: Keyword arguments to submit get caught (#1407)"

This reverts commit 6cc8bb1.

Author: eddiebergman

autosklearn/__version__.py

@@ -1,4 +1,4 @@
 """Version information."""
 
 # The following line *must* be the last in the module, exactly as formatted:
-__version__ = "0.14.6"
+__version__ = "0.14.4"

autosklearn/util/single_thread_client.py

@@ -1,6 +1,5 @@
 import typing
 from pathlib import Path
-from typing import Any
 
 import dask.distributed
 
@@ -10,7 +9,6 @@ class DummyFuture(dask.distributed.Future):
     A class that mimics a distributed Future, the outcome of
     performing submit on a distributed client.
     """
-
     def __init__(self, result: typing.Any) -> None:
         self._result = result  # type: typing.Any
 
@@ -35,24 +33,13 @@ class SingleThreadedClient(dask.distributed.Client):
     A class to Mock the Distributed Client class, in case
     Auto-Sklearn is meant to run in the current Thread.
     """
-
     def __init__(self) -> None:
 
         # Raise a not implemented error if using a method from Client
-        implemented_methods = [
-            "submit",
-            "close",
-            "shutdown",
-            "write_scheduler_file",
-            "_get_scheduler_info",
-            "nthreads",
-        ]
-        method_list = [
-            func
-            for func in dir(dask.distributed.Client)
-            if callable(getattr(dask.distributed.Client, func))
-            and not func.startswith("__")
-        ]
+        implemented_methods = ['submit', 'close', 'shutdown', 'write_scheduler_file',
+                               '_get_scheduler_info', 'nthreads']
+        method_list = [func for func in dir(dask.distributed.Client) if callable(
+            getattr(dask.distributed.Client, func)) and not func.startswith('__')]
         for method in method_list:
             if method in implemented_methods:
                 continue
@@ -67,24 +54,8 @@ def submit(
         func: typing.Callable,
         *args: typing.List,
         priority: int = 0,
-        key: Any = None,
-        workers: Any = None,
-        resources: Any = None,
-        retries: Any = None,
-        fifo_timeout: Any = "100 ms",
-        allow_other_workers: Any = False,
-        actor: Any = False,
-        actors: Any = False,
-        pure: Any = None,
-        **kwargs: Any,
+        **kwargs: typing.Dict,
     ) -> typing.Any:
-        """
-        Note
-        ----
-        The keyword arguments caught in `dask.distributed.Client` need to
-        be specified here so they don't get passed in as ``**kwargs`` to the
-        ``func``.
-        """
         return DummyFuture(func(*args, **kwargs))
 
     def close(self) -> None:
@@ -99,17 +70,17 @@ def write_scheduler_file(self, scheduler_file: str) -> None:
 
     def _get_scheduler_info(self) -> typing.Dict:
         return {
-            "workers": ["127.0.0.1"],
-            "type": "Scheduler",
+            'workers': ['127.0.0.1'],
+            'type': 'Scheduler',
         }
 
     def nthreads(self) -> typing.Dict:
         return {
-            "127.0.0.1": 1,
+            '127.0.0.1': 1,
         }
 
     def __repr__(self) -> str:
-        return "SingleThreadedClient()"
+        return 'SingleThreadedClient()'
 
     def __del__(self) -> None:
         pass

doc/releases.rst

@@ -9,16 +9,6 @@
 Releases
 ========
 
-Version 0.14.6
-==============
-
-* HOTFIX #1407: Catches keyword arguments in `SingleThreadedClient` so they don't get passed to it's executing `func`.
-
-Contributors v0.14.6
-********************
-* Eddie Bergman
-
-
 Version 0.14.5
 ==============