mstumped on linux #326
Replies: 3 comments
-
|
@fanaee This looks like a problem with the way that you've set up What happens when you try: Are you using a Jupyter notebook to run your code? |
Beta Was this translation helpful? Give feedback.
-
|
I am using your demo code: import stumpy your_time_series = np.random.rand(3, 1000) # Each row represents data from a different dimension while each column represents data from the same dimension matrix_profile, matrix_profile_indices = stumpy.mstumped(dask_client, your_time_series, m=window_size) |
Beta Was this translation helpful? Give feedback.
-
|
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
-
I am recieiving this error when using mstumped on linux. How can fix that?
/opt/anaconda3/lib/python3.8/site-packages/distributed/node.py:151: UserWarning: Port 8787 is already in use.
Perhaps you already have a cluster running?
Hosting the HTTP server on port 36967 instead
warnings.warn(
/opt/anaconda3/lib/python3.8/site-packages/distributed/node.py:151: UserWarning: Port 8787 is already in use.
Perhaps you already have a cluster running?
Hosting the HTTP server on port 43325 instead
warnings.warn(
/opt/anaconda3/lib/python3.8/site-packages/distributed/node.py:151: UserWarning: Port 8787 is already in use.
Perhaps you already have a cluster running?
Hosting the HTTP server on port 33449 instead
warnings.warn(
/opt/anaconda3/lib/python3.8/site-packages/distributed/node.py:151: UserWarning: Port 8787 is already in use.
Perhaps you already have a cluster running?
Hosting the HTTP server on port 41425 instead
warnings.warn(
Task exception was never retrieved
future: <Task finished name='Task-10' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-9' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-11' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-8' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-7' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-10' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-9' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-11' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-8' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-7' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
/opt/anaconda3/lib/python3.8/site-packages/distributed/node.py:151: UserWarning: Port 8787 is already in use.
Perhaps you already have a cluster running?
Hosting the HTTP server on port 35719 instead
warnings.warn(
Task exception was never retrieved
future: <Task finished name='Task-10' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-10' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-7' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-9' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-11' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-11' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-8' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-8' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-9' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-7' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-11' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-7' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-8' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-10' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
Task exception was never retrieved
future: <Task finished name='Task-9' coro=<_wrap_awaitable() done, defined at /opt/anaconda3/lib/python3.8/asyncio/tasks.py:677> exception=RuntimeError('\n An attempt has been made to start a new process before the\n current process has finished its bootstrapping phase.\n\n This probably means that you are not using fork to start your\n child processes and you have forgotten to use the proper idiom\n in the main module:\n\n if name == 'main':\n freeze_support()\n ...\n\n The "freeze_support()" line can be omitted if the program\n is not going to be frozen to produce an executable.')>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/asyncio/tasks.py", line 684, in _wrap_awaitable
return (yield from awaitable.await())
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 290, in _
await self.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 295, in start
response = await self.instantiate()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 378, in instantiate
result = await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 575, in start
await self.process.start()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 34, in _call_and_set_future
res = func(*args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/process.py", line 202, in _start
process.start()
File "/opt/anaconda3/lib/python3.8/multiprocessing/process.py", line 121, in start
self._popen = self._Popen(self)
File "/opt/anaconda3/lib/python3.8/multiprocessing/context.py", line 283, in _Popen
return Popen(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 32, in init
super().init(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_fork.py", line 19, in init
self._launch(process_obj)
File "/opt/anaconda3/lib/python3.8/multiprocessing/popen_spawn_posix.py", line 42, in _launch
prep_data = spawn.get_preparation_data(process_obj._name)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 154, in get_preparation_data
_check_not_importing_main()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 134, in _check_not_importing_main
raise RuntimeError('''
RuntimeError:
An attempt has been made to start a new process before the
current process has finished its bootstrapping phase.
^CTraceback (most recent call last):
File "", line 1, in
Traceback (most recent call last):
Traceback (most recent call last):
File "", line 1, in
Traceback (most recent call last):
File "", line 1, in
Traceback (most recent call last):
File "", line 1, in
Traceback (most recent call last):
File "", line 1, in
File "/home/stud1/h/hadfan20/.local/MPdemo.py", line 4, in
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 116, in spawn_main
exitcode = _main(fd, parent_sentinel)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 125, in _main
exitcode = _main(fd, parent_sentinel)
exitcode = _main(fd, parent_sentinel)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 125, in _main
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 125, in _main
exitcode = _main(fd, parent_sentinel)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 125, in _main
exitcode = _main(fd, parent_sentinel)
prepare(preparation_data)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 125, in _main
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 236, in prepare
prepare(preparation_data)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 236, in prepare
prepare(preparation_data)
prepare(preparation_data)
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 236, in prepare
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 236, in prepare
_fixup_main_from_path(data['init_main_from_path'])
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 287, in _fixup_main_from_path
prepare(preparation_data)
_fixup_main_from_path(data['init_main_from_path'])
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 236, in prepare
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 287, in _fixup_main_from_path
_fixup_main_from_path(data['init_main_from_path'])
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 287, in _fixup_main_from_path
_fixup_main_from_path(data['init_main_from_path'])
dask_client = Client()
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 287, in _fixup_main_from_path
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 744, in init
main_content = runpy.run_path(main_path,
main_content = runpy.run_path(main_path,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 265, in run_path
File "/opt/anaconda3/lib/python3.8/runpy.py", line 265, in run_path
main_content = runpy.run_path(main_path,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 265, in run_path
main_content = runpy.run_path(main_path,
_fixup_main_from_path(data['init_main_from_path'])
File "/opt/anaconda3/lib/python3.8/multiprocessing/spawn.py", line 287, in _fixup_main_from_path
return _run_module_code(code, init_globals, run_name,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 265, in run_path
File "/opt/anaconda3/lib/python3.8/runpy.py", line 97, in _run_module_code
return _run_module_code(code, init_globals, run_name,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 97, in _run_module_code
return _run_module_code(code, init_globals, run_name,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 97, in _run_module_code
self.start(timeout=timeout)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 948, in start
_run_code(code, mod_globals, init_globals,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 87, in _run_code
_run_code(code, mod_globals, init_globals,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 87, in _run_code
main_content = runpy.run_path(main_path,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 265, in run_path
_run_code(code, mod_globals, init_globals,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 87, in _run_code
return _run_module_code(code, init_globals, run_name,
exec(code, run_globals)
File "/opt/anaconda3/lib/python3.8/runpy.py", line 97, in _run_module_code
File "/home/stud1/h/hadfan20/.local/MPdemo.py", line 4, in
exec(code, run_globals)
File "/home/stud1/h/hadfan20/.local/MPdemo.py", line 4, in
exec(code, run_globals)
File "/home/stud1/h/hadfan20/.local/MPdemo.py", line 4, in
_run_code(code, mod_globals, init_globals,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 87, in _run_code
return _run_module_code(code, init_globals, run_name,
File "/opt/anaconda3/lib/python3.8/runpy.py", line 97, in _run_module_code
exec(code, run_globals)
File "/home/stud1/h/hadfan20/.local/MPdemo.py", line 4, in
sync(self.loop, self._start, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 336, in sync
_run_code(code, mod_globals, init_globals,
dask_client = Client()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 744, in init
File "/opt/anaconda3/lib/python3.8/runpy.py", line 87, in _run_code
e.wait(10)
exec(code, run_globals)
File "/opt/anaconda3/lib/python3.8/threading.py", line 558, in wait
File "/home/stud1/h/hadfan20/.local/MPdemo.py", line 4, in
dask_client = Client()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 744, in init
dask_client = Client()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 744, in init
self.start(timeout=timeout)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 948, in start
signaled = self._cond.wait(timeout)
File "/opt/anaconda3/lib/python3.8/threading.py", line 306, in wait
self.start(timeout=timeout)
dask_client = Client()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 948, in start
self.start(timeout=timeout)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 744, in init
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 948, in start
gotit = waiter.acquire(True, timeout)
dask_client = Client()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 744, in init
KeyboardInterrupt
sync(self.loop, self._start, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 336, in sync
e.wait(10)
File "/opt/anaconda3/lib/python3.8/threading.py", line 558, in wait
self.start(timeout=timeout)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 948, in start
sync(self.loop, self._start, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 336, in sync
sync(self.loop, self._start, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 336, in sync
self.start(timeout=timeout)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/client.py", line 948, in start
e.wait(10)
e.wait(10)
File "/opt/anaconda3/lib/python3.8/threading.py", line 558, in wait
sync(self.loop, self._start, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 336, in sync
File "/opt/anaconda3/lib/python3.8/threading.py", line 558, in wait
sync(self.loop, self._start, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 336, in sync
signaled = self._cond.wait(timeout)
File "/opt/anaconda3/lib/python3.8/threading.py", line 306, in wait
e.wait(10)
File "/opt/anaconda3/lib/python3.8/threading.py", line 558, in wait
distributed.utils - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 656, in log_errors
yield
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
distributed.core - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
tornado.application - ERROR - Exception in callback <bound method Nanny.memory_monitor of <Nanny: None, threads: 4>>
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 907, in _run
return self.callback()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 414, in memory_monitor
process = self.process.process
AttributeError: 'NoneType' object has no attribute 'process'
distributed.utils - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 656, in log_errors
yield
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
distributed.utils - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 656, in log_errors
yield
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
distributed.utils - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 656, in log_errors
yield
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
distributed.utils - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 656, in log_errors
yield
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
distributed.core - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
distributed.core - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
distributed.core - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
distributed.core - ERROR - addresses should be strings or tuples, got None
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
tornado.application - ERROR - Exception in callback functools.partial(<bound method IOLoop._discard_future_result of <tornado.platform.asyncio.AsyncIOLoop object at 0x7fb346f99c40>>, <Task finished name='Task-18' coro=<Nanny._on_exit() done, defined at /opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py:440> exception=TypeError('addresses should be strings or tuples, got None')>)
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 743, in _run_callback
ret = callback()
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 767, in _discard_future_result
future.result()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 443, in _on_exit
await self.scheduler.unregister(address=self.worker_address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 861, in send_recv_from_rpc
result = await send_recv(comm=comm, op=key, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 660, in send_recv
raise exc.with_traceback(tb)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
tornado.application - ERROR - Exception in callback functools.partial(<bound method IOLoop._discard_future_result of <tornado.platform.asyncio.AsyncIOLoop object at 0x7fb346f99c40>>, <Task finished name='Task-19' coro=<Nanny._on_exit() done, defined at /opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py:440> exception=TypeError('addresses should be strings or tuples, got None')>)
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 743, in _run_callback
ret = callback()
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 767, in _discard_future_result
future.result()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 443, in _on_exit
await self.scheduler.unregister(address=self.worker_address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 861, in send_recv_from_rpc
result = await send_recv(comm=comm, op=key, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 660, in send_recv
raise exc.with_traceback(tb)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
tornado.application - ERROR - Exception in callback functools.partial(<bound method IOLoop._discard_future_result of <tornado.platform.asyncio.AsyncIOLoop object at 0x7fb346f99c40>>, <Task finished name='Task-20' coro=<Nanny._on_exit() done, defined at /opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py:440> exception=TypeError('addresses should be strings or tuples, got None')>)
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 743, in _run_callback
ret = callback()
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 767, in _discard_future_result
future.result()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 443, in _on_exit
await self.scheduler.unregister(address=self.worker_address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 861, in send_recv_from_rpc
result = await send_recv(comm=comm, op=key, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 660, in send_recv
raise exc.with_traceback(tb)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
tornado.application - ERROR - Exception in callback functools.partial(<bound method IOLoop._discard_future_result of <tornado.platform.asyncio.AsyncIOLoop object at 0x7fb346f99c40>>, <Task finished name='Task-21' coro=<Nanny._on_exit() done, defined at /opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py:440> exception=TypeError('addresses should be strings or tuples, got None')>)
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 743, in _run_callback
ret = callback()
File "/opt/anaconda3/lib/python3.8/site-packages/tornado/ioloop.py", line 767, in _discard_future_result
future.result()
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/nanny.py", line 443, in _on_exit
await self.scheduler.unregister(address=self.worker_address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 861, in send_recv_from_rpc
result = await send_recv(comm=comm, op=key, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 660, in send_recv
raise exc.with_traceback(tb)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/core.py", line 513, in handle_comm
result = await result
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 2208, in remove_worker
address = self.coerce_address(address)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/scheduler.py", line 4946, in coerce_address
raise TypeError("addresses should be strings or tuples, got %r" % (addr,))
TypeError: addresses should be strings or tuples, got None
^CError in atexit._run_exitfuncs:
Traceback (most recent call last):
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/deploy/spec.py", line 622, in close_clusters
cluster.close(timeout=10)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/deploy/cluster.py", line 90, in close
return self.sync(self._close, callback_timeout=timeout)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/deploy/cluster.py", line 169, in sync
return sync(self.loop, func, *args, **kwargs)
File "/opt/anaconda3/lib/python3.8/site-packages/distributed/utils.py", line 336, in sync
e.wait(10)
File "/opt/anaconda3/lib/python3.8/threading.py", line 558, in wait
signaled = self._cond.wait(timeout)
File "/opt/anaconda3/lib/python3.8/threading.py", line 306, in wait
gotit = waiter.acquire(True, timeout)
KeyboardInterrupt
/opt/anaconda3/lib/python3.8/multiprocessing/resource_tracker.py:216: UserWarning: resource_tracker: There appear to be 150 leaked semaphore objects to clean up at shutdown
warnings.warn('resource_tracker: There appear to be %d '
Beta Was this translation helpful? Give feedback.
All reactions