'Process every entry in the queue.'

def run_once(self, *args, **kwargs):

    try:
        self.reconcile()
    except:
        self.logger.exception('Unhandled    Exception    trying    to    reconcile')
    self.log_stats(force=True)
