In [1]:
## TODO:  Trigger pyspark_submit_pi DAG from Airflow REST API

In [ ]: