diff --git a/dbt/adapters/spark/impl.py b/dbt/adapters/spark/impl.py index ab95e85f2..8e823664d 100644 --- a/dbt/adapters/spark/impl.py +++ b/dbt/adapters/spark/impl.py @@ -212,7 +212,7 @@ def list_relations_without_caching(self, schema_relation: BaseRelation) -> List[ def set_relation_information(self, relation: BaseRelation): if relation.information: return relation - rows: List[agate.Row] = super().get_columns_in_relations(relation) + rows: List[agate.Row] = super().get_columns_in_relation(relation) information = "" for info_row in rows: info_type, info_value = info_row.values()