docs: def _auto_commit(self):
          """
          Check if we have to commit based on number of messages and commit
          """
  
          # Check if we are supposed to do an auto-commit
          if not self.auto_commit or self.auto_commit_every_n is None:
              return
  
          if self.count_since_commit >= self.auto_commit_every_n:
              self.commit()