broken pipeline after build_mtt.py

[wubinbai]

after implementing the build_mtt.py with dataset downloaded, it pops up broken pipeline error. How to solve? anyone know? Thanks

wb@i7:/media/wb/PSSD/TEMP/resemul$ ipy build_mtt.py Python 3.6.5 |Anaconda, Inc.| (default, Apr 29 2018, 16:14:56) Type 'copyright', 'credits' or 'license' for more information IPython 6.4.0 -- An enhanced Interactive Python. Type '?' for help. /home/wb/anaconda3/lib/python3.6/site-packages/tensorflow/python/framework/dtypes.py:523: FutureWarning: Passing (type, 1) or '1type' as a synonym of type is deprecated; in a future version of numpy, it will be understood as (type, (1,)) / '(1,)type'. _np_qint8 = np.dtype([("qint8", np.int8, 1)]) /home/wb/anaconda3/lib/python3.6/site-packages/tensorflow/python/framework/dtypes.py:524: FutureWarning: Passing (type, 1) or '1type' as a synonym of type is deprecated; in a future version of numpy, it will be understood as (type, (1,)) / '(1,)type'. _np_quint8 = np.dtype([("quint8", np.uint8, 1)]) /home/wb/anaconda3/lib/python3.6/site-packages/tensorflow/python/framework/dtypes.py:525: FutureWarning: Passing (type, 1) or '1type' as a synonym of type is deprecated; in a future version of numpy, it will be understood as (type, (1,)) / '(1,)type'. _np_qint16 = np.dtype([("qint16", np.int16, 1)]) /home/wb/anaconda3/lib/python3.6/site-packages/tensorflow/python/framework/dtypes.py:526: FutureWarning: Passing (type, 1) or '1type' as a synonym of type is deprecated; in a future version of numpy, it will be understood as (type, (1,)) / '(1,)type'. _np_quint16 = np.dtype([("quint16", np.uint16, 1)]) /home/wb/anaconda3/lib/python3.6/site-packages/tensorflow/python/framework/dtypes.py:527: FutureWarning: Passing (type, 1) or '1type' as a synonym of type is deprecated; in a future version of numpy, it will be understood as (type, (1,)) / '(1,)type'. _np_qint32 = np.dtype([("qint32", np.int32, 1)]) /home/wb/anaconda3/lib/python3.6/site-packages/tensorflow/python/framework/dtypes.py:532: FutureWarning: Passing (type, 1) or '1type' as a synonym of type is deprecated; in a future version of numpy, it will be understood as (type, (1,)) / '(1,)type'. np_resource = np.dtype([("resource", np.ubyte, 1)]) /home/wb/anaconda3/lib/python3.6/site-packages/h5py/init.py:36: FutureWarning: Conversion of the second argument of issubdtype from float to np.floating is deprecated. In future, it will be treated as np.float64 == np.dtype(float).type. from ._conv import register_converters as _register_converters Start building the dataset. 100 audios are written into "test-0038-of-0043.seq.tfrecord". 100 audios are written into "test-0041-of-0043.seq.tfrecord". 101 audios are written into "test-0002-of-0043.seq.tfrecord". 101 audios are written into "test-0013-of-0043.seq.tfrecord". 101 audios are written into "test-0003-of-0043.seq.tfrecord". 102 audios are written into "val-0007-of-0015.tfrecord". 101 audios are written into "val-0014-of-0015.tfrecord". 102 audios are written into "val-0013-of-0015.tfrecord". 100 audios are written into "train-0109-of-0152.tfrecord". 101 audios are written into "test-0028-of-0043.seq.tfrecord". 101 audios are written into "test-0021-of-0043.seq.tfrecord". 100 audios are written into "test-0037-of-0043.seq.tfrecord". 100 audios are written into "train-0069-of-0152.tfrecord". 100 audios are written into "train-0091-of-0152.tfrecord". 101 audios are written into "train-0048-of-0152.tfrecord". 100 audios are written into "train-0138-of-0152.tfrecord". 100 audios are written into "train-0131-of-0152.tfrecord". 100 audios are written into "train-0103-of-0152.tfrecord". 100 audios are written into "train-0050-of-0152.tfrecord". 100 audios are written into "train-0077-of-0152.tfrecord". 100 audios are written into "train-0059-of-0152.tfrecord". 100 audios are written into "train-0083-of-0152.tfrecord". 100 audios are written into "train-0089-of-0152.tfrecord". 101 audios are written into "train-0001-of-0152.tfrecord". 101 audios are written into "train-0015-of-0152.tfrecord". 101 audios are written into "train-0033-of-0152.tfrecord". 100 audios are written into "train-0076-of-0152.tfrecord". 101 audios are written into "train-0016-of-0152.tfrecord". 100 audios are written into "train-0105-of-0152.tfrecord". 101 audios are written into "train-0023-of-0152.tfrecord". 101 audios are written into "train-0008-of-0152.tfrecord". 101 audios are written into "train-0018-of-0152.tfrecord". 101 audios are written into "train-0030-of-0152.tfrecord". 100 audios are written into "train-0086-of-0152.tfrecord". 100 audios are written into "train-0106-of-0152.tfrecord". 101 audios are written into "train-0038-of-0152.tfrecord". 100 audios are written into "train-0075-of-0152.tfrecord". 100 audios are written into "train-0097-of-0152.tfrecord". 101 audios are written into "train-0002-of-0152.tfrecord". 100 audios are written into "train-0135-of-0152.tfrecord". 100 audios are written into "train-0061-of-0152.tfrecord". 101 audios are written into "train-0049-of-0152.tfrecord". 100 audios are written into "train-0085-of-0152.tfrecord". 100 audios are written into "train-0115-of-0152.tfrecord". 101 audios are written into "test-0000-of-0043.seq.tfrecord". 101 audios are written into "test-0010-of-0043.seq.tfrecord". 101 audios are written into "test-0006-of-0043.seq.tfrecord". 101 audios are written into "test-0031-of-0043.seq.tfrecord". 101 audios are written into "test-0011-of-0043.seq.tfrecord". 101 audios are written into "test-0012-of-0043.seq.tfrecord". 101 audios are written into "test-0019-of-0043.seq.tfrecord". 101 audios are written into "test-0020-of-0043.seq.tfrecord". 101 audios are written into "train-0011-of-0152.tfrecord". 100 audios are written into "train-0136-of-0152.tfrecord". 100 audios are written into "train-0066-of-0152.tfrecord". 100 audios are written into "train-0096-of-0152.tfrecord". 101 audios are written into "train-0041-of-0152.tfrecord". 100 audios are written into "train-0124-of-0152.tfrecord". 100 audios are written into "train-0053-of-0152.tfrecord". 101 audios are written into "train-0005-of-0152.tfrecord". 100 audios are written into "train-0098-of-0152.tfrecord". 100 audios are written into "train-0113-of-0152.tfrecord". 101 audios are written into "train-0003-of-0152.tfrecord". 100 audios are written into "train-0071-of-0152.tfrecord". 101 audios are written into "test-0014-of-0043.seq.tfrecord". 101 audios are written into "test-0007-of-0043.seq.tfrecord". 100 audios are written into "test-0034-of-0043.seq.tfrecord". 100 audios are written into "train-0073-of-0152.tfrecord". 100 audios are written into "train-0128-of-0152.tfrecord". 102 audios are written into "val-0008-of-0015.tfrecord". 102 audios are written into "val-0003-of-0015.tfrecord". 102 audios are written into "val-0005-of-0015.tfrecord". 100 audios are written into "test-0036-of-0043.seq.tfrecord". 101 audios are written into "test-0024-of-0043.seq.tfrecord". 100 audios are written into "train-0082-of-0152.tfrecord". 100 audios are written into "train-0080-of-0152.tfrecord". 100 audios are written into "train-0060-of-0152.tfrecord". 100 audios are written into "train-0112-of-0152.tfrecord". 100 audios are written into "train-0051-of-0152.tfrecord". 101 audios are written into "train-0013-of-0152.tfrecord". 100 audios are written into "train-0123-of-0152.tfrecord". 100 audios are written into "train-0140-of-0152.tfrecord". 101 audios are written into "train-0035-of-0152.tfrecord". 102 audios are written into "val-0012-of-0015.tfrecord". 101 audios are written into "test-0022-of-0043.seq.tfrecord". 102 audios are written into "val-0009-of-0015.tfrecord". 100 audios are written into "train-0107-of-0152.tfrecord". 101 audios are written into "train-0022-of-0152.tfrecord". 100 audios are written into "train-0064-of-0152.tfrecord". 100 audios are written into "train-0111-of-0152.tfrecord". 100 audios are written into "train-0058-of-0152.tfrecord". 100 audios are written into "train-0055-of-0152.tfrecord". 100 audios are written into "train-0129-of-0152.tfrecord". 101 audios are written into "train-0009-of-0152.tfrecord". 100 audios are written into "train-0139-of-0152.tfrecord". 101 audios are written into "train-0042-of-0152.tfrecord". 100 audios are written into "train-0119-of-0152.tfrecord". 101 audios are written into "train-0026-of-0152.tfrecord". 101 audios are written into "train-0000-of-0152.tfrecord". 102 audios are written into "val-0000-of-0015.tfrecord". 102 audios are written into "val-0002-of-0015.tfrecord". 102 audios are written into "val-0006-of-0015.tfrecord". 101 audios are written into "train-0019-of-0152.tfrecord". Process Process-1: Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/process.py", line 258, in _bootstrap self.run() File "/home/wb/anaconda3/lib/python3.6/multiprocessing/process.py", line 93, in run self._target(*self._args, **self._kwargs) File "/media/wb/PSSD/TEMP/resemul/build_mtt.py", line 49, in process_audio_files examples = audio_to_examples(audio_path, labels, sample_rate, num_samples) File "/media/wb/PSSD/TEMP/resemul/data/preprocessing/audio_processing.py", line 126, in audio_to_examples segments = _audio_to_segments(filename, sample_rate=sample_rate, num_samples=num_samples) File "/media/wb/PSSD/TEMP/resemul/data/preprocessing/audio_processing.py", line 85, in _audio_to_segments sig = Signal(filename, sample_rate=sample_rate, dtype=np.float32, stop=29, num_channels=1) File "/home/wb/anaconda3/lib/python3.6/site-packages/madmom/audio/signal.py", line 598, in new dtype=dtype) File "/home/wb/anaconda3/lib/python3.6/site-packages/madmom/io/audio.py", line 633, in load_audio_file raise LoadAudioFileError(error) madmom.io.audio.LoadAudioFileError: "All attempts to load audio file './dataset/mp3/9/american_baroque-dances_and_suites_of_rameau_and_couperin-25-le_petit_rien_xiveme_ordre_couperin-88-117.mp3' failed." 100 audios are written into "train-0052-of-0152.tfrecord". 101 audios are written into "train-0027-of-0152.tfrecord". 100 audios are written into "train-0150-of-0152.tfrecord". 100 audios are written into "train-0100-of-0152.tfrecord". 101 audios are written into "train-0007-of-0152.tfrecord". 100 audios are written into "train-0067-of-0152.tfrecord". 100 audios are written into "train-0078-of-0152.tfrecord". Process Process-2: Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/process.py", line 258, in _bootstrap self.run() File "/home/wb/anaconda3/lib/python3.6/multiprocessing/process.py", line 93, in run self._target(*self._args, **self._kwargs) File "/media/wb/PSSD/TEMP/resemul/build_mtt.py", line 49, in process_audio_files examples = audio_to_examples(audio_path, labels, sample_rate, num_samples) File "/media/wb/PSSD/TEMP/resemul/data/preprocessing/audio_processing.py", line 126, in audio_to_examples segments = _audio_to_segments(filename, sample_rate=sample_rate, num_samples=num_samples) File "/media/wb/PSSD/TEMP/resemul/data/preprocessing/audio_processing.py", line 85, in _audio_to_segments sig = Signal(filename, sample_rate=sample_rate, dtype=np.float32, stop=29, num_channels=1) File "/home/wb/anaconda3/lib/python3.6/site-packages/madmom/audio/signal.py", line 598, in new dtype=dtype) File "/home/wb/anaconda3/lib/python3.6/site-packages/madmom/io/audio.py", line 633, in load_audio_file raise LoadAudioFileError(error) madmom.io.audio.LoadAudioFileError: "All attempts to load audio file './dataset/mp3/8/jacob_heringman-josquin_des_prez_lute_settings-19-gintzler__pater_noster-204-233.mp3' failed." 100 audios are written into "train-0151-of-0152.tfrecord". 100 audios are written into "train-0134-of-0152.tfrecord". 101 audios are written into "train-0031-of-0152.tfrecord". 101 audios are written into "train-0043-of-0152.tfrecord". 100 audios are written into "train-0116-of-0152.tfrecord". 100 audios are written into "train-0063-of-0152.tfrecord". 100 audios are written into "train-0068-of-0152.tfrecord". 100 audios are written into "test-0039-of-0043.seq.tfrecord". 100 audios are written into "test-0033-of-0043.seq.tfrecord". 101 audios are written into "test-0001-of-0043.seq.tfrecord". 101 audios are written into "test-0004-of-0043.seq.tfrecord". 101 audios are written into "test-0005-of-0043.seq.tfrecord". 100 audios are written into "train-0141-of-0152.tfrecord". 101 audios are written into "train-0014-of-0152.tfrecord". 100 audios are written into "train-0102-of-0152.tfrecord". 101 audios are written into "train-0036-of-0152.tfrecord". 100 audios are written into "train-0108-of-0152.tfrecord". 101 audios are written into "test-0009-of-0043.seq.tfrecord". 101 audios are written into "test-0025-of-0043.seq.tfrecord". 100 audios are written into "train-0147-of-0152.tfrecord". 101 audios are written into "train-0028-of-0152.tfrecord". 100 audios are written into "train-0137-of-0152.tfrecord". 100 audios are written into "train-0092-of-0152.tfrecord". 102 audios are written into "val-0004-of-0015.tfrecord". 102 audios are written into "val-0011-of-0015.tfrecord". 102 audios are written into "val-0001-of-0015.tfrecord". 102 audios are written into "val-0010-of-0015.tfrecord". 100 audios are written into "train-0148-of-0152.tfrecord". 100 audios are written into "train-0099-of-0152.tfrecord". 100 audios are written into "train-0084-of-0152.tfrecord". 101 audios are written into "train-0034-of-0152.tfrecord". 101 audios are written into "train-0017-of-0152.tfrecord". Process Process-7: Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/process.py", line 258, in _bootstrap self.run() File "/home/wb/anaconda3/lib/python3.6/multiprocessing/process.py", line 93, in run self._target(*self._args, **self._kwargs) File "/media/wb/PSSD/TEMP/resemul/build_mtt.py", line 49, in process_audio_files examples = audio_to_examples(audio_path, labels, sample_rate, num_samples) File "/media/wb/PSSD/TEMP/resemul/data/preprocessing/audio_processing.py", line 126, in audio_to_examples segments = _audio_to_segments(filename, sample_rate=sample_rate, num_samples=num_samples) File "/media/wb/PSSD/TEMP/resemul/data/preprocessing/audio_processing.py", line 85, in _audio_to_segments sig = Signal(filename, sample_rate=sample_rate, dtype=np.float32, stop=29, num_channels=1) File "/home/wb/anaconda3/lib/python3.6/site-packages/madmom/audio/signal.py", line 598, in new dtype=dtype) File "/home/wb/anaconda3/lib/python3.6/site-packages/madmom/io/audio.py", line 633, in load_audio_file raise LoadAudioFileError(error) madmom.io.audio.LoadAudioFileError: "All attempts to load audio file './dataset/mp3/6/norine_braun-now_and_zen-08-gently-117-146.mp3' failed." Done.

In [1]: Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 398, in _send_bytes self._send(buf) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) ^[[12;1R^[[12;1R File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) ^[[12;1RBrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) ^[[12;1R File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe Traceback (most recent call last): File "/home/wb/anaconda3/lib/python3.6/multiprocessing/queues.py", line 240, in _feed send_bytes(obj) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 200, in send_bytes self._send_bytes(m[offset:offset + size]) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 397, in _send_bytes self._send(header) File "/home/wb/anaconda3/lib/python3.6/multiprocessing/connection.py", line 368, in _send n = write(self._handle, buf) BrokenPipeError: [Errno 32] Broken pipe

[nol-alb]

Has this resolved?