  
  class ConsumerBuffer():
      """ Memory buffer for consuming """
      def __init__(self, dispatcher, index, data):
          logger.debug("Initializing %s: (dispatcher: '%s', index: %s, data: %s)",
                       self.__class__.__name__, dispatcher, index, data)
          self._data = data
          self._id = index
          self._dispatcher = dispatcher
          logger.debug("Initialized %s", self.__class__.__name__)
 
</s> remove         logger.debug("Initializing %s: (index: '%s', data: %s, stop_event: %s, queue: %s)",
 </s> add         logger.trace("Initializing %s: (index: '%s', data: %s, stop_event: %s, queue: %s)", </s> remove         logger.debug("Initialized %s", self.__class__.__name__)
 </s> add         logger.trace("Initialized %s", self.__class__.__name__) </s> remove         logger.debug("Initialized %s", self.__class__.__name__)
 </s> add         logger.trace("Initialized %s", self.__class__.__name__) </s> remove         self._result_tokens.close()
 </s> add         self._buffer_tokens.close()
        logger.trace("Initializing %s: (dispatcher: '%s', index: %s, data: %s)",
  
  class ConsumerBuffer():
      """ Memory buffer for consuming """
      def __init__(self, dispatcher, index, data):
        logger.trace("Initializing %s: (dispatcher: '%s', index: %s, data: %s)",
                       self.__class__.__name__, dispatcher, index, data)
          self._data = data
          self._id = index
          self._dispatcher = dispatcher
          logger.debug("Initialized %s", self.__class__.__name__)
keep keep keep keep replace keep keep keep keep keep
 mask shape fix + logging level 
lib/multithreading.py