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")
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.
        
sacred/observers/queue.py