in app/services/elasticsearch.py [0:0]
def generate_actions():
for _, row in dataframe.iterrows():
doc = row.to_dict()
doc["doc_type"] = doc_type # Add document type
yield {"_index": index_name, "_source": doc}