From a3e4dcbfc7cc96d48442ff85a95a42770cecdbcd Mon Sep 17 00:00:00 2001 From: Eugene Chung Date: Mon, 10 Jun 2024 22:53:18 +0000 Subject: [PATCH] Update --- app/06_load_daily_city_metrics.py | 2 +- steps/04_load_weather.sql | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/app/06_load_daily_city_metrics.py b/app/06_load_daily_city_metrics.py index 457d4df..012b8d5 100644 --- a/app/06_load_daily_city_metrics.py +++ b/app/06_load_daily_city_metrics.py @@ -13,7 +13,7 @@ def main(session: Session) -> str: # Define the tables order_detail = session.table("RAW_POS.ORDER_DETAIL") order_header = session.table("RAW_POS.ORDER_HEADER") - history_day = session.table("FROSTBYTE_WEATHERSOURCE.ONPOINT_ID.HISTORY_DAY") + history_day = session.table("TB_WEATHERSOURCE.ONPOINT_ID.HISTORY_DAY") location = session.table("RAW_POS.LOCATION") # Join the tables diff --git a/steps/04_load_weather.sql b/steps/04_load_weather.sql index b61f6a6..a9c25e2 100644 --- a/steps/04_load_weather.sql +++ b/steps/04_load_weather.sql @@ -56,4 +56,5 @@ GRANT IMPORTED PRIVILEGES ON DATABASE FROSTBYTE_WEATHERSOURCE TO ROLE HOL_ROLE; -- Let's look at the data - same 3-part naming convention as any other table -SELECT * FROM FROSTBYTE_WEATHERSOURCE.ONPOINT_ID.POSTAL_CODES LIMIT 100; +-- SELECT * FROM FROSTBYTE_WEATHERSOURCE.ONPOINT_ID.POSTAL_CODES LIMIT 100; +SELECT * FROM TB_WEATHERSOURCE.ONPOINT_ID.POSTAL_CODES LIMIT 100;