          if get_backend() == "amd":
              logger.debug("Parallel processing disabled by amd")
              return False
  
          logger.verbose("%s - %sMB free of %sMB",
                         self._vram_stats["device"],
                         self._vram_stats["vram_free"],
                         self._vram_stats["vram_total"])
          if self._vram_stats["vram_free"] <= self._total_vram_required:
              logger.warning("Not enough free VRAM for parallel processing. "
 
</s> remove         if self._vram_stats["vram_free"] <= self._total_vram_required:
 </s> add         if cast(int, self._vram_stats["vram_free"]) <= self._total_vram_required: </s> remove         if plugins_required + batch_required <= self._vram_stats["vram_free"]:
 </s> add         if plugins_required + batch_required <= cast(int, self._vram_stats["vram_free"]): </s> remove     def _set_phases(self, multiprocess):
 </s> add     def _set_phases(self, multiprocess: bool) -> List[List[str]]: </s> remove         phases = []
        current_phase = []
        available = self._vram_stats["vram_free"]
 </s> add         phases: List[List[str]] = []
        current_phase: List[str] = []
        available = cast(int, self._vram_stats["vram_free"]) </s> remove     def set_batchsize(self, plugin_type, batchsize):
 </s> add     def reset_phase_index(self) -> None:
        """ Reset the current phase index back to 0. Used for when batch processing is used in
        extract. """
        self._phase_index = 0

    def set_batchsize(self,
                      plugin_type: Literal["align", "detect"],
                      batchsize: int) -> None:
        logger.verbose("%s - %sMB free of %sMB",  # type: ignore
          if get_backend() == "amd":
              logger.debug("Parallel processing disabled by amd")
              return False
  
        logger.verbose("%s - %sMB free of %sMB",  # type: ignore
                         self._vram_stats["device"],
                         self._vram_stats["vram_free"],
                         self._vram_stats["vram_total"])
          if self._vram_stats["vram_free"] <= self._total_vram_required:
              logger.warning("Not enough free VRAM for parallel processing. "
keep keep keep keep replace keep keep keep keep keep
 extract: Add batch processing mode 
plugins/extract/pipeline.py