This is a simple Transform job (from ELT, Extract Load Transform), done in dbt
, that uses Apache Airflow
that runs locally using Astronomer Cosmos for scheduling and Snowflake
as a data warehouse system.
The data is taken from a sample Snowflake's dataset. The code is written in python