We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 75f825e commit 4da5401Copy full SHA for 4da5401
sqlmesh/core/engine_adapter/trino.py
@@ -128,7 +128,7 @@ def replace_query(
128
supports_replace_table_override: t.Optional[bool] = None,
129
**kwargs: t.Any,
130
) -> None:
131
- catalog_type = self.get_catalog_type(self.get_catalog_type_from_table(table_name))
+ catalog_type = self.get_catalog_type_from_table(table_name)
132
# User may have a custom catalog type name so we are assuming they keep the catalog type still in the name
133
# Ex: `acme_iceberg` would be identified as an iceberg catalog and therefore supports replace table
134
supports_replace_table_override = None
0 commit comments