          for filename, image in self._images.load():
              if load_queue.shutdown.is_set():
                  logger.debug("Load Queue: Stop signal received. Terminating")
                  break
              item = {"filename": filename,
                      "image": image[..., :3]}
              load_queue.put(item)
          load_queue.put("EOF")
          logger.debug("Load Images: Complete")
  
      def _reload(self, detected_faces):
 
</s> remove             detect_item = detected_faces.pop(filename, None)
            if not detect_item:
 </s> add             extract_media = detected_faces.pop(filename, None)
            if not extract_media: </s> remove             Dictionary of detected_faces with the filename as its key and a list of
            :class:`lib.faces_detect.DetectedFace` as the values for pairing with reloaded images.
 </s> add             Dictionary of :class:`plugins.extract.pipeline.ExtractMedia` with the filename as the
            key for repopulating the image attribute. </s> remove             detect_item["image"] = image
            load_queue.put(detect_item)
 </s> add             extract_media.set_image(image)
            load_queue.put(extract_media) </s> remove         filename, extension = os.path.splitext(os.path.basename(faces["filename"]))
        for idx, face in enumerate(faces["detected_faces"]):
 </s> add         filename, extension = os.path.splitext(os.path.basename(extract_media.filename))
        for idx, face in enumerate(extract_media.detected_faces): </s> remove         logger.trace("Outputting faces for %s", faces["filename"])
 </s> add         logger.trace("Outputting faces for %s", extract_media.filename)
            item = ExtractMedia(filename, image[..., :3])
          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])
            item = ExtractMedia(filename, image[..., :3])
              load_queue.put(item)
          load_queue.put("EOF")
          logger.debug("Load Images: Complete")
  
      def _reload(self, detected_faces):
keep keep keep keep replace replace keep keep keep keep keep
 plugins.extract - Create ExtractMedia class for pipeline flow
Bugfix - Fix memory leak in extract 
scripts/extract.py