code: def run_initial(self, events):
          
          self_name = type(self).__name__
          for i, batch in enumerate(grouper(events, self.INITIAL_BATCH_SIZE, skip_missing=True), 1):
              self.logger.debug('%s processing initial batch %d', self_name, i)
  
              for j, processed_batch in enumerate(grouper(
                      batch, self.BATCH_SIZE, skip_missing=True), 1):
                  self.logger.info('%s uploading initial chunk #%d (batch %d)', self_name, j, i)
                  self.upload_records(processed_batch, from_queue=False)
docs: Runs the initial batch upload
  
          :param events: an iterable containing events