We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f92dfd1 commit 154b56eCopy full SHA for 154b56e
sqlmesh/core/engine_adapter/snowflake.py
@@ -90,7 +90,10 @@ def query_factory() -> Query:
90
#
91
# The above issue has already been fixed upstream, but we keep the following
92
# line anyway in order to support a wider range of Snowflake versions.
93
- self.cursor.execute(f'USE SCHEMA "{temp_table.db}"')
+ schema = f'"{temp_table.db}"'
94
+ if temp_table.catalog:
95
+ schema = f'"{temp_table.catalog}".{schema}'
96
+ self.cursor.execute(f"USE SCHEMA {schema}")
97
98
# See: https://stackoverflow.com/a/75627721
99
for column, kind in columns_to_types.items():
0 commit comments