          >>>         extractor.input_queue.put({"filename": "path/to/image/file",
          >>>                                    "image": np.array(image),
          >>>                                    "detected_faces": [<DetectedFace objects]})
          """
          retval = self._is_parallel or self.phase == "align"
          logger.trace(retval)
          return retval
  
      def set_batchsize(self, plugin_type, batchsize):
          """ Set the batchsize of a given :attr:`plugin_type` to the given :attr:`batchsize`.
 
</s> remove         retval = 1 if self._is_parallel else 2
 </s> add         retval = 1 if self._is_parallel else 3 </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             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         self.image = image[self.top: self.bottom,
 </s> add         self.face = image[self.top: self.bottom,
        retval = self._is_parallel or self.phase == "mask"
          >>>         extractor.input_queue.put({"filename": "path/to/image/file",
          >>>                                    "image": np.array(image),
          >>>                                    "detected_faces": [<DetectedFace objects]})
          """
        retval = self._is_parallel or self.phase == "mask"
          logger.trace(retval)
          return retval
  
      def set_batchsize(self, plugin_type, batchsize):
          """ Set the batchsize of a given :attr:`plugin_type` to the given :attr:`batchsize`.
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