diff --git a/dbt-athena/src/dbt/adapters/athena/relation.py b/dbt-athena/src/dbt/adapters/athena/relation.py index ed5495dea..7728c8557 100644 --- a/dbt-athena/src/dbt/adapters/athena/relation.py +++ b/dbt-athena/src/dbt/adapters/athena/relation.py @@ -131,6 +131,10 @@ def get_table_type(table: TableTypeDef) -> TableType: if table.get("Parameters", {}).get("table_type", "").lower() == "iceberg": _type = TableType.ICEBERG + elif table.get("Parameters", {}).get("EXTERNAL", "").lower() == "true": + _type = TableType.TABLE + elif table.get("Parameters", {}).get("createdBy", "").lower() == "appflow.amazonaws.com": + _type = TableType.TABLE elif not input_table_type: raise ValueError(f"Table type cannot be None for table {table_full_name}") else: