We are setting up dbt project in Snowflake and we are using Airflow for orchestration and scheduling purpose. I am planning to use BashOperator from Airflow to have the models executed. Is it possible to use SQLQueryOperator from Airflow. Which is the best method.
The context of why I’m trying to do this
What I’ve already tried
Some example code or error messages
Put code inside backticks
to preserve indentation
which is especially important
for Python and YAML!