              Add face count per frame to self._faces_per_filename for joining
              batches back up in finalize """
          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":
 
</s> remove                          self._rollover["filename"], len(self._rollover["detected_faces"]))
 </s> add                          self._rollover.filename, len(self._rollover.detected_faces)) </s> remove         if self._rollover:
 </s> add         if self._rollover is not None: </s> remove         if self._rollover:
 </s> add         if self._rollover is not None: </s> remove             self._rollover = dict()
 </s> add             self._rollover = None </s> remove             self._rollover = dict()
 </s> add             self._rollover = None
                         self._rollover.filename, len(self._rollover.detected_faces))
              Add face count per frame to self._faces_per_filename for joining
              batches back up in finalize """
          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":
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/align/_base.py