def insert_dataframe_to_elasticsearch()

in app/services/elasticsearch.py [0:0]

• 6 lines of code
• 2 McCabe index (conditional complexity)

def insert_dataframe_to_elasticsearch(
    es_client: Elasticsearch,
    index_name: str,
    dataframe: bf.DataFrame,
    doc_type: str = "kb",  # 'kb' or 'news'
    chunk_size: int = 500,