              plugin_type = flow_phase
              idx = None
          return plugin_type, idx
  
      def _add_queues(self):
          """ Add the required processing queues to Queue Manager """
          queues = {}
          tasks = [f"extract{self._instance}_{phase}_in" for phase in self._flow]
          tasks.append(f"extract{self._instance}_{self._final_phase}_out")
          for task in tasks:
 
</s> remove         idx = flow_phase.split("_")[-1]
        if idx.isdigit():
            idx = int(idx)
 </s> add         sidx = flow_phase.split("_")[-1]
        if sidx.isdigit():
            idx: Optional[int] = int(sidx) </s> remove     def _vram_per_phase(self):
 </s> add     def _vram_per_phase(self) -> Dict[str, float]: </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 _active_plugins(self):
 </s> add     def _active_plugins(self) -> List["PluginExtractor"]:
    def _add_queues(self) -> Dict[str, EventQueue]:
              plugin_type = flow_phase
              idx = None
          return plugin_type, idx
  
    def _add_queues(self) -> Dict[str, EventQueue]:
          """ Add the required processing queues to Queue Manager """
          queues = {}
          tasks = [f"extract{self._instance}_{phase}_in" for phase in self._flow]
          tasks.append(f"extract{self._instance}_{self._final_phase}_out")
          for task in tasks:
keep keep keep keep replace keep keep keep keep keep
 extract: Add batch processing mode 
plugins/extract/pipeline.py