diff --git a/distributed/core.py b/distributed/core.py index 9aaf535191c..c55abf4b6df 100644 --- a/distributed/core.py +++ b/distributed/core.py @@ -167,6 +167,10 @@ def __init__( self.io_loop = io_loop or IOLoop.current() self.loop = self.io_loop + if kwargs: + for key in kwargs: + raise NameError(f"{self.__class__.__name__} has no such option {key}.") + if not hasattr(self.io_loop, "profile"): ref = weakref.ref(self.io_loop) @@ -238,7 +242,7 @@ def set_thread_ident(): self.__stopped = False - super().__init__(**kwargs) + super().__init__() @property def status(self):