From f57671ee5d4070be81fada0ea95c9f82079ba5a6 Mon Sep 17 00:00:00 2001 From: HelgeSolvberg Date: Sun, 22 Feb 2026 22:01:29 +0100 Subject: [PATCH 1/6] Fixed errors --- module-1/hamburg_weather/pipeline/objects/views/views.sql | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/module-1/hamburg_weather/pipeline/objects/views/views.sql b/module-1/hamburg_weather/pipeline/objects/views/views.sql index a0f9d593..7888d2ed 100644 --- a/module-1/hamburg_weather/pipeline/objects/views/views.sql +++ b/module-1/hamburg_weather/pipeline/objects/views/views.sql @@ -7,8 +7,8 @@ SELECT TO_VARCHAR(hd.date_valid_std, 'YYYY-MM') AS yyyy_mm, pc.city_name AS city, c.country AS country_desc -FROM WEATHER_SOURCE_LLC_FROSTBYTE.onpoint_id.history_day hd -JOIN WEATHER_SOURCE_LLC_FROSTBYTE.onpoint_id.postal_codes pc +FROM FROSTBYTE_WEATHERSOURCE.onpoint_id.history_day hd +JOIN FROSTBYTE_WEATHERSOURCE.onpoint_id.postal_codes pc ON pc.postal_code = hd.postal_code AND pc.country = hd.country JOIN {{env}}_tasty_bytes.raw_pos.country c From 4bc43554878b14764b47082d780c3ef865f27a24 Mon Sep 17 00:00:00 2001 From: HelgeSolvberg Date: Mon, 23 Feb 2026 10:10:36 +0100 Subject: [PATCH 2/6] Fix missing data --- .../pipeline/data/load_tasty_bytes.sql | 35 ++++++++++--------- 1 file changed, 18 insertions(+), 17 deletions(-) diff --git a/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql b/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql index 4565f538..01c4d730 100644 --- a/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql +++ b/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql @@ -59,12 +59,13 @@ raw zone table build -- todo: complete table build CREATE TABLE {{env}}_tasty_bytes.raw_pos.country ( - country_id NUMBER(18,0), - country VARCHAR(16777216), - iso_currency VARCHAR(3), - iso_country VARCHAR(2), - city VARCHAR(16777216), - city_population VARCHAR(16777216) + country_id, + country, + iso_currency, + iso_country, + city_id, + city, + city_population ); @@ -293,17 +294,17 @@ USE WAREHOUSE demo_build_wh; -- country table load --- COPY INTO {{env}}_tasty_bytes.raw_pos.country --- ( --- country_id, --- country, --- iso_currency, --- iso_country, --- city_id, --- city, --- city_population --- ) --- FROM @{{env}}_tasty_bytes.public.s3load/raw_pos/country/; + COPY INTO {{env}}_tasty_bytes.raw_pos.country + ( + country_id, + country, + iso_currency, + iso_country, + city_id, + city, + city_population + ) + FROM @{{env}}_tasty_bytes.public.s3load/raw_pos/country/; -- franchise table load From e8512a690e1285e3d6bb9195ba336e28718b8483 Mon Sep 17 00:00:00 2001 From: HelgeSolvberg Date: Mon, 23 Feb 2026 10:23:30 +0100 Subject: [PATCH 3/6] Fix missing data 2 --- module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql b/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql index 01c4d730..416d5a6a 100644 --- a/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql +++ b/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql @@ -57,7 +57,7 @@ raw zone table build -- country table build -- todo: complete table build -CREATE TABLE {{env}}_tasty_bytes.raw_pos.country +CREATE OR ALTER TABLE {{env}}_tasty_bytes.raw_pos.country ( country_id, country, From 609164db948e64230d16cce646ea687a0bf67d9a Mon Sep 17 00:00:00 2001 From: HelgeSolvberg <90315806+HelgeSolvberg@users.noreply.github.com> Date: Mon, 23 Feb 2026 10:41:45 +0100 Subject: [PATCH 4/6] create main.yml --- .github/workflows/main.yml | 67 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 67 insertions(+) create mode 100644 .github/workflows/main.yml diff --git a/.github/workflows/main.yml b/.github/workflows/main.yml new file mode 100644 index 00000000..e7413e0c --- /dev/null +++ b/.github/workflows/main.yml @@ -0,0 +1,67 @@ +name: Deploy Templatized Data Environment + +on: + pull_request: + types: [closed] + branches: + - staging + - main + push: + branches: + - staging + - main + +jobs: + deploy_data_environment: + # Only run when PR is merged or on direct push to environment branches + if: github.event_name == 'push' || (github.event_name == 'pull_request' && github.event.pull_request.merged == true) + runs-on: ubuntu-latest + + env: + # Read connection secret + SNOWFLAKE_CONNECTIONS_ADVANCED_DATA_ENGINEERING_SNOWFLAKE_ACCOUNT: ${{ secrets.SNOWFLAKE_ACCOUNT }} + SNOWFLAKE_CONNECTIONS_ADVANCED_DATA_ENGINEERING_SNOWFLAKE_USER: ${{ secrets.SNOWFLAKE_USER }} + SNOWFLAKE_CONNECTIONS_ADVANCED_DATA_ENGINEERING_SNOWFLAKE_PASSWORD: ${{ secrets.SNOWFLAKE_PASSWORD }} + + steps: + # Checkout step is necessary to access repository files + - name: Checkout repository + uses: actions/checkout@v4 + + # Determine environment based on target branch + - name: Set environment + id: set_env + run: | + TARGET_BRANCH="${GITHUB_BASE_REF:-${GITHUB_REF#refs/heads/}}" + + if [[ $TARGET_BRANCH == "staging" ]]; then + echo "DEPLOY_ENV=staging" >> $GITHUB_ENV + echo "Environment set to staging" + elif [[ $TARGET_BRANCH == "main" ]]; then + echo "DEPLOY_ENV=prod" >> $GITHUB_ENV + echo "Environment set to production" + else + echo "Unexpected branch: $TARGET_BRANCH" + exit 1 + fi + + # Install Snowflake CLI GitHub Action and point to config file + - name: Install SnowflakeCLI + uses: snowflakedb/snowflake-cli-action@v1.5 + with: + cli-version: "latest" + default-config-file-path: "config.toml" + + # Fetch latest changes from the repository to Snowflake + - name: Fetch latest changes to Snowflake + run: snow git fetch course_repo.public.advanced_data_engineering_snowflake + + # Deploy templates to the data environment - + - name: Deploy templates to data environment + run: | + # Export TARGET_BRANCH for use in this step + echo "Using branch: ${GITHUB_REF_NAME}" + snow git execute @advanced_data_engineering_snowflake/branches/${GITHUB_REF_NAME}/module-1/hamburg_weather/pipeline/data/ \ + -D "env='${{ env.DEPLOY_ENV }}'" \ + --database=COURSE_REPO \ + --schema=PUBLIC From 3fb0f65c157eeb3388976b3e7000388bb6c9b305 Mon Sep 17 00:00:00 2001 From: HelgeSolvberg Date: Mon, 23 Feb 2026 10:55:51 +0100 Subject: [PATCH 5/6] Fix weather database --- module-1/hamburg_weather/pipeline/objects/views/views.sql | 1 + 1 file changed, 1 insertion(+) diff --git a/module-1/hamburg_weather/pipeline/objects/views/views.sql b/module-1/hamburg_weather/pipeline/objects/views/views.sql index 7888d2ed..ef9e9636 100644 --- a/module-1/hamburg_weather/pipeline/objects/views/views.sql +++ b/module-1/hamburg_weather/pipeline/objects/views/views.sql @@ -7,6 +7,7 @@ SELECT TO_VARCHAR(hd.date_valid_std, 'YYYY-MM') AS yyyy_mm, pc.city_name AS city, c.country AS country_desc + --Corrected database name FROM FROSTBYTE_WEATHERSOURCE.onpoint_id.history_day hd JOIN FROSTBYTE_WEATHERSOURCE.onpoint_id.postal_codes pc ON pc.postal_code = hd.postal_code From 4101d58c8278959058b571287988474ecb7159ea Mon Sep 17 00:00:00 2001 From: HelgeSolvberg Date: Mon, 23 Feb 2026 11:42:25 +0100 Subject: [PATCH 6/6] Update load_tasty_bytes.sql --- module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql b/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql index 4565f538..0b3d0659 100644 --- a/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql +++ b/module-1/hamburg_weather/pipeline/data/load_tasty_bytes.sql @@ -64,7 +64,8 @@ CREATE TABLE {{env}}_tasty_bytes.raw_pos.country iso_currency VARCHAR(3), iso_country VARCHAR(2), city VARCHAR(16777216), - city_population VARCHAR(16777216) + city_population VARCHAR(16777216), + city_id NUMBER(19,0) );