diff --git a/dbt/adapters/databricks/impl.py b/dbt/adapters/databricks/impl.py index 3f3438ea4..e4affbde6 100644 --- a/dbt/adapters/databricks/impl.py +++ b/dbt/adapters/databricks/impl.py @@ -449,7 +449,7 @@ def parse_columns_from_information( # type: ignore[override] columns.append(column) return columns - def get_catalog(self, manifest: Manifest) -> Tuple[Table, List[Exception]]: + def get_catalog(self, manifest: Manifest) -> Tuple[Table, List[Exception]]: # type: ignore schema_map = self._get_catalog_schemas(manifest) with executor(self.config) as tpe: diff --git a/dbt/adapters/databricks/relation.py b/dbt/adapters/databricks/relation.py index 29dd60634..07046f98b 100644 --- a/dbt/adapters/databricks/relation.py +++ b/dbt/adapters/databricks/relation.py @@ -1,5 +1,5 @@ from dataclasses import dataclass, field -from typing import Any, Dict, Optional, Set, Type +from typing import Any, Dict, Iterable, Optional, Set, Type from dbt.contracts.relation import ( ComponentName, ) @@ -141,5 +141,5 @@ def is_hive_metastore(database: Optional[str]) -> bool: return database is None or database.lower() == "hive_metastore" -def extract_identifiers(relations: Set[BaseRelation]) -> Set[str]: +def extract_identifiers(relations: Iterable[BaseRelation]) -> Set[str]: return {r.identifier for r in relations if r.identifier is not None}