From 6522f87a5b19d4186acf815352c841a35eb0eca4 Mon Sep 17 00:00:00 2001 From: Dave Date: Wed, 17 Apr 2024 14:02:01 +0200 Subject: [PATCH] fix athena iceberg locations --- dlt/destinations/impl/athena/athena.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dlt/destinations/impl/athena/athena.py b/dlt/destinations/impl/athena/athena.py index 1beb249386..25152ec06f 100644 --- a/dlt/destinations/impl/athena/athena.py +++ b/dlt/destinations/impl/athena/athena.py @@ -367,7 +367,7 @@ def _get_table_update_sql( if is_iceberg: sql.append(f"""CREATE TABLE {qualified_table_name} ({columns}) - LOCATION '{location}' + LOCATION '{location.rstrip('/')}' TBLPROPERTIES ('table_type'='ICEBERG', 'format'='parquet');""") elif table_format == "jsonl": sql.append(f"""CREATE EXTERNAL TABLE {qualified_table_name}