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;