code: def processed_records(self, records):
          
          for record in records:
              self.logger.debug('Marking as processed: %s', record)
              record.processed = True
          db.session.commit()
docs: Executed after successfully uploading a batch of records from the queue.
  
          :param records: a list of queue entries