Airflow Sqlalchemy Python Example