      def _add_queues(self):
          """ Add the required processing queues to Queue Manager """
          queues = dict()
          tasks = ["extract_{}_in".format(phase) for phase in self._flow]
          tasks.append("extract_{}_out".format(self._final_phase))
          for task in tasks:
              # Limit queue size to avoid stacking ram
              queue_manager.add_queue(task, maxsize=self._queue_size)
              queues[task] = queue_manager.get_queue(task)
 
</s> remove         if masker is not None and masker.lower() != "none":
            retval.append("mask")
 </s> add         for idx, mask in enumerate(masker):
            if mask is not None and mask.lower() != "none":
                retval.append("mask_{}".format(idx)) </s> remove     colorformat: str
 </s> add     color_format: str </s> remove                          self._queues["post"],
 </s> add                          self._queues["post_{}".format(name)], </s> remove         The normalization method is dictated by the command line argument `-nh (--normalization)`
 </s> add         The normalization method is dictated by the normalization command line argument </s> remove         logger.info("sample filename: %s, base filename: %s", sample_filename, basename)
 </s> add         logger.debug("sample filename: %s, base filename: %s", sample_filename, basename)
        tasks = []
      def _add_queues(self):
          """ Add the required processing queues to Queue Manager """
          queues = dict()
        tasks = []
          tasks = ["extract_{}_in".format(phase) for phase in self._flow]
          tasks.append("extract_{}_out".format(self._final_phase))
          for task in tasks:
              # Limit queue size to avoid stacking ram
              queue_manager.add_queue(task, maxsize=self._queue_size)
              queues[task] = queue_manager.get_queue(task)
keep keep add keep keep keep keep keep keep
 Extraction - Auto generate Components and Extended Masks 
plugins/extract/pipeline.py