Skip to content

Commit

Permalink
Fixed sisue
Browse files Browse the repository at this point in the history
  • Loading branch information
rahulgoyal2987 committed Dec 9, 2024
1 parent b8fc1d2 commit c33e13d
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion dbt/adapters/spark/impl.py
Original file line number Diff line number Diff line change
Expand Up @@ -176,6 +176,7 @@ def list_relations_without_caching(self, schema_relation: BaseRelation) -> List[
"""Distinct Spark compute engines may not support the same SQL featureset. Thus, we must
try different methods to fetch relation information."""
try:
kwargs = {"schema_relation": schema_relation}
# Iceberg behavior: 3-row result of relations obtained
show_table_rows = self.execute_macro(
LIST_RELATIONS_SHOW_TABLES_MACRO_NAME, kwargs=kwargs
Expand Down Expand Up @@ -239,7 +240,7 @@ def get_relation(self, database: str, schema: str, identifier: str) -> Optional[
database = None # type: ignore

relation = super().get_relation(database, schema, identifier)
self.set_relation_information(relation) if relation else None
self.set_relation_information(relation) if relation else None

def parse_describe_extended(
self, relation: BaseRelation, raw_rows: AttrDict
Expand Down

0 comments on commit c33e13d

Please sign in to comment.