Closed tmrb closed 3 years ago
mfeurer
commented
3 years ago Hi @tmrb, thanks a lot for reporting this issue. It looks like you are using an old version of dask.distributed. The argument local_dir got renamed to local_directory (commit). Could you please let us know your version of dask.distributed and try whether a later version fixes the issue?
tmrb
commented
3 years ago using the later version (0.10.0) worked! tks
Em sex., 6 de nov. de 2020 às 13:36, Matthias Feurer < notifications@github.com> escreveu:
Hi @tmrb https://github.com/tmrb, thanks a lot for reporting this issue. It looks like you are using an old version of dask.distributed. The argument local_dir got renamed to local_directory (commit https://github.com/dask/distributed/commit/5437975b9c8f5bccb8ee0d39de80526412f83903). Could you please let us know your version of dask.distributed and try whether a later version fixes the issue?
— You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub https://github.com/automl/auto-sklearn/issues/1000#issuecomment-723176264, or unsubscribe https://github.com/notifications/unsubscribe-auth/ANKYWW3FEIGVYAICIEHXPQDSOQQXXANCNFSM4TM2VQOQ .
-- Thiago Moura da Rocha Bastos Mestrando em Ciências da Computação - UFPE Téc. Laboratório - UFPB Engenheiro Químico - Crea n°181796239-6 https://www.linkedin.com/in/thiago-bastos-644847146/ https://www.linkedin.com/in/thiago-bastos-644847146/ http://lattes.cnpq.br/5771316236931732
18 frames /usr/local/lib/python3.6/dist-packages/autosklearn/estimators.py in fit(self, X, y, X_test, y_test, feat_type, dataset_name) 587 y_test=y_test, 588 feat_type=feat_type, --> 589 dataset_name=dataset_name, 590 ) 591
/usr/local/lib/python3.6/dist-packages/autosklearn/estimators.py in fit(self, kwargs) 346 output_folder=self.outputfolder, 347 ) --> 348 self.automl.fit(load_models=self._load_models, kwargs) 349 350 return self
/usr/local/lib/python3.6/dist-packages/autosklearn/automl.py in fit(self, X, y, X_test, y_test, feat_type, dataset_name, only_return_configuration_space, load_models) 1215 only_return_configuration_space=only_return_configuration_space, 1216 load_models=load_models, -> 1217 ) 1218 1219 def predict(self, X, batch_size=None, n_jobs=1):
/usr/local/lib/python3.6/dist-packages/autosklearn/automl.py in fit(self, X, y, task, X_test, y_test, feat_type, dataset_name, only_return_configuration_space, load_models) 392 ): 393 self._create_dask_client() --> 394 else: 395 self._is_dask_client_internally_created = False 396
/usr/local/lib/python3.6/dist-packages/autosklearn/automl.py in _create_dask_client(self) 240 # file was deleted, so the client could not close 241 # the worker properly --> 242 ) 243 ) 244
/usr/local/lib/python3.6/dist-packages/distributed/deploy/local.py in init(self, n_workers, threads_per_worker, processes, loop, start, ip, scheduler_port, silence_logs, diagnostics_port, services, worker_services, service_kwargs, asynchronous, security, **worker_kwargs) 140 self.worker_kwargs['security'] = security 141 --> 142 self.start(ip=ip, n_workers=n_workers) 143 144 clusters_to_close.add(self)
/usr/local/lib/python3.6/dist-packages/distributed/deploy/local.py in start(self, kwargs) 177 self._started = self._start(kwargs) 178 else: --> 179 self.sync(self._start, **kwargs) 180 181 @gen.coroutine
/usr/local/lib/python3.6/dist-packages/distributed/deploy/local.py in sync(self, func, *args, *kwargs) 170 return future 171 else: --> 172 return sync(self.loop, func, args, kwargs) 173 174 def start(self, kwargs):
/usr/local/lib/python3.6/dist-packages/distributed/utils.py in sync(loop, func, *args, *kwargs) 275 e.wait(10) 276 if error[0]: --> 277 six.reraise(error[0]) 278 else: 279 return result[0]
/usr/local/lib/python3.6/dist-packages/six.py in reraise(tp, value, tb) 701 if value.traceback is not tb: 702 raise value.with_traceback(tb) --> 703 raise value 704 finally: 705 value = None
/usr/local/lib/python3.6/dist-packages/distributed/utils.py in f() 260 if timeout is not None: 261 future = gen.with_timeout(timedelta(seconds=timeout), future) --> 262 result[0] = yield future 263 except Exception as exc: 264 error[0] = sys.exc_info()
/usr/local/lib/python3.6/dist-packages/tornado/gen.py in run(self) 1131 1132 try: -> 1133 value = future.result() 1134 except Exception: 1135 self.had_exception = True
/usr/local/lib/python3.6/dist-packages/tornado/gen.py in run(self) 1139 if exc_info is not None: 1140 try: -> 1141 yielded = self.gen.throw(*exc_info) 1142 finally: 1143 # Break up a reference to itself
/usr/local/lib/python3.6/dist-packages/distributed/deploy/local.py in _start(self, ip, n_workers) 197 self.scheduler.start(scheduler_address) 198 --> 199 yield [self._start_worker(**self.worker_kwargs) for i in range(n_workers)] 200 201 self.status = 'running'
/usr/local/lib/python3.6/dist-packages/tornado/gen.py in run(self) 1131 1132 try: -> 1133 value = future.result() 1134 except Exception: 1135 self.had_exception = True
/usr/local/lib/python3.6/dist-packages/tornado/gen.py in callback(f) 881 for f in children: 882 try: --> 883 result_list.append(f.result()) 884 except Exception as e: 885 if future.done():
/usr/local/lib/python3.6/dist-packages/tornado/gen.py in wrapper(*args, **kwargs) 324 try: 325 orig_stack_contexts = stack_context._state.contexts --> 326 yielded = next(result) 327 if stack_context._state.contexts is not orig_stack_contexts: 328 yielded = _create_future()
/usr/local/lib/python3.6/dist-packages/distributed/deploy/local.py in _start_worker(self, death_timeout, kwargs) 217 w = W(self.scheduler.address, loop=self.loop, 218 death_timeout=death_timeout, --> 219 silence_logs=self.silence_logs, kwargs) 220 yield w._start() 221
/usr/local/lib/python3.6/dist-packages/distributed/worker.py in init(self, scheduler_ip, scheduler_port, scheduler_file, ncores, loop, local_dir, services, service_ports, name, reconnect, memory_limit, executor, resources, silence_logs, death_timeout, preload, preload_argv, security, contact_address, memory_monitor_interval, extensions, metrics, kwargs) 475 io_loop=self.loop, 476 connection_args=self.connection_args, --> 477 kwargs) 478 479 self.scheduler = self.rpc(scheduler_addr)
TypeError: init() got an unexpected keyword argument 'local_directory'