                                    args=(update_secs, ))
          thread.daemon = True
          thread.start()
  
      def debug_queue_sizes(self, update_secs):
          """ Output the queue sizes
              logged to INFO so it also displays in console
          """
          while True:
              logger.info("====================================================")
              for name in sorted(self.queues.keys()):
                  logger.info("%s: %s", name, self.queues[name].qsize())
 
</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             sleep(update_secs)
 </s> add             sleep(update_interval) </s> remove queue_manager = QueueManager()  # pylint: disable=invalid-name
 </s> add queue_manager = _QueueManager()  # pylint: disable=invalid-name </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) </s> remove         queue = self.queues.get(name, None)
 </s> add         queue = self.queues.get(name)
    def _debug_queue_sizes(self, update_interval) -> None:
        """ Print the queue size for each managed queue to console.

        Parameters
        ----------
        update_interval: int
            The number of seconds between printing information to the console
                                    args=(update_secs, ))
          thread.daemon = True
          thread.start()
  
    def _debug_queue_sizes(self, update_interval) -> None:
        """ Print the queue size for each managed queue to console.

        Parameters
        ----------
        update_interval: int
            The number of seconds between printing information to the console
    def _debug_queue_sizes(self, update_interval) -> None:
        """ Print the queue size for each managed queue to console.

        Parameters
        ----------
        update_interval: int
            The number of seconds between printing information to the console
    def _debug_queue_sizes(self, update_interval) -> None:
        """ Print the queue size for each managed queue to console.

        Parameters
        ----------
        update_interval: int
            The number of seconds between printing information to the console
          """
          while True:
              logger.info("====================================================")
              for name in sorted(self.queues.keys()):
                  logger.info("%s: %s", name, self.queues[name].qsize())
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