              queue = self.queues[name]
          logger.debug("QueueManager got: '%s'", name)
          return queue
  
      def terminate_queues(self):
          """ Set shutdown event, clear and send EOF to all queues
              To be called if there is an error """
          logger.debug("QueueManager terminating all queues")
          self.shutdown.set()
          self.flush_queues()
          for q_name, queue in self.queues.items():
              logger.debug("QueueManager terminating: '%s'", q_name)
 
</s> remove         self.flush_queues()
 </s> add         self._flush_queues() </s> remove     def flush_queues(self):
        """ Empty out all queues """
 </s> add     def _flush_queues(self):
        """ Empty out the contents of every managed queue. """ </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         queue = self.queues.get(name, None)
 </s> add         queue = self.queues.get(name) </s> remove     def del_queue(self, name):
        """ remove a queue from the manager """
 </s> add     def del_queue(self, name: str) -> None:
        """ Remove a queue from the manager

        Parameters
        ----------
        name: str
            The name of the queue to be deleted. Must exist within the queue manager.
        """
    def terminate_queues(self) -> None:
        """ Terminates all managed queues.

        Sets the global shutdown event, clears and send EOF to all queues.  To be called if there
        is an error """
              queue = self.queues[name]
          logger.debug("QueueManager got: '%s'", name)
          return queue
  
    def terminate_queues(self) -> None:
        """ Terminates all managed queues.

        Sets the global shutdown event, clears and send EOF to all queues.  To be called if there
        is an error """
    def terminate_queues(self) -> None:
        """ Terminates all managed queues.

        Sets the global shutdown event, clears and send EOF to all queues.  To be called if there
        is an error """
    def terminate_queues(self) -> None:
        """ Terminates all managed queues.

        Sets the global shutdown event, clears and send EOF to all queues.  To be called if there
        is an error """
          logger.debug("QueueManager terminating all queues")
          self.shutdown.set()
          self.flush_queues()
          for q_name, queue in self.queues.items():
              logger.debug("QueueManager terminating: '%s'", q_name)
keep keep keep keep replace replace 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 
lib/queue_manager.py