          return data, np_data
  
      def _create_worker(self, kwargs):
          """ Create Worker """
          return mp.Process(target=self._runner, kwargs=kwargs)
  
      def free(self, index):
          """ Free memory """
          if self._stop_event.is_set():
              return
 
</s> remove         batch = self.get_next(is_preview_iteration)
 </s> add         batch = self.get_next(do_preview) </s> remove     def train_one_batch(self, is_preview_iteration):
 </s> add     def train_one_batch(self, do_preview): </s> remove     def get_next(self, is_preview_iteration):
 </s> add     def get_next(self, do_preview): </s> remove         self.target = batch[1] if is_preview_iteration else None
 </s> add         self.target = batch[1] if do_preview else None
        return self.CTX.Process(target=self._runner, kwargs=kwargs)
          return data, np_data
  
      def _create_worker(self, kwargs):
          """ Create Worker """
        return self.CTX.Process(target=self._runner, kwargs=kwargs)
  
      def free(self, index):
          """ Free memory """
          if self._stop_event.is_set():
              return
keep keep keep keep replace keep keep keep keep keep
 Minor FixedProducerDispatcher changes. Fix timelapse bug 
lib/multithreading.py