diff --git a/swh/dataset/athena.py b/swh/dataset/athena.py index 779b23119bb79d00e0e2dea0b202dd30cad054d5..1798c1de9f0fe3923a10518e90e0460deea1d73f 100644 --- a/swh/dataset/athena.py +++ b/swh/dataset/athena.py @@ -107,12 +107,14 @@ def create_tables(database_name, dataset_location, output_location=None, replace """ client = boto3.client("athena") client.output_location = output_location - client.database_name = database_name + + client.database_name = "default" # we have to pick some existing database query( client, create_database(database_name), desc="Creating {} database".format(database_name), ) + client.database_name = database_name if replace: for table in TABLES: