old_contents: import json
  
  from exporters.writers.base_writer import BaseWriter, ItemsLimitReached
  
  
  class ConsoleWriter(BaseWriter):
      """
      It is just a writer with testing purposes. It prints every item in console.
      """
  
      def __init__(self, options):
          super(ConsoleWriter, self).__init__(options)
          self.logger.info('ConsoleWriter has been initiated')
          self.pretty_print = self.options.get('pretty_print', False)
  
      def write_batch(self, batch):
          for item in batch:
              print item.formatted
              self.increment_written_items()
              if self.items_limit and self.items_limit == self.stats.items_count:
                  raise ItemsLimitReached('Finishing job after items_limit reached: {} items written.'.format(self.stats.items_count))
          self.logger.debug('Wrote items')
  
new_contents: import json
  
  from exporters.writers.base_writer import BaseWriter, ItemsLimitReached
  
  
  class ConsoleWriter(BaseWriter):
      """
      It is just a writer with testing purposes. It prints every item in console.
      """
  
      def __init__(self, options):
          super(ConsoleWriter, self).__init__(options)
          self.logger.info('ConsoleWriter has been initiated')
          self.pretty_print = self.options.get('pretty_print', False)
  
      def write_batch(self, batch):
          for item in batch:
              print item.formatted
              self.increment_written_items()
              if self.items_limit and self.items_limit == self.items_count:
                  raise ItemsLimitReached('Finishing job after items_limit reached: {} items written.'.format(self.items_count))
          self.logger.debug('Wrote items')
  
subject: Fix items_count