          for filename, image in self._images.load():
              if load_queue.shutdown.is_set():
                  logger.debug("Load Queue: Stop signal received. Terminating")
                  break
              item = ExtractMedia(filename, image[..., :3])
              load_queue.put(item)
          load_queue.put("EOF")
          logger.debug("Load Images: Complete")
  
      def _reload(self, detected_faces: Dict[str, ExtractMedia]) -> None:
 
</s> remove         self._run_extraction()
 </s> add     def reload(self, detected_faces: Dict[str, ExtractMedia]) -> None:
        """ Reload images for multiple pipeline passes """
        self._threaded_redirector("reload", (detected_faces, ))

    def check_thread_error(self) -> None:
        """ Check if any errors have occurred in the running threads and raise their errors """
        for thread in self._threads:
            thread.check_and_raise_error()

    def join(self) -> None:
        """ Join all open loader threads """ </s> remove                  detected_faces: Optional[List["DetectedFace"]] = None) -> None:
 </s> add                  detected_faces: Optional[List["DetectedFace"]] = None,
                 is_aligned: bool = False) -> None: </s> remove         media = ExtractMedia(filename, image, detected_faces=[detected_face])
 </s> add         media = ExtractMedia(filename, image, detected_faces=[detected_face], is_aligned=True) </s> remove                      "detected_faces: %s)", self.__class__.__name__, filename, image.shape,
                     detected_faces)
 </s> add                      "detected_faces: %s, is_aligned: %s)", self.__class__.__name__, filename,
                     image.shape, detected_faces, is_aligned) </s> remove             detected_faces = {}
 </s> add             detected_faces: Dict[str, ExtractMedia] = {}
            is_aligned = filename in self._aligned_filenames
            item = ExtractMedia(filename, image[..., :3], is_aligned=is_aligned)
          for filename, image in self._images.load():
              if load_queue.shutdown.is_set():
                  logger.debug("Load Queue: Stop signal received. Terminating")
                  break
            is_aligned = filename in self._aligned_filenames
            item = ExtractMedia(filename, image[..., :3], is_aligned=is_aligned)
              load_queue.put(item)
          load_queue.put("EOF")
          logger.debug("Load Images: Complete")
  
      def _reload(self, detected_faces: Dict[str, ExtractMedia]) -> None:
keep keep keep keep replace keep keep keep keep keep
 Update Face Filter
  - Remove old face filter
  - plugins.extract.pipeline: Expose plugins directly
  - Change `is_aligned` from plugin level to ExtractMedia level
  - Allow extract pipeline to take faceswap aligned images
  - Add ability for recognition plugins to accept aligned faces as input
  - Add face filter to recognition plugin
  - Move extractor pipeline IO ops to own class 
scripts/extract.py