                           "swapped_faces: %s)", item["filename"], len(item["detected_faces"]),
                           len(item["reference_faces"]), item["swapped_faces"].shape[0])
              pointer += num_faces
          self._out_queue.put(batch)
          logger.trace("Queued out batch. Batchsize: %s", len(batch))
  
  
  class OptionalActions():  # pylint:disable=too-few-public-methods
      """ Process specific optional actions for Convert.
  
 
</s> remove         logger.trace("Patched faces")
 </s> add         logger.trace("Patched faces")  # type: ignore </s> remove     @staticmethod
    def process(old_face, new_face, raw_mask):
 </s> add     def process(self, old_face, new_face, raw_mask): </s> remove     def flush_queue(self, q_name):
        """ Empty out a specific queue """
        logger.debug("QueueManager flushing: '%s'", q_name)
        queue = self.queues[q_name]
 </s> add     def flush_queue(self, name: str) -> None:
        """ Flush the contents from a managed queue.

        Parameters
        ----------
        name: str
            The name of the managed :class:`EventQueue` to flush
        """
        logger.debug("QueueManager flushing: '%s'", name)
        queue = self.queues[name] </s> remove class QueueManager():
    """ Manage queues for availabilty across processes
        Don't import this class directly, instead
        import the variable: queue_manager """
    def __init__(self):
 </s> add class EventQueue(Queue):
    """ Standard Queue object with a separate global shutdown parameter indicating that the main
    process, and by extension this queue, should be shut down.

    Parameters
    ----------
    shutdown_event: :class:`threading.Event`
        The global shutdown event common to all managed queues
    maxsize: int, Optional
        Upperbound limit on the number of items that can be placed in the queue. Default: `0`
    """
    def __init__(self, shutdown_event: threading.Event, maxsize: int = 0) -> None:
        super().__init__(maxsize=maxsize)
        self._shutdown = shutdown_event

    @property
    def shutdown(self) -> threading.Event:
        """ :class:`threading.Event`: The global shutdown event """
        return self._shutdown


class _QueueManager():
    """ Manage :class:`EventQueue` objects for availabilty across processes.

        Notes
        -----
        Don't import this class directly, instead import via :func:`queue_manager` """
    def __init__(self) -> None: </s> remove     def flush_queues(self):
        """ Empty out all queues """
 </s> add     def _flush_queues(self):
        """ Empty out the contents of every managed queue. """
        logger.trace("Queued out batch. Batchsize: %s", len(batch))  # type:ignore
                           "swapped_faces: %s)", item["filename"], len(item["detected_faces"]),
                           len(item["reference_faces"]), item["swapped_faces"].shape[0])
              pointer += num_faces
          self._out_queue.put(batch)
        logger.trace("Queued out batch. Batchsize: %s", len(batch))  # type:ignore
  
  
  class OptionalActions():  # pylint:disable=too-few-public-methods
      """ Process specific optional actions for Convert.
  
keep keep keep keep replace keep keep keep keep keep
 Bugfix: convert - Gif Writer
  - Fix non-launch error on Gif Writer
  - convert plugins - linting
  - convert/fs_media/preview/queue_manager - typing
  - Change convert items from dict to Dataclass 
scripts/convert.py