Skip to content
This repository was archived by the owner on Sep 2, 2025. It is now read-only.

fix: get_columns_in_relation for LAMBDA catalogs #637

Merged
nicor88 merged 4 commits into from
Apr 29, 2024
Merged

fix: get_columns_in_relation for LAMBDA catalogs #637

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
0a93f91
fix get_columns_in_relation for non-athena catalogs
antonysouthworth-halter Apr 29, 2024
c5a2b14
fix ci
nicor88 Apr 29, 2024
5cb9ab1
Merge branch 'main' into patch-1
nicor88 Apr 29, 2024
6e8027e
Merge branch 'main' into patch-1
nicor88 Apr 29, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 8 additions & 3 deletions dbt/adapters/athena/impl.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1081,10 +1081,15 @@ def get_columns_in_relation(self, relation: AthenaRelation) -> List[AthenaColumn
config=get_boto3_config(num_retries=creds.effective_num_retries),
)

get_table_kwargs = dict(
DatabaseName=relation.schema,
Name=relation.identifier,
)
if catalog_id:
get_table_kwargs["CatalogId"] = catalog_id

try:
table = glue_client.get_table(CatalogId=catalog_id, DatabaseName=relation.schema, Name=relation.identifier)[
"Table"
]
table = glue_client.get_table(**get_table_kwargs)["Table"]
except ClientError as e:
if e.response["Error"]["Code"] == "EntityNotFoundException":
LOGGER.debug("table not exist, catching the error")
Expand Down