          index: int
              The index of this plugin type within the flow, if there are multiple plugins in use
              otherwise ``None`` if there is only 1 plugin in use for the given phase
          """
          idx = flow_phase.split("_")[-1]
          if idx.isdigit():
              idx = int(idx)
              plugin_type = "_".join(flow_phase.split("_")[:-1])
          else:
              plugin_type = flow_phase
              idx = None
          return plugin_type, idx
 
</s> remove     def _add_queues(self):
 </s> add     def _add_queues(self) -> Dict[str, EventQueue]: </s> remove         logger.trace("Active plugins: %s", retval)
 </s> add         logger.trace("Active plugins: %s", retval)  # type: ignore </s> remove         logger.trace("All Plugins: %s", retval)
 </s> add         logger.trace("All Plugins: %s", retval)  # type: ignore </s> remove         logger.trace(retval)
 </s> add         logger.trace(retval)  # type: ignore </s> remove     def _get_plugin_type_and_index(flow_phase):
 </s> add     def _get_plugin_type_and_index(flow_phase: str) -> Tuple[str, Optional[int]]:
        sidx = flow_phase.split("_")[-1]
        if sidx.isdigit():
            idx: Optional[int] = int(sidx)
          index: int
              The index of this plugin type within the flow, if there are multiple plugins in use
              otherwise ``None`` if there is only 1 plugin in use for the given phase
          """
        sidx = flow_phase.split("_")[-1]
        if sidx.isdigit():
            idx: Optional[int] = int(sidx)
        sidx = flow_phase.split("_")[-1]
        if sidx.isdigit():
            idx: Optional[int] = int(sidx)
        sidx = flow_phase.split("_")[-1]
        if sidx.isdigit():
            idx: Optional[int] = int(sidx)
              plugin_type = "_".join(flow_phase.split("_")[:-1])
          else:
              plugin_type = flow_phase
              idx = None
          return plugin_type, idx
keep keep keep keep replace replace replace keep keep keep keep keep
 extract: Add batch processing mode 
plugins/extract/pipeline.py