File tree Expand file tree Collapse file tree
sqlmesh/core/engine_adapter Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -166,6 +166,14 @@ def _create_schema(
166166 properties : t .List [exp .Expr ],
167167 kind : str ,
168168 ) -> None :
169+ schema = to_schema (schema_name )
170+ if schema .catalog and schema .catalog != self ._default_catalog :
171+ logger .info (
172+ "Skipping creation of schema '%s' because Athena does not support creating schemas in non-default catalogs." ,
173+ schema .sql (dialect = self .dialect ),
174+ )
175+ return
176+
169177 if location := self ._table_location (table_properties = None , table = exp .to_table (schema_name )):
170178 # don't add extra LocationProperty's if one already exists
171179 if not any (p for p in properties if isinstance (p , exp .LocationProperty )):
@@ -687,7 +695,7 @@ def _boto3_client(self, name: str) -> t.Any:
687695 conn = self .connection
688696 return conn .session .client (
689697 name ,
690- region_name = conn .region_̀name ,
698+ region_name = conn .region_name ,
691699 config = conn .config ,
692700 ** conn ._client_kwargs ,
693701 ) # type: ignore
You can’t perform that action at this time.
0 commit comments