          if self._rollover:
              logger.trace("Getting from _rollover: (filename: `%s`, faces: %s)",
                           self._rollover["filename"], len(self._rollover["detected_faces"]))
              item = self._rollover
              self._rollover = dict()
          else:
              item = self._get_item(queue)
              if item != "EOF":
                  logger.trace("Getting from queue: (filename: %s, faces: %s)",
                               item["filename"], len(item["detected_faces"]))
 
</s>
            self._rollover = None
          if self._rollover:
              logger.trace("Getting from _rollover: (filename: `%s`, faces: %s)",
                           self._rollover["filename"], len(self._rollover["detected_faces"]))
              item = self._rollover
            self._rollover = None
          else:
              item = self._get_item(queue)
              if item != "EOF":
                  logger.trace("Getting from queue: (filename: %s, faces: %s)",
                               item["filename"], len(item["detected_faces"]))
keep keep keep keep replace keep keep keep keep keep
 plugins.extract - Create ExtractMedia class for pipeline flow
Bugfix - Fix memory leak in extract
plugins/extract/mask/_base.py