      # <<< INTERNAL METHODS >>> #
      @property
      def _output_queue(self):
          """ Return the correct output queue depending on the current phase """
          qname = "extract_align_out" if self.final_pass else "extract_align_in"
          retval = self._queues[qname]
          logger.trace("%s: %s", qname, retval)
          return retval
  
      @property
 
</s> remove             logger.debug("Switching to align phase")
            self.phase = "align"
 </s> add             self.phase = "align" if self.phase == "detect" else "mask"
            logger.debug("Switching to %s phase", self.phase) </s> remove         if self._is_parallel or self.phase == "detect":
            qname = "extract_detect_in"
        else:
            qname = "extract_align_in"
 </s> add         qname_dict = dict(detect="extract_detect_in",
                          align="extract_align_in",
                          mask="extract_mask_in")
        qname = "extract_detect_in" if self._is_parallel else qname_dict[self.phase] </s> remove             retval = [self._detector, self._aligner]
        elif self.passes == 2 and not self.final_pass:
 </s> add             retval = [self._detector, self._aligner, self._masker]
        elif self.passes == 3 and self.phase == 'detect': </s> remove         retval = 1 if self._is_parallel else 2
 </s> add         retval = 1 if self._is_parallel else 3 </s> remove         retval = bool(opts.get("mask_type", None) or opts["warp_to_landmarks"])
 </s> add         retval = opts["warp_to_landmarks"]
        qname_dict = dict(detect="extract_align_in",
                          align="extract_mask_in",
                          mask="extract_mask_out")
        qname = "extract_mask_out" if self.final_pass else qname_dict[self.phase]
      # <<< INTERNAL METHODS >>> #
      @property
      def _output_queue(self):
          """ Return the correct output queue depending on the current phase """
        qname_dict = dict(detect="extract_align_in",
                          align="extract_mask_in",
                          mask="extract_mask_out")
        qname = "extract_mask_out" if self.final_pass else qname_dict[self.phase]
          retval = self._queues[qname]
          logger.trace("%s: %s", qname, retval)
          return retval
  
      @property
keep keep keep keep replace keep keep keep keep keep
 Smart Mask Exposure for Extraction & Training (#831)

Smart Masks - Initial Commit 
plugins/extract/pipeline.py