class_docstr: Wraps any observer and puts processing of events in the background.
  
  If the covered observer fails to process an event, the queue observer
  will retry until it works. This is useful for observers that rely on
  external services like databases that might become temporarily
  unavailable.
docstr: Initialize QueueObserver.
  
  Parameters
  ----------
  covered_observer
      The real observer that is being wrapped.
  interval
      The interval in seconds at which the background thread is woken up to process new events.
  retry_interval
      The interval in seconds to wait if an event failed to be processed.
docstr_tok: ["Initialize","QueueObserver",".","Parameters","--","--","--","--","--","covered_observer","The","real","observer","that","is","being","wrapped",".","interval","The","interval","in","seconds","at","which","the","background","thread","is","woken","up","to","process","new","events",".","retry_interval","The","interval","in","seconds","to","wait","if","an","event","failed","to","be","processed","."]
code: def __init__(
      self,
      covered_observer: RunObserver,
      interval: float = 20.0,
      retry_interval: float = 10.0,
  ):
      """Initialize QueueObserver.
  
      Parameters
      ----------
      covered_observer
          The real observer that is being wrapped.
      interval
          The interval in seconds at which the background thread is woken up to process new events.
      retry_interval
          The interval in seconds to wait if an event failed to be processed.
      """
      self._covered_observer = covered_observer
      self._retry_interval = retry_interval
      self._interval = interval
      self._queue = None
      self._worker = None
      self._stop_worker_event = None
      logger.debug("just testing")
  
imports: from collections import namedtuple
  from queue import Queue
  from sacred.observers.base import RunObserver
  from sacred.utils import IntervalTimer
  import traceback
  import logging
label_desc: Use image node_id 1 to create a new QueueObserver object from inherited base classes: RunObserver with example: obj = QueueObserver(covered_observer, interval, retry_interval)