code: def run(self):
          
          self.log.debug('consumer is running...')
  
          self.running = True
          while self.running:
              self.upload()
  
          self.log.debug('consumer exited.')
docs: Runs the consumer.