code: def write_batch(self, batch):
          
          for item in batch:
              for key in item:
                  self.aggregated_info['occurrences'][key] += 1
              self.increment_written_items()
              if self.items_limit and self.items_limit == self.get_metadata('items_count'):
                  raise ItemsLimitReached('Finishing job after items_limit reached: {} items written.'
                                          .format(self.get_metadata('items_count')))
          self.logger.debug('Wrote items')
docs: Receives the batch and writes it. This method is usually called from a manager.