Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Mulitprocessing errors in pre-processing? #82

Open
rkube opened this issue Apr 25, 2022 · 1 comment
Open

Mulitprocessing errors in pre-processing? #82

rkube opened this issue Apr 25, 2022 · 1 comment

Comments

@rkube
Copy link
Contributor

rkube commented Apr 25, 2022

Hi,
I'm trying to pre-process the FRNN dataset on traverse and get these errors when running guarantee_preprocessed.py. Does anyone know what the cause of this may be?

Traceback (most recent call last):
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/process.py", line 315, in _bootstrap
    self.run()
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/process.py", line 108, in run
    self._target(*self._args, **self._kwargs)
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/pool.py", line 136, in worker
    put((job, i, (False, wrapped)))
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/queues.py", line 371, in put
    self._writer.send_bytes(obj)
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 203, in send_bytes
    self._send_bytes(m[offset:offset + size])
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 414, in _send_bytes
    self._send(header + buf)
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 371, in _send
    n = write(self._handle, buf)
BrokenPipeError: [Errno 32] Broken pipe
Signal Electron temperature profile, shot 150509 contains no data [omit]
...saved shot 150509
Process ForkPoolWorker-75:
Traceback (most recent call last):
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/pool.py", line 131, in worker
    put((job, i, result))
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/queues.py", line 371, in put
    self._writer.send_bytes(obj)
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 203, in send_bytes
    self._send_bytes(m[offset:offset + size])
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 414, in _send_bytes
    self._send(header + buf)
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 371, in _send
    n = write(self._handle, buf)
BrokenPipeError: [Errno 32] Broken pipe

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/process.py", line 315, in _bootstrap
    self.run()
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/process.py", line 108, in run
    self._target(*self._args, **self._kwargs)
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/pool.py", line 136, in worker
    put((job, i, (False, wrapped)))
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/queues.py", line 371, in put
    self._writer.send_bytes(obj)
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 203, in send_bytes
    self._send_bytes(m[offset:offset + size])
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 414, in _send_bytes
    self._send(header + buf)
  File "/home/rkube/.conda/envs/frnn/lib/python3.8/site-packages/multiprocess-0.70.12.2-py3.8.egg/multiprocess/connection.py", line 371, in _send
    n = write(self._handle, buf)
BrokenPipeError: [Errno 32] Broken pipe
...saved shot 147205
Signal Electron temperature profile, shot 139545 contains no data [omit]
Process ForkPoolWorker-71:
@rkube
Copy link
Contributor Author

rkube commented Apr 25, 2022

I've replaced pathos with https://docs.python.org/3/library/multiprocessing.html and I'm getting the same errors.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant