PySpark Pipeline in Airflow project