I run it as a (additional) DAG on Airflow. Take a look at the example script (example.py).