def generate_actions()

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}