[Errno 32] Broken pip

[MrXiaoZhen]

hi, i have a problem about train.py:
2019-04-09 16:59:35.321468
Progress: [##########] 100% Done...99999%
mean loss: 8.890891
Process ForkPoolWorker-1:35:
Traceback (most recent call last):
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/pool.py", line 125, in worker
put((job, i, result))
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/queues.py", line 347, in put
self._writer.send_bytes(obj)
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/connection.py", line 200, in send_bytes
self._send_bytes(m[offset:offset + size])
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/connection.py", line 397, in _send_bytes
self._send(header)
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/connection.py", line 368, 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/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/process.py", line 252, in _bootstrap
self.run()
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/process.py", line 93, in run
self._target(*self._args, **self._kwargs)
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/pool.py", line 130, in worker
put((job, i, (False, wrapped)))
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/queues.py", line 347, in put
self._writer.send_bytes(obj)
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/connection.py", line 200, in send_bytes
self._send_bytes(m[offset:offset + size])
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/connection.py", line 404, in _send_bytes
self._send(header + buf)
File "/home/student/anaconda3/envs/tensorflow1.4/lib/python3.5/multiprocessing/connection.py", line 368, in _send
n = write(self._handle, buf)
BrokenPipeError: [Errno 32] Broken pipe

Do you know how to solve it? thanks a lot!!!