diff --git a/awswrangler/athena/_read.py b/awswrangler/athena/_read.py index 3ab4fa970..6c8f431f6 100644 --- a/awswrangler/athena/_read.py +++ b/awswrangler/athena/_read.py @@ -558,7 +558,9 @@ def _resolve_query_without_cache( boto3_session=boto3_session, ) finally: - catalog.delete_table_if_exists(database=database, table=name, boto3_session=boto3_session) + catalog.delete_table_if_exists( + database=ctas_database_name or database, table=name, boto3_session=boto3_session + ) return _resolve_query_without_cache_regular( sql=sql, database=database, diff --git a/tests/test_athena.py b/tests/test_athena.py index 9b21b34a0..7019e782a 100644 --- a/tests/test_athena.py +++ b/tests/test_athena.py @@ -112,7 +112,7 @@ def test_athena_ctas(path, path2, path3, glue_table, glue_table2, glue_database, ctas_temp_table_name=glue_table2, s3_output=path3, ) - assert wr.catalog.does_table_exist(database=glue_ctas_database, table=glue_table2) is True + assert wr.catalog.does_table_exist(database=glue_ctas_database, table=glue_table2) is False assert len(wr.s3.list_objects(path=path3)) > 2 assert len(wr.s3.list_objects(path=final_destination)) > 0 for df in dfs: