Migrate PySpark to dbt