  from lib.model import masks
  from lib.multithreading import FixedProducerDispatcher
  from lib.umeyama import umeyama
  
  logger = logging.getLogger(__name__)  # pylint: disable=invalid-name
  
  
  class TrainingDataGenerator():
 
</s> remove     def get_next(self, is_preview_iteration):
 </s> add     def get_next(self, do_preview): </s> remove         self.samples = batch[0] if is_preview_iteration else None
 </s> add         self.samples = batch[0] if do_preview else None </s> remove         self.target = batch[1] if is_preview_iteration else None
 </s> add         self.target = batch[1] if do_preview else None </s> remove     EVENT = mp.Event
    QUEUE = mp.Queue
 </s> add     CTX = mp.get_context("spawn")
    EVENT = CTX.Event
from lib.queue_manager import queue_manager
  from lib.model import masks
  from lib.multithreading import FixedProducerDispatcher
from lib.queue_manager import queue_manager
  from lib.umeyama import umeyama
  
  logger = logging.getLogger(__name__)  # pylint: disable=invalid-name
  
  
  class TrainingDataGenerator():
keep add keep keep keep keep keep keep
 Minor FixedProducerDispatcher changes. Fix timelapse bug 
lib/training_data.py