Traceback (most recent call last):
File "/tmp/venv/lib/python3.8/site-packages/distributed/comm/core.py", line 285, in connect
comm = await asyncio.wait_for(
File "/usr/lib/python3.8/asyncio/tasks.py", line 490, in wait_for
raise exceptions.TimeoutError()
asyncio.exceptions.TimeoutError
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/tmp/venv/bin/wkz", line 33, in <module>
sys.exit(load_entry_point('workoutizer', 'console_scripts', 'wkz')())
File "/tmp/venv/lib/python3.8/site-packages/click/core.py", line 1137, in __call__
return self.main(*args, **kwargs)
File "/tmp/venv/lib/python3.8/site-packages/click/core.py", line 1062, in main
rv = self.invoke(ctx)
File "/tmp/venv/lib/python3.8/site-packages/click/core.py", line 1668, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "/tmp/venv/lib/python3.8/site-packages/click/core.py", line 1404, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/tmp/venv/lib/python3.8/site-packages/click/core.py", line 763, in invoke
return __callback(*args, **kwargs)
File "/workspaces/workoutizer/workoutizer/cli.py", line 40, in init
_init(import_demo_activities=demo)
File "/workspaces/workoutizer/workoutizer/cli.py", line 163, in _init
run_importer__dask(models, importing_demo_data=True)
File "/workspaces/workoutizer/wkz/file_importer.py", line 389, in run_importer__dask
sse.send(msg, "blue", "DEBUG")
File "/tmp/venv/lib/python3.8/site-packages/distributed/deploy/spec.py", line 454, in __exit__
super().__exit__(typ, value, traceback)
File "/tmp/venv/lib/python3.8/site-packages/distributed/deploy/cluster.py", line 419, in __exit__
return self.sync(self.__aexit__, typ, value, traceback)
File "/tmp/venv/lib/python3.8/site-packages/distributed/deploy/cluster.py", line 192, in sync
return sync(self.loop, func, *args, **kwargs)
File "/tmp/venv/lib/python3.8/site-packages/distributed/utils.py", line 354, in sync
raise exc.with_traceback(tb)
File "/tmp/venv/lib/python3.8/site-packages/distributed/utils.py", line 337, in f
result[0] = yield future
File "/tmp/venv/lib/python3.8/site-packages/tornado/gen.py", line 762, in run
value = future.result()
File "/tmp/venv/lib/python3.8/site-packages/tornado/ioloop.py", line 741, in _run_callback
ret = callback()
File "/tmp/venv/lib/python3.8/site-packages/tornado/ioloop.py", line 765, in _discard_future_result
future.result()
File "/tmp/venv/lib/python3.8/site-packages/distributed/deploy/cluster.py", line 428, in __aexit__
await f
File "/tmp/venv/lib/python3.8/site-packages/distributed/deploy/spec.py", line 426, in _close
await self._correct_state()
File "/tmp/venv/lib/python3.8/site-packages/distributed/deploy/spec.py", line 341, in _correct_state_internal
await self.scheduler_comm.retire_workers(workers=list(to_close))
File "/tmp/venv/lib/python3.8/site-packages/distributed/core.py", line 791, in send_recv_from_rpc
comm = await self.live_comm()
File "/tmp/venv/lib/python3.8/site-packages/distributed/core.py", line 749, in live_comm
comm = await connect(
File "/tmp/venv/lib/python3.8/site-packages/distributed/comm/core.py", line 309, in connect
raise IOError(
OSError: Timed out trying to connect to inproc://10.1.0.2/13/1 after 10 s