docs: def bulk_load_docs(es, docs):
      """Bulk load docs
  
      Args:
          es: elasticsearch handle
          docs: Iterator of doc objects - includes index_name
      """
  
      chunk_size = 200
  
      try:
          results = elasticsearch.helpers.bulk(es, docs, chunk_size=chunk_size)
          log.debug(f"Elasticsearch documents loaded: {results[0]}")
  
          # elasticsearch.helpers.parallel_bulk(es, terms, chunk_size=chunk_size, thread_count=4)
          if len(results[1]) > 0:
              log.error("Bulk load errors {}".format(results))
      except elasticsearch.ElasticsearchException as e:
          log.error("Indexing error: {}\n".format(e))