Calling Spark Scala Function from Python airflow dag code