diff --git a/dbt/adapters/snowflake/impl.py b/dbt/adapters/snowflake/impl.py index 671906242..2143ba55d 100644 --- a/dbt/adapters/snowflake/impl.py +++ b/dbt/adapters/snowflake/impl.py @@ -3,7 +3,7 @@ import agate -from dbt.adapters.base.impl import AdapterConfig, ConstraintSupport # type: ignore +from dbt.adapters.base.impl import AdapterConfig, AdapterFeature, ConstraintSupport # type: ignore from dbt.adapters.base.meta import available from dbt.adapters.sql import SQLAdapter # type: ignore from dbt.adapters.sql.impl import ( @@ -256,6 +256,10 @@ def submit_python_job(self, parsed_model: dict, compiled_code: str): def valid_incremental_strategies(self): return ["append", "merge", "delete+insert"] + @classmethod + def has_feature(cls, feature: AdapterFeature) -> bool: + return feature in [AdapterFeature.CatalogByRelations] + def debug_query(self): """Override for DebugTask method""" self.execute("select 1 as id")