index creation

[riyaj8888]

can we create elastic search index inside Airflow DAG script?

from elasticsearch import Elasticsearch es = Elasticsearch("http://localhost:9200") es.indices.create(index=index_name, body=mappings)

but i am unable to create index inside that airflwo dag script. I am using Airflow Docker on window machine