      @property
      def _final_phase(self):
          """ Return the final phase from the flow list """
          retval = self._flow[-1]
          logger.trace(retval)
          return retval
  
      @property
      def _output_queue(self):
          """ Return the correct output queue depending on the current phase """
 
</s> remove     def _final_phase(self):
 </s> add     def _final_phase(self) -> str: </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     def input_queue(self):
 </s> add     def input_queue(self) -> EventQueue: </s> remove         logger.trace(retval)
 </s> add         logger.trace(retval)  # type: ignore
        logger.trace(retval)  # type: ignore
      @property
      def _final_phase(self):
          """ Return the final phase from the flow list """
          retval = self._flow[-1]
        logger.trace(retval)  # type: ignore
          return retval
  
      @property
      def _output_queue(self):
          """ Return the correct output queue depending on the current phase """
keep keep keep keep replace keep keep keep keep keep
 extract: Add batch processing mode 
plugins/extract/pipeline.py