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