Run pipeline

Trigger DAG

Place tutorial_dag.py and query.sql under the ./dags directory like below.

├── dags
│   ├── tutorial_dag.py
│   └── query.sql

After a slight delay, you can search the DAG by dag_id on Airflow UI.

Activate and trigger the DAG manually.

Check Data on BigQuery

After the DAG finishes successfully, check the BigQuery destination table to see the data mart as a result.