          This should be set prior to :func:`launch` if the batch size is to be manually overridden
  
          Parameters
          ----------
          plugin_type: {'aligner', 'detector'}
              The plugin_type to be overridden
          batchsize: int
              The batch size to use for this plugin type
          """
          logger.debug("Overriding batchsize for plugin_type: %s to: %s", plugin_type, batchsize)
 
</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: </s> remove     def launch(self):
 </s> add     def launch(self) -> None: </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         extractor_type: {'aligner', 'detector', 'masker'}
 </s> add         extractor_type: {'align', 'detect', 'mask'}
        plugin_type: {'align', 'detect'}
          This should be set prior to :func:`launch` if the batch size is to be manually overridden
  
          Parameters
          ----------
        plugin_type: {'align', 'detect'}
              The plugin_type to be overridden
          batchsize: int
              The batch size to use for this plugin type
          """
          logger.debug("Overriding batchsize for plugin_type: %s to: %s", plugin_type, batchsize)
keep keep keep keep replace keep keep keep keep keep
 extract: Add batch processing mode 
plugins/extract/pipeline.py