diff --git a/dags/cwa_transformation_incremental_v_1_0_0.py b/dags/cwa_transformation_incremental_v_1_0_0.py index 296309d..03f5208 100644 --- a/dags/cwa_transformation_incremental_v_1_0_0.py +++ b/dags/cwa_transformation_incremental_v_1_0_0.py @@ -35,7 +35,7 @@ conn_id="snowflake_dev", profile_args={ "database": "weather_data", - "schema": "cwb_dev" + "schema": "cwb_dev_v2" }, )) diff --git a/dags/cwa_transformation_refresh_v_1_0_0.py b/dags/cwa_transformation_refresh_v_1_0_0.py index 989af64..be65ed6 100644 --- a/dags/cwa_transformation_refresh_v_1_0_0.py +++ b/dags/cwa_transformation_refresh_v_1_0_0.py @@ -35,7 +35,7 @@ conn_id="snowflake_dev", profile_args={ "database": "weather_data", - "schema": "cwb_dev" + "schema": "cwb_dev_v2" }, ))