Skip to content

Commit

Permalink
add methods
Browse files Browse the repository at this point in the history
  • Loading branch information
nicor88 committed Nov 6, 2023
1 parent f5772f2 commit 4b9ecc9
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 0 deletions.
4 changes: 4 additions & 0 deletions dbt/adapters/athena/impl.py
Original file line number Diff line number Diff line change
Expand Up @@ -662,6 +662,10 @@ def list_relations_without_caching(self, schema_relation: AthenaRelation) -> Lis

return relations

@available
def get_catalog_relations(self, relations: List[AthenaRelation]) -> List[BaseRelation]:
raise NotImplementedError("get_catalog_relations is not implemented for Athena")

@available
def swap_table(self, src_relation: AthenaRelation, target_relation: AthenaRelation) -> None:
conn = self.connections.get_thread_connection()
Expand Down
4 changes: 4 additions & 0 deletions dbt/include/athena/macros/adapters/metadata.sql
Original file line number Diff line number Diff line change
Expand Up @@ -11,3 +11,7 @@
{% macro athena__list_relations_without_caching(schema_relation) %}
{{ return(adapter.list_relations_without_caching(schema_relation)) }}
{% endmacro %}

{% macro athena__get_catalog_relations(information_schema, relations) %}
{{ return(adapter.get_catalog_relations(relations)) }}
{% endmacro %}

0 comments on commit 4b9ecc9

Please sign in to comment.