code: def _set_es_workers(self, **kwargs):
          
          def make_es_worker(search_conn, es_index, es_doc_type, class_name):
              """
              Returns a new es_worker instance
  
              args:
              -----
                  search_conn: the connection to elasticsearch
                  es_index: the name of the elasticsearch index
                  es_doc_type: the name of the elasticsearch doctype
                  class_name: name of the rdf class that is being indexed
              """
              new_esbase = copy.copy(search_conn)
              new_esbase.es_index = es_index
              new_esbase.doc_type = es_doc_type
              log.info("Indexing '%s' into ES index '%s' doctype '%s'",
                       class_name.pyuri,
                       es_index,
                       es_doc_type)
              return new_esbase
  
          def additional_indexers(rdf_class):
              """
              returns additional classes to index based off of the es definitions
              """
              rtn_list = rdf_class.es_indexers()
              rtn_list.remove(rdf_class)
              return rtn_list
  
  
          self.es_worker = make_es_worker(self.search_conn,
                                          self.es_index,
                                          self.es_doc_type,
                                          self.rdf_class.__name__)
          if not kwargs.get("idx_only_base"):
              self.other_indexers = {item.__name__: make_es_worker(
                          self.search_conn,
                          item.es_defs.get('kds_esIndex')[0],
                          item.es_defs.get('kds_esDocType')[0],
                          item.__name__)
                      for item in additional_indexers(self.rdf_class)}
          else:
              self.other_indexers = {}
docs: Creates index worker instances for each class to index
  
          kwargs:
          -------
              idx_only_base[bool]: True will only index the base class