(self)
Starts the queue monitor
Starts the queue monitor
Starts the queue monitor
def start(self):
        """Starts the queue monitor"""
        # fmt: off
        self._queue_monitor_task = asyncio.ensure_future(queue_exception_checker(
            self._queue_monitor(),
            self.error_queue,
        ))
def start ( self ) : # fmt: off self . _queue_monitor_task = asyncio . ensure_future ( queue_exception_checker ( self . _queue_monitor ( ) , self . error_queue , ) )