          self._queues = self._add_queues()
          logger.debug("Initialized %s", self.__class__.__name__)
  
      @property
      def input_queue(self):
          """ queue: Return the correct input queue depending on the current phase
  
          The input queue is the entry point into the extraction pipeline. An :class:`ExtractMedia`
          object should be put to the queue.
  
 
</s> remove         logger.trace(retval)
 </s> add         logger.trace(retval)  # type: ignore </s> remove     def _output_queue(self):
 </s> add     def _output_queue(self) -> EventQueue: </s> remove         logger.trace(retval)
 </s> add         logger.trace(retval)  # type: ignore </s> remove         logger.trace("Active plugins: %s", retval)
 </s> add         logger.trace("Active plugins: %s", retval)  # type: ignore </s> remove     def detected_faces(self):
 </s> add     def detected_faces(self) -> Generator["ExtractMedia", None, None]:
    def input_queue(self) -> EventQueue:
          self._queues = self._add_queues()
          logger.debug("Initialized %s", self.__class__.__name__)
  
      @property
    def input_queue(self) -> EventQueue:
          """ queue: Return the correct input queue depending on the current phase
  
          The input queue is the entry point into the extraction pipeline. An :class:`ExtractMedia`
          object should be put to the queue.
  
keep keep keep keep replace keep keep keep keep keep
 extract: Add batch processing mode 
plugins/extract/pipeline.py