old_contents: # -*- coding: utf-8 -*-
  import simplejson as json
  from pkgutil import get_data
  
  from openprocurement.search.index import BaseIndex, logger
  
  
  class OrgsIndex(BaseIndex):
      """org-suggest index
      """
      __index_name__ = 'orgs'
  
      allow_async_reindex = False
  
      def need_reindex(self):
          if not self.current_index:
              return True
          if self.force_next_reindex:
              self.force_next_reindex = False
              return True
          return False
  
      def check_index(self, index_name):
          self.check_all_field = True
          self.skip_check_count = True
          return super(OrgsIndex, self).check_index(index_name)
  
      def index_item(self, index_name, item):
          try:
              return self.engine.index_item(index_name, item)
          except Exception as e:
              if self.config['ignore_errors']:
                  return None
              if not self.test_exists(index_name, item['meta']):
                  raise e
  
      def index_source(self, index_name=None, reset=False, reindex=False):
          res = BaseIndex.index_source(self, index_name, reset, reindex)
          # allow create empty index on reindex (only for orgs)
          if res == 0 and reset:
              return 1
          return res
  
      def create_index(self, name, settings='settings/orgs.json'):
          logger.info("Create new index %s from %s", name, settings)
          data = get_data(__name__, settings)
          body = json.loads(data)
          body['settings']['index']['number_of_shards'] = 2
          self.engine.create_index(name, body=body)
  
new_contents: # -*- coding: utf-8 -*-
  import simplejson as json
  from pkgutil import get_data
  
  from openprocurement.search.index import BaseIndex, logger
  
  
  class OrgsIndex(BaseIndex):
      """org-suggest index
      """
      __index_name__ = 'orgs'
  
      allow_async_reindex = False
  
      def need_reindex(self):
          if not self.current_index:
              return True
          if self.force_next_reindex:
              self.force_next_reindex = False
              return True
          return False
  
      def check_index(self, index_name):
          self.check_all_field = True
          self.skip_check_count = True
          return super(OrgsIndex, self).check_index(index_name)
  
      def index_item(self, index_name, item):
          try:
              return self.engine.index_item(index_name, item)
          except Exception as e:
              if self.config['ignore_errors']:
                  return None
              if not self.test_exists(index_name, item['meta']):
                  raise e
  
      def index_source(self, index_name=None, reset=False, reindex=False):
          res = BaseIndex.index_source(self, index_name, reset, reindex)
          # allow create empty index on reindex (only for orgs)
          if res == 0 and reset:
              return 1
          return res
  
      def create_index(self, name, settings='settings/orgs.json'):
          logger.info("Create new index %s from %s", name, settings)
          data = get_data(__name__, settings)
          body = json.loads(data)
          body['settings']['index']['number_of_shards'] = 1
          self.engine.create_index(name, body=body)
  
subject: change shards to 1 for orgs