0it [00:00, ?it/s]Traceback (most recent call last):


 "F:/pycharm/bert4keras/pretraining/data_utils.py", line 344, in <module>

max_queue_size=max_queue_size,


 "F:/pycharm/bert4keras/pretraining/data_utils.py", line 126, in process

callback=write_to_tfrecord,


 "F:\pycharm\bert4keras\bert4keras\snippets.py", line 105, in parallel_apply

pool = Pool(workers, worker_step, (in_queue, out_queue))


 "D:\software\anoconda\envs\keras_bert\lib\multiprocessing\context.py", line 119, in Pool

context=self.get_context())


 "D:\software\anoconda\envs\keras_bert\lib\multiprocessing\pool.py", line 174, in __init__

self._repopulate_pool()


 "D:\software\anoconda\envs\keras_bert\lib\multiprocessing\pool.py", line 239, in _repopulate_pool

w.start()


 "D:\software\anoconda\envs\keras_bert\lib\multiprocessing\process.py", line 105, in start

self._popen = self._Popen(self)


 "D:\software\anoconda\envs\keras_bert\lib\multiprocessing\context.py", line 322, in _Popen

return Popen(process_obj)


 "D:\software\anoconda\envs\keras_bert\lib\multiprocessing\popen_spawn_win32.py", line 65, in __init__

reduction.dump(process_obj, to_child)


 "D:\software\anoconda\envs\keras_bert\lib\multiprocessing\reduction.py", line 60, in dump

ForkingPickler(file, protocol).dump(obj)
AttributeError: Can't pickle local object 'parallel_apply.<locals>.worker_step'

Traceback (most recent call last):


 "<stdin>", line 1, in <module>
AttributeError: module 'typeguard' has no attribute '__version__'
