'Replicate dbs under the given root in an infinite loop.'

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

    sleep((random.random() * self.interval))
    while True:
        begin = time.time()
        try:
            self.run_once()
        except (Exception, Timeout):
            self.logger.exception(_('ERROR    trying    to    replicate'))
        elapsed = (time.time() - begin)
        if (elapsed < self.interval):
            sleep((self.interval - elapsed))
