Skip to content

S
seminar-breakout
Commit 2a712afe authored by Yuxin Wu's avatar Yuxin Wu
Browse files
Options

fix #809

parent d079b37c
Show whitespace changes
Inline Side-by-side
Showing with 0 additions and 1 deletion
tensorpack/dataflow/parallel_map.py
View file @ 2a712afe
...@@ -268,7 +268,6 @@ class MultiProcessMapDataZMQ(_ParallelMapData, _MultiProcessZMQDataFlow): ...@@ -268,7 +268,6 @@ class MultiProcessMapDataZMQ(_ParallelMapData, _MultiProcessZMQDataFlow):
self.ds.reset_state() self.ds.reset_state()
self._iter = self.ds.get_data() self._iter = self.ds.get_data()
self._iter_worker = _repeat_iter(lambda: iter(self._proc_ids))
self._start_processes() self._start_processes()
self._fill_buffer() # pre-fill the bufer self._fill_buffer() # pre-fill the bufer
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment