          for q_name in self.queues:
              self.flush_queue(q_name)
          logger.debug("QueueManager flushed all queues")
  
      def flush_queue(self, q_name):
          """ Empty out a specific queue """
          logger.debug("QueueManager flushing: '%s'", q_name)
          queue = self.queues[q_name]
          while not queue.empty():
              queue.get(True, 1)
  
      def debug_monitor(self, update_secs=2):
          """ Debug tool for monitoring 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 debug_monitor(self, update_secs=2):
        """ Debug tool for monitoring queues """
        thread = threading.Thread(target=self.debug_queue_sizes,
                                  args=(update_secs, ))
 </s> add     def debug_monitor(self, update_interval: int = 2) -> None:
        """ A debug tool for monitoring managed :class:`EventQueues`.

        Prints queue sizes to the console for all managed queues.

        Parameters
        ----------
        update_interval: int, Optional
            The number of seconds between printing information to the console. Default: 2
        """
        thread = threading.Thread(target=self._debug_queue_sizes,
                                  args=(update_interval, )) </s> remove         self.flush_queues()
 </s> add         self._flush_queues() </s> remove     def terminate_queues(self):
        """ Set shutdown event, clear and send EOF to all queues
            To be called if there is an error """
 </s> add     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 """ </s> remove         queue = Queue(maxsize=maxsize)

        setattr(queue, "shutdown", self.shutdown)
        self.queues[name] = queue
 </s> add         self.queues[name] = EventQueue(self.shutdown, maxsize=maxsize)
    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]
          for q_name in self.queues:
              self.flush_queue(q_name)
          logger.debug("QueueManager flushed all queues")
  
    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]
    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]
    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]
    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]
          while not queue.empty():
              queue.get(True, 1)
  
      def debug_monitor(self, update_secs=2):
          """ Debug tool for monitoring queues """
keep keep keep keep replace 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