重试回滚注解 #decorator

retry_and_rollback.py

# frontera/contrib/backends/sqlalchemy/revisiting.py

def retry_and_rollback(func):
  def func_wrapper(self, *args, **kwargs):
    tries = 5
    while True:
      try:
        return func(self, *args, **kwargs)
      except Exception as exc:
        self.logger.exception(exc)
        self.session.rollback()
        sleep(5)
        tries -= 1
        if tries > 0:
          self.logger.info("Tries left %i" % tries)
          continue
        else:
          raise exc
  return func_wrapper