          >>>  'image': <the source image as a numpy.array in BGR color format>,
          >>>  'detected_faces: [<list of DetectedFace objects as generated from detect>]}
  
          """
          if self._is_parallel or self.phase == "detect":
              qname = "extract_detect_in"
          else:
              qname = "extract_align_in"
          retval = self._queues[qname]
          logger.trace("%s: %s", qname, retval)
          return retval
  
      @property
 
</s> remove         qname = "extract_align_out" if self.final_pass else "extract_align_in"
 </s> add         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] </s> remove         retval = self._is_parallel or self.phase == "align"
 </s> add         retval = self._is_parallel or self.phase == "mask" </s> remove         retval = 1 if self._is_parallel else 2
 </s> add         retval = 1 if self._is_parallel else 3 </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':
        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]
          >>>  'image': <the source image as a numpy.array in BGR color format>,
          >>>  'detected_faces: [<list of DetectedFace objects as generated from detect>]}
  
          """
        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]
        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]
        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]
        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]
          retval = self._queues[qname]
          logger.trace("%s: %s", qname, retval)
          return retval
  
      @property
keep keep keep keep replace replace replace replace keep keep keep keep keep
 Smart Mask Exposure for Extraction & Training (#831)

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