We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d41c3e0 commit 434c052Copy full SHA for 434c052
sqlmesh/core/engine_adapter/snowflake.py
@@ -526,7 +526,8 @@ def _get_data_objects(
526
type=DataObjectType.from_str(row.type), # type: ignore
527
clustering_key=row.clustering_key, # type: ignore
528
)
529
- for row in df.itertuples()
+ # lowercase the column names for cases where Snowflake might return uppercase column names for certain catalogs
530
+ for row in df.rename(columns={col: col.lower() for col in df.columns}).itertuples()
531
]
532
533
def set_current_catalog(self, catalog: str) -> None:
0 commit comments